org.apache.beam.sdk.values.reflect

Interface SchemaFactory

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

DefaultSchemaFactory

@Internal
public interface SchemaFactory
extends java.io.Serializable

For internal use only; no backwards-compatibility guarantees.

Interface for factories used to create record types based on getters.

Different implementations can have different ways of mapping getter types to coders. For example Beam SQL uses custom mapping via java.sql.Types.

Default implementation is DefaultSchemaFactory. It returns instances of Schema, mapping FieldValueGetter.type() to known coders.

Method Summary

Modifier and Type	Method and Description
Schema	createSchema(java.lang.Iterable<FieldValueGetter> getters) Create a Schema for the list of the pojo field getters.

Method Detail

createSchema

Schema createSchema(java.lang.Iterable<FieldValueGetter> getters)

Create a Schema for the list of the pojo field getters.