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, ProtoMessageSchema, ThriftSchema

@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
boolean	equals(@Nullable java.lang.Object obj)
abstract java.util.List<FieldValueGetter>	fieldValueGetters(java.lang.Class<?> targetClass, Schema schema) Implementing class should override to return FieldValueGetters.
abstract java.util.List<FieldValueTypeInformation>	fieldValueTypeInformations(java.lang.Class<?> targetClass, Schema schema) Implementing class should override to return a list of type-informations.
<T> SerializableFunction<Row,T>	fromRowFunction(TypeDescriptor<T> typeDescriptor) Given a type, returns a function that converts from a Row object to that type.
int	hashCode()
abstract SchemaUserTypeCreator	schemaTypeCreator(java.lang.Class<?> targetClass, Schema schema) Implementing class should override to return a constructor.
<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, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

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

schemaFor

Constructor Detail

GetterBasedSchemaProvider

public GetterBasedSchemaProvider()

Method Detail

fieldValueGetters

public abstract java.util.List<FieldValueGetter> fieldValueGetters(java.lang.Class<?> targetClass,
                                                                   Schema schema)

Implementing class should override to return FieldValueGetters.

fieldValueTypeInformations

public abstract java.util.List<FieldValueTypeInformation> fieldValueTypeInformations(java.lang.Class<?> targetClass,
                                                                                     Schema schema)

Implementing class should override to return a list of type-informations.

schemaTypeCreator

public abstract SchemaUserTypeCreator schemaTypeCreator(java.lang.Class<?> targetClass,
                                                        Schema schema)

Implementing class should override to return a constructor.

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

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(@Nullable java.lang.Object obj)

Overrides:

equals in class java.lang.Object