Package org.apache.beam.sdk.values

Interface PValue

All Superinterfaces:

PInput, POutput

All Known Subinterfaces:

PCollectionView<T>

All Known Implementing Classes:

PCollection, PCollectionViews.SimplePCollectionView, PValueBase

@Internal
public interface PValue
extends POutput, PInput

For internal use. No backwards compatibility guarantees.

A primitive value within Beam.

Method Summary

Modifier and Type	Method	Description
Map<TupleTag<?>,PValue>	expand()	Deprecated. A PValue always expands into itself.
void	finishSpecifying(PInput upstreamInput, PTransform<?,?> upstreamTransform)	After building, finalizes this PValue to make it ready for being used as an input to a PTransform.
String	getName()	Returns the name of this PValue.

Methods inherited from interface org.apache.beam.sdk.values.PInput

getPipeline

Methods inherited from interface org.apache.beam.sdk.values.POutput

finishSpecifyingOutput, getPipeline

Method Details

getName

String getName()

Returns the name of this PValue.

expand

@Deprecated
Map<TupleTag<?>,PValue> expand()

Deprecated.

A PValue always expands into itself. Calling expand() on a PValue is almost never appropriate.

Expands this POutput into a list of its component output PValues.

• A PValue expands to itself.
• A tuple or list of PValues (such as PCollectionTuple or PCollectionList) expands to its component PValue PValues.

Not intended to be invoked directly by user code..

Specified by:

expand in interface PInput

Specified by:

expand in interface POutput

finishSpecifying

@Internal
void finishSpecifying(PInput upstreamInput,
 PTransform<?,?> upstreamTransform)

After building, finalizes this PValue to make it ready for being used as an input to a PTransform.

Automatically invoked whenever apply() is invoked on this PValue. Users should not normally call this explicitly.

Parameters:

upstreamInput - the PInput the PTransform was applied to to produce this output

upstreamTransform - the PTransform that produced this PValue