com.google.cloud.dataflow.sdk.values

Class CodedTupleTag<T>

java.lang.Object

com.google.cloud.dataflow.sdk.values.TupleTag<T>

com.google.cloud.dataflow.sdk.values.CodedTupleTag<T>

Type Parameters:

T - the type of the values associated with this tag

All Implemented Interfaces:

Serializable

public class CodedTupleTag<T>
extends TupleTag<T>

A TupleTag combined with the Coder to use for values associated with the tag.

Used as tags in WindowingInternals.KeyedState.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method and Description
Coder<T>	getCoder() Returns the Coder used for values associated with this tag.
static <T> CodedTupleTag<T>	of(String id, Coder<T> coder) Returns a CodedTupleTag with the given id that uses the given Coder whenever a value associated with the tag needs to be serialized.
String	toString()

Methods inherited from class com.google.cloud.dataflow.sdk.values.TupleTag

asCloudObject, equals, getId, getOutName, getTypeDescriptor, hashCode

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

of

public static <T> CodedTupleTag<T> of(String id,
                                      Coder<T> coder)

Returns a CodedTupleTag with the given id that uses the given Coder whenever a value associated with the tag needs to be serialized.

It is up to the user to ensure that two CodedTupleTags with the same id actually mean the same tag and carry the same generic type parameter. Violating this invariant can lead to hard-to-diagnose runtime type errors.

(An explicit id is required so that persistent keyed state saved by one run of a streaming program can be reused if that streaming program is upgraded to a new version.)

Type Parameters:

T - the type of the values associated with the tag

getCoder

public Coder<T> getCoder()

Returns the Coder used for values associated with this tag.

toString

public String toString()

Overrides:

toString in class TupleTag<T>