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 java.lang.Object

Converts Arrow schema to Beam row schema.

Constructor Summary

Constructors

Constructor and Description
ArrowSchemaTranslator()

Method Summary

Modifier and Type	Method and Description
static Schema	toBeamSchema(java.util.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 Detail

ArrowSchemaTranslator

public ArrowSchemaTranslator()

Method Detail

toBeamSchema

public static Schema toBeamSchema(Schema schema)

toBeamSchema

public static Schema toBeamSchema(java.util.List<Field> fields)