Package org.apache.beam.sdk.values
Interface PInput
-
- All Known Subinterfaces:
PCollectionView<T>
,PValue
- All Known Implementing Classes:
KeyedPCollectionTuple
,PBegin
,PCollection
,PCollectionList
,PCollectionRowTuple
,PCollectionTuple
,PCollectionViews.SimplePCollectionView
,PValueBase
,WithFailures.Result
public interface PInput
The interface for things that might be input to aPTransform
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.Map<TupleTag<?>,PValue>
expand()
Pipeline
getPipeline()
-
-
-
Method Detail
-
getPipeline
Pipeline getPipeline()
-
expand
java.util.Map<TupleTag<?>,PValue> expand()
Expands thisPInput
into a list of its component outputPValues
.- A
PValue
expands to itself. - A tuple or list of
PValues
(such asPCollectionTuple
orPCollectionList
) expands to its componentPValue PValues
.
Not intended to be invoked directly by user code.
- A
-
-