Package org.apache.beam.sdk.io.aws2.schemas

Class AwsSchemaProvider

java.lang.Object

org.apache.beam.sdk.schemas.GetterBasedSchemaProvider

org.apache.beam.sdk.schemas.GetterBasedSchemaProviderV2

org.apache.beam.sdk.io.aws2.schemas.AwsSchemaProvider

All Implemented Interfaces:

Serializable, SchemaProvider

public class AwsSchemaProvider
extends GetterBasedSchemaProviderV2

Schema provider for AWS SdkPojo models using the provided field metadata (@see SdkPojo.sdkFields()) rather than reflection.

Note: Beam doesn't support self-referential schemas. Some AWS models are not compatible with schemas for that reason and require a dedicated coder, such as DynamoDB AttributeValue (coder).

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
AwsSchemaProvider()

Method Summary

Modifier and Type	Method	Description
<T> List<FieldValueGetter<@NonNull T,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.
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.
<T> SerializableFunction<Row,T>	fromRowFunction(TypeDescriptor<T> type)	Given a type, returns a function that converts from a Row object to that type.
<T> @Nullable Schema	schemaFor(TypeDescriptor<T> type)	Lookup a schema for the given type.
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.GetterBasedSchemaProviderV2

fieldValueGetters, fieldValueTypeInformations, schemaTypeCreator

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

equals, hashCode, toRowFunction

Methods inherited from class java.lang.Object

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

Constructor Details

AwsSchemaProvider

public AwsSchemaProvider()

Method Details

schemaFor

public <T> @Nullable Schema schemaFor(TypeDescriptor<T> type)

Description copied from interface: SchemaProvider

Lookup a schema for the given type. If no schema exists, returns null.

fieldValueGetters

public <T>
List<FieldValueGetter<@NonNull T,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.

Specified by:

fieldValueGetters in class GetterBasedSchemaProviderV2

fromRowFunction

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

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

Overrides:

fromRowFunction in class GetterBasedSchemaProvider

fieldValueTypeInformations

public 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.

Specified by:

fieldValueTypeInformations in class GetterBasedSchemaProviderV2

schemaTypeCreator

public 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.

Specified by:

schemaTypeCreator in class GetterBasedSchemaProviderV2