org.apache.beam.sdk.values

Interface PInput

All Known Subinterfaces:

PCollectionView<T>, PValue

All Known Implementing Classes:

KeyedPCollectionTuple, PBegin, PCollection, PCollectionList, PCollectionTuple, PCollectionViews.SimplePCollectionView, PValueBase

public interface PInput

The interface for things that might be input to a PTransform.

Method Summary

Modifier and Type	Method and Description
java.util.Map<TupleTag<?>,PValue>	expand() Expands this PInput into a list of its component output PValues.
Pipeline	getPipeline() Returns the owning Pipeline of this PInput.

Method Detail

getPipeline

Pipeline getPipeline()

Returns the owning Pipeline of this PInput.

expand

java.util.Map<TupleTag<?>,PValue> expand()

Expands this PInput 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.