org.apache.beam.sdk.schemas

Class GetterBasedSchemaProvider

java.lang.Object

org.apache.beam.sdk.schemas.GetterBasedSchemaProvider

All Implemented Interfaces:

java.io.Serializable, SchemaProvider

Direct Known Subclasses:

AutoValueSchema, AvroRecordSchema, JavaBeanSchema, JavaFieldSchema

@Experimental(value=SCHEMAS)
public abstract class GetterBasedSchemaProvider
extends java.lang.Object
implements SchemaProvider

A SchemaProvider base class that vends schemas and rows based on FieldValueGetters.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GetterBasedSchemaProvider()

Method Summary

Modifier and Type	Method and Description
<T> SerializableFunction<Row,T>	fromRowFunction(TypeDescriptor<T> typeDescriptor) Given a type, returns a function that converts from a Row object to that type.
<T> SerializableFunction<T,Row>	toRowFunction(TypeDescriptor<T> typeDescriptor) Given a type, return a function that converts that type to a Row object If no schema exists, returns null.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.schemas.SchemaProvider

schemaFor

Constructor Detail

GetterBasedSchemaProvider

public GetterBasedSchemaProvider()

Method Detail

toRowFunction

public <T> SerializableFunction<T,Row> toRowFunction(TypeDescriptor<T> typeDescriptor)

Description copied from interface: SchemaProvider

Given a type, return a function that converts that type to a Row object If no schema exists, returns null.

Specified by:

toRowFunction in interface SchemaProvider

fromRowFunction

public <T> SerializableFunction<Row,T> fromRowFunction(TypeDescriptor<T> typeDescriptor)

Description copied from interface: SchemaProvider

Given a type, returns a function that converts from a Row object to that type. If no schema exists, returns null.

Specified by:

fromRowFunction in interface SchemaProvider