org.apache.beam.sdk.transforms

Class DoFnSchemaInformation

java.lang.Object

org.apache.beam.sdk.transforms.DoFnSchemaInformation

All Implemented Interfaces:

java.io.Serializable

@Experimental(value=SCHEMAS)
 @Internal
public abstract class DoFnSchemaInformation
extends java.lang.Object
implements java.io.Serializable

Represents information about how a DoFn extracts schemas.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DoFnSchemaInformation.Builder The builder object.

Constructor Summary

Constructors

Constructor and Description
DoFnSchemaInformation()

Method Summary

Modifier and Type	Method and Description
static DoFnSchemaInformation	create() Create an instance.
abstract java.util.List<SerializableFunction<?,?>>	getElementConverters() The schema of the @Element parameter.
abstract FieldAccessDescriptor	getFieldAccessDescriptor() Effective FieldAccessDescriptor applied by DoFn.
abstract DoFnSchemaInformation.Builder	toBuilder()

Methods inherited from class java.lang.Object

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

Constructor Detail

DoFnSchemaInformation

public DoFnSchemaInformation()

Method Detail

getElementConverters

public abstract java.util.List<SerializableFunction<?,?>> getElementConverters()

The schema of the @Element parameter. If the Java type does not match the input PCollection but the schemas are compatible, Beam will automatically convert between the Java types.

getFieldAccessDescriptor

public abstract FieldAccessDescriptor getFieldAccessDescriptor()

Effective FieldAccessDescriptor applied by DoFn.

create

public static DoFnSchemaInformation create()

Create an instance.

toBuilder

public abstract DoFnSchemaInformation.Builder toBuilder()