Package org.apache.beam.sdk.schemas
Class AvroRecordSchema
- java.lang.Object
-
- org.apache.beam.sdk.schemas.GetterBasedSchemaProvider
-
- org.apache.beam.sdk.schemas.AvroRecordSchema
-
- All Implemented Interfaces:
java.io.Serializable
,SchemaProvider
public class AvroRecordSchema extends GetterBasedSchemaProvider
ASchemaProvider
for AVRO generated SpecificRecords and POJOs.This provider infers a schema from generated SpecificRecord objects, and creates schemas and rows that bind to the appropriate fields. This provider also infers schemas from Java POJO objects, creating a schema that matches that inferred by the AVRO libraries.
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AvroRecordSchema()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.List<FieldValueGetter>
fieldValueGetters(java.lang.Class<?> targetClass, Schema schema)
Implementing class should override to return FieldValueGetters.java.util.List<FieldValueTypeInformation>
fieldValueTypeInformations(java.lang.Class<?> targetClass, Schema schema)
Implementing class should override to return a list of type-informations.<T> Schema
schemaFor(TypeDescriptor<T> typeDescriptor)
Lookup a schema for the given type.SchemaUserTypeCreator
schemaTypeCreator(java.lang.Class<?> targetClass, Schema schema)
Implementing class should override to return a constructor.-
Methods inherited from class org.apache.beam.sdk.schemas.GetterBasedSchemaProvider
equals, fromRowFunction, hashCode, toRowFunction
-
-
-
-
Method Detail
-
schemaFor
public <T> Schema schemaFor(TypeDescriptor<T> typeDescriptor)
Description copied from interface:SchemaProvider
Lookup a schema for the given type. If no schema exists, returns null.
-
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 classGetterBasedSchemaProvider
-
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 classGetterBasedSchemaProvider
-
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 classGetterBasedSchemaProvider
-
-