Class StructuredCoder<T>

java.lang.Object
org.apache.beam.sdk.coders.Coder<T>
org.apache.beam.sdk.coders.StructuredCoder<T>
All Implemented Interfaces:
Serializable
Direct Known Subclasses:
AtomicCoder, FailsafeValueInSingleWindow.Coder, FileBasedSink.FileResultCoder, GlobalWindow.Coder, IntervalWindow.IntervalWindowCoder, IsmFormat.MetadataKeyCoder, IterableLikeCoder, KafkaRecordCoder, KvCoder, LengthPrefixCoder, MapCoder, NullableCoder, OptionalCoder, PCollectionViews.ValueOrMetadataCoder, ProducerRecordCoder, ReadableFileCoder, ShardedKeyCoder, SingletonKeyedWorkItemCoder, SnappyCoder, SortedMapCoder, TestStream.TestStreamCoder, TimestampedValue.TimestampedValueCoder, TimestampPrefixingWindowCoder, TopicPartitionCoder, UnionCoder, ValueInSingleWindow.Coder, ValueWithRecordId.ValueWithRecordIdCoder, VarLongCoder, WindowedValues.WindowedValueCoder

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:

See Also:
  • Constructor Details

    • StructuredCoder

      protected StructuredCoder()
  • Method Details