org.apache.beam.sdk.coders

Class StructuredCoder<T>

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

AtomicCoder, FailsafeValueInSingleWindow.Coder, FileBasedSink.FileResultCoder, GlobalWindow.Coder, IntervalWindow.IntervalWindowCoder, IterableLikeCoder, KafkaRecordCoder, KvCoder, LengthPrefixCoder, MapCoder, NullableCoder, PCollectionViews.ValueOrMetadataCoder, ProducerRecordCoder, ReadableFileCoder, ShardedKeyCoder, SnappyCoder, SortedMapCoder, TestStream.TestStreamCoder, TimestampedValue.TimestampedValueCoder, TimestampPrefixingWindowCoder, TopicPartitionCoder, UnionCoder, ValueInSingleWindow.Coder, ValueWithRecordId.ValueWithRecordIdCoder, VarLongCoder

public abstract class StructuredCoder<T>
extends Coder<T>

An abstract base class to implement a Coder that defines equality, hashing, and printing via the class name and recursively using getComponents().

A StructuredCoder should be defined purely in terms of its component coders, and contain no additional configuration.

To extend StructuredCoder, override the following methods as appropriate:

• getComponents(): the default implementation returns Coder.getCoderArguments().
• Coder.getEncodedElementByteSize(T) and Coder.isRegisterByteSizeObserverCheap(T): the default implementation encodes values to bytes and counts the bytes, which is considered expensive. The default element byte size observer uses the value returned by Coder.getEncodedElementByteSize(T).

See Also:

Serialized Form

Nested Class Summary

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

Coder.Context, Coder.NonDeterministicException

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	StructuredCoder()

Method Summary

Modifier and Type	Method and Description
boolean	equals(@Nullable java.lang.Object o)
java.util.List<? extends Coder<?>>	getComponents() Returns the list of Coders that are components of this Coder.
int	hashCode()
java.lang.String	toString()

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

consistentWithEquals, decode, decode, encode, encode, getCoderArguments, getEncodedElementByteSize, getEncodedTypeDescriptor, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic, verifyDeterministic

Methods inherited from class java.lang.Object

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

Constructor Detail

StructuredCoder

protected StructuredCoder()

Method Detail

getComponents

public java.util.List<? extends Coder<?>> getComponents()

Returns the list of Coders that are components of this Coder.

The default components will be equal to the value returned by Coder.getCoderArguments().

equals

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

Overrides:

equals in class java.lang.Object

Returns:

true if the two StructuredCoder instances have the same class and equal components.

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object