org.apache.beam.sdk.values.reflect

Class DefaultSchemaFactory

java.lang.Object

org.apache.beam.sdk.values.reflect.DefaultSchemaFactory

All Implemented Interfaces:

java.io.Serializable, SchemaFactory

public class DefaultSchemaFactory
extends java.lang.Object
implements SchemaFactory

A default implementation of the SchemaFactory interface. The purpose of the factory is to create a row types given a list of getters.

Row type is represented by Schema which essentially is a List<Pair<FieldName, Coder>>.

Getters (e.g. pojo field getters) are represented by FieldValueGetter interface, which exposes the field's name (see FieldValueGetter.name()) and java type (see FieldValueGetter.type()).

This is the default factory implementation used in RowFactory.

In other cases, when mapping requires extra logic, another implentation of the SchemaFactory should be used instead of this class.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DefaultSchemaFactory()

Method Summary

Modifier and Type	Method and Description
Schema	createSchema(java.lang.Iterable<FieldValueGetter> fieldValueGetters) Uses FieldValueGetter.name() as field names.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSchemaFactory

public DefaultSchemaFactory()

Method Detail

createSchema

public Schema createSchema(java.lang.Iterable<FieldValueGetter> fieldValueGetters)

Uses FieldValueGetter.name() as field names. Uses CoderRegistry.createDefault() to get coders for FieldValueGetter.type().

Specified by:

createSchema in interface SchemaFactory