org.apache.beam.sdk.util.construction

Class ModelCoders

java.lang.Object

org.apache.beam.sdk.util.construction.ModelCoders

public class ModelCoders
extends java.lang.Object

Utilities and constants ot interact with coders that are part of the Beam Model.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ModelCoders.KvCoderComponents Components of a KV RunnerApi.Coder with names.
static class	ModelCoders.WindowedValueCoderComponents Components of a Windowed Value RunnerApi.Coder with names.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BOOL_CODER_URN
static java.lang.String	BYTES_CODER_URN
static java.lang.String	CUSTOM_WINDOW_CODER_URN
static java.lang.String	DOUBLE_CODER_URN
static java.lang.String	GLOBAL_WINDOW_CODER_URN
static java.lang.String	INT64_CODER_URN
static java.lang.String	INTERVAL_WINDOW_CODER_URN
static java.lang.String	ITERABLE_CODER_URN
static java.lang.String	KV_CODER_URN
static java.lang.String	LENGTH_PREFIX_CODER_URN
static java.lang.String	NULLABLE_CODER_URN
static java.lang.String	PARAM_WINDOWED_VALUE_CODER_URN
static java.lang.String	ROW_CODER_URN
static java.lang.String	SHARDED_KEY_CODER_URN
static java.lang.String	STATE_BACKED_ITERABLE_CODER_URN
static java.lang.String	STRING_UTF8_CODER_URN
static java.lang.String	TIMER_CODER_URN
static java.lang.String	WINDOWED_VALUE_CODER_URN

Method Summary

Modifier and Type	Method and Description
static ModelCoders.KvCoderComponents	getKvCoderComponents(org.apache.beam.model.pipeline.v1.RunnerApi.Coder coder)
static ModelCoders.WindowedValueCoderComponents	getWindowedValueCoderComponents(org.apache.beam.model.pipeline.v1.RunnerApi.Coder coder)
static org.apache.beam.model.pipeline.v1.RunnerApi.Coder	kvCoder(java.lang.String keyCoderId, java.lang.String valueCoderId)
static org.apache.beam.model.pipeline.v1.RunnerApi.Coder	paramWindowedValueCoder(java.lang.String elementCoderId, java.lang.String windowCoderId, byte[] payload)
static java.util.Set<java.lang.String>	urns()
static org.apache.beam.model.pipeline.v1.RunnerApi.Coder	windowedValueCoder(java.lang.String elementCoderId, java.lang.String windowCoderId)

Methods inherited from class java.lang.Object

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

Field Detail

BYTES_CODER_URN

public static final java.lang.String BYTES_CODER_URN

BOOL_CODER_URN

public static final java.lang.String BOOL_CODER_URN

INT64_CODER_URN

public static final java.lang.String INT64_CODER_URN

STRING_UTF8_CODER_URN

public static final java.lang.String STRING_UTF8_CODER_URN

DOUBLE_CODER_URN

public static final java.lang.String DOUBLE_CODER_URN

ITERABLE_CODER_URN

public static final java.lang.String ITERABLE_CODER_URN

TIMER_CODER_URN

public static final java.lang.String TIMER_CODER_URN

KV_CODER_URN

public static final java.lang.String KV_CODER_URN

LENGTH_PREFIX_CODER_URN

public static final java.lang.String LENGTH_PREFIX_CODER_URN

GLOBAL_WINDOW_CODER_URN

public static final java.lang.String GLOBAL_WINDOW_CODER_URN

INTERVAL_WINDOW_CODER_URN

public static final java.lang.String INTERVAL_WINDOW_CODER_URN

CUSTOM_WINDOW_CODER_URN

public static final java.lang.String CUSTOM_WINDOW_CODER_URN

WINDOWED_VALUE_CODER_URN

public static final java.lang.String WINDOWED_VALUE_CODER_URN

PARAM_WINDOWED_VALUE_CODER_URN

public static final java.lang.String PARAM_WINDOWED_VALUE_CODER_URN

ROW_CODER_URN

public static final java.lang.String ROW_CODER_URN

STATE_BACKED_ITERABLE_CODER_URN

public static final java.lang.String STATE_BACKED_ITERABLE_CODER_URN

See Also:

Constant Field Values

SHARDED_KEY_CODER_URN

public static final java.lang.String SHARDED_KEY_CODER_URN

NULLABLE_CODER_URN

public static final java.lang.String NULLABLE_CODER_URN

Method Detail

urns

public static java.util.Set<java.lang.String> urns()

getWindowedValueCoderComponents

public static ModelCoders.WindowedValueCoderComponents getWindowedValueCoderComponents(org.apache.beam.model.pipeline.v1.RunnerApi.Coder coder)

windowedValueCoder

public static org.apache.beam.model.pipeline.v1.RunnerApi.Coder windowedValueCoder(java.lang.String elementCoderId,
                                                                                   java.lang.String windowCoderId)

paramWindowedValueCoder

public static org.apache.beam.model.pipeline.v1.RunnerApi.Coder paramWindowedValueCoder(java.lang.String elementCoderId,
                                                                                        java.lang.String windowCoderId,
                                                                                        byte[] payload)

getKvCoderComponents

public static ModelCoders.KvCoderComponents getKvCoderComponents(org.apache.beam.model.pipeline.v1.RunnerApi.Coder coder)

kvCoder

public static org.apache.beam.model.pipeline.v1.RunnerApi.Coder kvCoder(java.lang.String keyCoderId,
                                                                        java.lang.String valueCoderId)