Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.values
Interface PInput
-
- All Known Subinterfaces:
- PCollectionView<T>, PValue
- All Known Implementing Classes:
- KeyedPCollectionTuple, PBegin, PCollection, PCollectionList, PCollectionTuple, PValueBase, TypedPValue
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 and Description Collection<? extends PValue>
expand()
void
finishSpecifying()
After building, finalizes thisPInput
to make it ready for being used as an input to aPTransform
.Pipeline
getPipeline()
-
-
-
Method Detail
-
getPipeline
Pipeline getPipeline()
-
expand
Collection<? extends 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
-
finishSpecifying
void finishSpecifying()
After building, finalizes thisPInput
to make it ready for being used as an input to aPTransform
.Automatically invoked whenever
apply()
is invoked on thisPInput
, so users do not normally call this explicitly.
-
-