org.apache.beam.sdk.util.construction

Interface CoderTranslator<T extends Coder<?>>

public interface CoderTranslator<T extends Coder<?>>

An interface that translates coders to components and back.

This interface is incomplete. Coders must in the general case have the capability to encode an additional payload, which is not currently supported. This exists as a temporary measure.

Method Summary

Modifier and Type	Method and Description
T	fromComponents(java.util.List<Coder<?>> components, byte[] payload, CoderTranslation.TranslationContext context) Create a Coder from its component coders using the specified translation context.
java.util.List<? extends Coder<?>>	getComponents(T from) Extract all component coders within a coder.
default byte[]	getPayload(T from) Returns the serialized payload that will be provided when deserializing this coder, if any.

Method Detail

getComponents

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

Extract all component coders within a coder.

getPayload

default byte[] getPayload(T from)

Returns the serialized payload that will be provided when deserializing this coder, if any. If there is no payload, a byte array of length 0 should be returned.

The default implementation returns a byte array of length zero.

fromComponents

T fromComponents(java.util.List<Coder<?>> components,
                 byte[] payload,
                 CoderTranslation.TranslationContext context)

Create a Coder from its component coders using the specified translation context.