org.apache.beam.sdk.extensions.sql

Class SqlRowTypeFactory

java.lang.Object

org.apache.beam.sdk.extensions.sql.SqlRowTypeFactory

All Implemented Interfaces:

RowTypeFactory

@Internal
public class SqlRowTypeFactory
extends java.lang.Object
implements RowTypeFactory

For internal use only; no backwards-compatibility guarantees.

Implementation of the RowTypeFactory to return instances of RowType with coders specific for SQL types, see SqlTypeCoders.

Constructor Summary

Constructors

Constructor and Description
SqlRowTypeFactory()

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlRowTypeFactory

public SqlRowTypeFactory()

Method Detail

createRowType

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

Description copied from interface: RowTypeFactory

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

Specified by:

createRowType in interface RowTypeFactory