org.apache.beam.sdk.values

Class TaggedPValue

java.lang.Object

org.apache.beam.sdk.values.TaggedPValue

@Internal
public abstract class TaggedPValue
extends java.lang.Object

For internal use only; no backwards-compatibility guarantees.

A (TupleTag, PValue) pair used in the expansion of a PInput or POutput.

Constructor Summary

Constructors

Constructor and Description
TaggedPValue()

Method Summary

Modifier and Type	Method and Description
abstract TupleTag<?>	getTag() Returns the local tag associated with the PValue.
abstract PValue	getValue() Returns the PValue.
static TaggedPValue	of(TupleTag<?> tag, PValue value)
static TaggedPValue	ofExpandedValue(PValue value)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaggedPValue

public TaggedPValue()

Method Detail

of

public static TaggedPValue of(TupleTag<?> tag,
                              PValue value)

ofExpandedValue

public static TaggedPValue ofExpandedValue(PValue value)

getTag

public abstract TupleTag<?> getTag()

Returns the local tag associated with the PValue.

getValue

public abstract PValue getValue()

Returns the PValue.