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
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

CODER_MAP, schema

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
int	hashCode()
static RowCoder	of(Schema 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)

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class SchemaCoder<Row>

hashCode

public int hashCode()

Overrides:

hashCode in class SchemaCoder<Row>