Package org.apache.beam.sdk.extensions.arrow

Class ArrowConversion.ArrowSchemaTranslator

java.lang.Object

org.apache.beam.sdk.extensions.arrow.ArrowConversion.ArrowSchemaTranslator

Enclosing class:

ArrowConversion

public static class ArrowConversion.ArrowSchemaTranslator
extends Object

Converts Arrow schema to Beam row schema.

Constructor Summary

Constructors

Constructor	Description
ArrowSchemaTranslator()

Method Summary

Modifier and Type	Method	Description
static Schema	toArrowSchema(Schema schema)	Converts a supported Beam row schema to an Arrow schema.
static Schema	toBeamSchema(List<Field> fields)
static Schema	toBeamSchema(Schema schema)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ArrowSchemaTranslator

public ArrowSchemaTranslator()

Method Details

toArrowSchema

public static Schema toArrowSchema(Schema schema)

Converts a supported Beam row schema to an Arrow schema.

toBeamSchema

public static Schema toBeamSchema(Schema schema)

toBeamSchema

public static Schema toBeamSchema(List<Field> fields)