org.apache.beam.sdk.transforms

Class DoFnSchemaInformation

java.lang.Object

org.apache.beam.sdk.transforms.DoFnSchemaInformation

All Implemented Interfaces:

java.io.Serializable

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 SchemaCoder<?>	getElementParameterSchema() The schema of the @Element parameter.
abstract DoFnSchemaInformation.Builder	toBuilder()
<T> DoFnSchemaInformation	withElementParameterSchema(SchemaCoder<T> schemaCoder)

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

getElementParameterSchema

@Nullable
public abstract SchemaCoder<?> getElementParameterSchema()

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.

create

public static DoFnSchemaInformation create()

Create an instance.

toBuilder

public abstract DoFnSchemaInformation.Builder toBuilder()

withElementParameterSchema

public <T> DoFnSchemaInformation withElementParameterSchema(SchemaCoder<T> schemaCoder)