org.apache.beam.sdk.values.reflect

Class RowFactory

java.lang.Object

org.apache.beam.sdk.values.reflect.RowFactory

All Implemented Interfaces:

java.io.Serializable

@Internal
public class RowFactory
extends java.lang.Object
implements java.io.Serializable

For internal use only; no backwards-compatibility guarantees.

Generates the code to create Schemas and Rows based on pojos.

Generated record types are cached in the instance of this factory.

At the moment single pojo class corresponds to single Schema.

Supported pojo getter types depend on types supported by the SchemaFactory. See DefaultSchemaFactory for default implementation.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
<T> Row	create(T pojo) Create a Row of the pojo.
static RowFactory	createDefault() Creates an instance of RowFactory using DefaultSchemaFactory and GeneratedGetterFactory.
<T> Schema	getSchema(java.lang.Class<T> elementType)
static RowFactory	of(SchemaFactory schemaFactory, org.apache.beam.sdk.values.reflect.GetterFactory getterFactory) Creates an instance of RowFactory using provided SchemaFactory and GetterFactory.
static RowFactory	withSchemaFactory(SchemaFactory schemaFactory) Creates an instance of RowFactory using provided SchemaFactory and GeneratedGetterFactory.

Methods inherited from class java.lang.Object

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

Method Detail

createDefault

public static RowFactory createDefault()

Creates an instance of RowFactory using DefaultSchemaFactory and GeneratedGetterFactory.

withSchemaFactory

public static RowFactory withSchemaFactory(SchemaFactory schemaFactory)

Creates an instance of RowFactory using provided SchemaFactory and GeneratedGetterFactory.

of

public static RowFactory of(SchemaFactory schemaFactory,
                            org.apache.beam.sdk.values.reflect.GetterFactory getterFactory)

Creates an instance of RowFactory using provided SchemaFactory and GetterFactory.

getSchema

public <T> Schema getSchema(java.lang.Class<T> elementType)

create

public <T> Row create(T pojo)

Create a Row of the pojo.

This implementation copies the return values of the pojo getters into the record fields on creation.

Currently all public getters are used to populate the record type and instance.

Field names for getters are stripped of the 'get' prefix. For example record field 'name' will be generated for 'getName()' pojo method.