org.apache.beam.runners.core.construction

Class Coders

java.lang.Object

org.apache.beam.runners.core.construction.Coders

public class Coders
extends Object

Converts to and from Beam Runner API representations of Coders.

Field Summary

Fields

Modifier and Type	Field and Description
static String	JAVA_SERIALIZED_CODER_URN

Constructor Summary

Constructors

Constructor and Description
Coders()

Method Summary

Modifier and Type	Method and Description
static Coder<?>	fromProto(RunnerApi.Coder protoCoder, RunnerApi.Components components)
static RunnerApi.MessageWithComponents	toProto(Coder<?> coder)
static RunnerApi.Coder	toProto(Coder<?> coder, org.apache.beam.runners.core.construction.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 String JAVA_SERIALIZED_CODER_URN

See Also:

Constant Field Values

Constructor Detail

Coders

public Coders()

Method Detail

toProto

public static RunnerApi.MessageWithComponents toProto(Coder<?> coder)
                                               throws IOException

Throws:

IOException

toProto

public static RunnerApi.Coder toProto(Coder<?> coder,
                                      org.apache.beam.runners.core.construction.SdkComponents components)
                               throws IOException

Throws:

IOException

fromProto

public static Coder<?> fromProto(RunnerApi.Coder protoCoder,
                                 RunnerApi.Components components)
                          throws IOException

Throws:

IOException