Package 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	Description
TaggedPValue()

Method Summary

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

ofExpandedValue

public static TaggedPValue ofExpandedValue(PCollection<?> value)

getTag

public abstract TupleTag<?> getTag()

Returns the local tag associated with the PValue.

getValue

public abstract PCollection<?> getValue()

Returns the PCollection.