Package org.apache.beam.sdk.coders

Class RowCoder

java.lang.Object

org.apache.beam.sdk.coders.Coder<T>

org.apache.beam.sdk.coders.CustomCoder<T>

org.apache.beam.sdk.schemas.SchemaCoder<Row>

org.apache.beam.sdk.coders.RowCoder

All Implemented Interfaces:

java.io.Serializable

@Experimental(SCHEMAS)
public class RowCoder
extends SchemaCoder<Row>

A sub-class of SchemaCoder that can only encode Row instances.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.coders.Coder

Coder.Context, Coder.NonDeterministicException

Field Summary

Fields inherited from class org.apache.beam.sdk.schemas.SchemaCoder

schema

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable java.lang.Object o)
int	hashCode()
static RowCoder	of(Schema schema)
static void	overrideEncodingPositions(java.util.UUID uuid, java.util.Map<java.lang.String,java.lang.Integer> encodingPositions)	Override encoding positions for the given schema.

Methods inherited from class org.apache.beam.sdk.schemas.SchemaCoder

coderForFieldType, consistentWithEquals, decode, encode, getEncodedTypeDescriptor, getFromRowFunction, getSchema, getToRowFunction, of, toString, verifyDeterministic

Methods inherited from class org.apache.beam.sdk.coders.CustomCoder

getCoderArguments

Methods inherited from class org.apache.beam.sdk.coders.Coder

decode, encode, getEncodedElementByteSize, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

of

public static RowCoder of(Schema schema)

overrideEncodingPositions

public static void overrideEncodingPositions(java.util.UUID uuid,
                                             java.util.Map<java.lang.String,java.lang.Integer> encodingPositions)

Override encoding positions for the given schema.

equals

public boolean equals(@Nullable java.lang.Object o)

Overrides:

equals in class SchemaCoder<Row>

hashCode

public int hashCode()

Overrides:

hashCode in class SchemaCoder<Row>