org.apache.beam.sdk.values.reflect

Interface RowTypeFactory

All Known Implementing Classes:

SqlRowTypeFactory

@Internal
public interface RowTypeFactory

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 DefaultRowTypeFactory. It returns instances of RowType, mapping FieldValueGetter.type() to known coders.

Method Summary

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

Method Detail

createRowType

RowType createRowType(java.lang.Iterable<FieldValueGetter> getters)

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