org.apache.beam.sdk.util.construction

Class CoderTranslation

java.lang.Object

org.apache.beam.sdk.util.construction.CoderTranslation

public class CoderTranslation
extends java.lang.Object

Converts to and from Beam Runner API representations of Coders.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	CoderTranslation.TranslationContext Pass through additional parameters beyond the components and payload to be able to translate specific coders.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	JAVA_SERIALIZED_CODER_URN

Constructor Summary

Constructors

Constructor and Description
CoderTranslation()

Method Summary

Modifier and Type	Method and Description
static Coder<?>	fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.Coder protoCoder, RehydratedComponents components, CoderTranslation.TranslationContext context)
static org.apache.beam.model.pipeline.v1.RunnerApi.MessageWithComponents	toProto(Coder<?> coder)
static org.apache.beam.model.pipeline.v1.RunnerApi.Coder	toProto(Coder<?> coder, SdkComponents components)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

JAVA_SERIALIZED_CODER_URN

public static final java.lang.String JAVA_SERIALIZED_CODER_URN

See Also:

Constant Field Values

Constructor Detail

CoderTranslation

public CoderTranslation()

Method Detail

toProto

public static org.apache.beam.model.pipeline.v1.RunnerApi.MessageWithComponents toProto(Coder<?> coder)
                                                                                 throws java.io.IOException

Throws:

java.io.IOException

toProto

public static org.apache.beam.model.pipeline.v1.RunnerApi.Coder toProto(Coder<?> coder,
                                                                        SdkComponents components)
                                                                 throws java.io.IOException

Throws:

java.io.IOException

fromProto

public static Coder<?> fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.Coder protoCoder,
                                 RehydratedComponents components,
                                 CoderTranslation.TranslationContext context)
                          throws java.io.IOException

Throws:

java.io.IOException