Package org.apache.beam.sdk.transforms

Class DoFnSchemaInformation

java.lang.Object

org.apache.beam.sdk.transforms.DoFnSchemaInformation

All Implemented Interfaces:

Serializable

@Internal
public abstract class DoFnSchemaInformation
extends Object
implements Serializable

Represents information about how a DoFn extracts schemas.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor	Description
DoFnSchemaInformation()

Method Summary

Modifier and Type	Method	Description
static DoFnSchemaInformation	create()	Create an instance.
abstract 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 Details

DoFnSchemaInformation

public DoFnSchemaInformation()

Method Details

getElementConverters

public abstract 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()