org.apache.beam.sdk.schemas

Class GetterBasedSchemaProviderV2

java.lang.Object

org.apache.beam.sdk.schemas.GetterBasedSchemaProvider

org.apache.beam.sdk.schemas.GetterBasedSchemaProviderV2

All Implemented Interfaces:

java.io.Serializable, SchemaProvider

Direct Known Subclasses:

AutoValueSchema, AvroRecordSchema, AwsSchemaProvider, JavaBeanSchema, JavaFieldSchema, ProtoMessageSchema, ThriftSchema

public abstract class GetterBasedSchemaProviderV2
extends GetterBasedSchemaProvider

A newer version of GetterBasedSchemaProvider, which works with TypeDescriptors, and which by default delegates the old, Class based methods, to the new ones.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GetterBasedSchemaProviderV2()

Method Summary

Modifier and Type	Method and Description
java.util.List<FieldValueGetter>	fieldValueGetters(java.lang.Class<?> targetClass, Schema schema) Implementing class should override to return FieldValueGetters.
abstract <T> java.util.List<FieldValueGetter<T,java.lang.Object>>	fieldValueGetters(TypeDescriptor<T> targetTypeDescriptor, Schema schema) Delegates to the GetterBasedSchemaProvider.fieldValueGetters(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.
java.util.List<FieldValueTypeInformation>	fieldValueTypeInformations(java.lang.Class<?> targetClass, Schema schema) Implementing class should override to return a list of type-informations.
abstract java.util.List<FieldValueTypeInformation>	fieldValueTypeInformations(TypeDescriptor<?> targetTypeDescriptor, Schema schema) Delegates to the GetterBasedSchemaProvider.fieldValueTypeInformations(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.
SchemaUserTypeCreator	schemaTypeCreator(java.lang.Class<?> targetClass, Schema schema) Implementing class should override to return a constructor.
abstract SchemaUserTypeCreator	schemaTypeCreator(TypeDescriptor<?> targetTypeDescriptor, Schema schema) Delegates to the GetterBasedSchemaProvider.schemaTypeCreator(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.

Methods inherited from class org.apache.beam.sdk.schemas.GetterBasedSchemaProvider

equals, fromRowFunction, hashCode, toRowFunction

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

GetterBasedSchemaProviderV2

public GetterBasedSchemaProviderV2()

Method Detail

fieldValueGetters

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

Description copied from class: GetterBasedSchemaProvider

Implementing class should override to return FieldValueGetters.

Specified by:

fieldValueGetters in class GetterBasedSchemaProvider

fieldValueGetters

public abstract <T> java.util.List<FieldValueGetter<T,java.lang.Object>> fieldValueGetters(TypeDescriptor<T> targetTypeDescriptor,
                                                                                           Schema schema)

Description copied from class: GetterBasedSchemaProvider

Delegates to the GetterBasedSchemaProvider.fieldValueGetters(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.

Overrides:

fieldValueGetters in class GetterBasedSchemaProvider

fieldValueTypeInformations

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

Description copied from class: GetterBasedSchemaProvider

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

Specified by:

fieldValueTypeInformations in class GetterBasedSchemaProvider

fieldValueTypeInformations

public abstract java.util.List<FieldValueTypeInformation> fieldValueTypeInformations(TypeDescriptor<?> targetTypeDescriptor,
                                                                                     Schema schema)

Description copied from class: GetterBasedSchemaProvider

Delegates to the GetterBasedSchemaProvider.fieldValueTypeInformations(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.

Overrides:

fieldValueTypeInformations in class GetterBasedSchemaProvider

schemaTypeCreator

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

Description copied from class: GetterBasedSchemaProvider

Implementing class should override to return a constructor.

Specified by:

schemaTypeCreator in class GetterBasedSchemaProvider

schemaTypeCreator

public abstract SchemaUserTypeCreator schemaTypeCreator(TypeDescriptor<?> targetTypeDescriptor,
                                                        Schema schema)

Description copied from class: GetterBasedSchemaProvider

Delegates to the GetterBasedSchemaProvider.schemaTypeCreator(Class, Schema) for backwards compatibility, override it if you want to use the richer type signature contained in the TypeDescriptor not subject to the type erasure.

Overrides:

schemaTypeCreator in class GetterBasedSchemaProvider