public interface POutput
PTransform
.Modifier and Type | Method and Description |
---|---|
java.util.Map<TupleTag<?>,PValue> |
expand()
|
void |
finishSpecifyingOutput(java.lang.String transformName,
PInput input,
PTransform<?,?> transform)
As part of applying the producing
PTransform , finalizes this output to make it ready
for being used as an input and for running. |
Pipeline |
getPipeline()
|
Pipeline getPipeline()
java.util.Map<TupleTag<?>,PValue> expand()
POutput
into a list of its component output PValues
.
PValue
expands to itself.
PValues
(such as PCollectionTuple
or PCollectionList
) expands to its component PValue PValues
.
Not intended to be invoked directly by user code.
void finishSpecifyingOutput(java.lang.String transformName, PInput input, PTransform<?,?> transform)
PTransform
, finalizes this output to make it ready
for being used as an input and for running.
This includes ensuring that all PCollections
have Coders
specified or defaulted.
Automatically invoked whenever this POutput
is output, after finishSpecifyingOutput(String, PInput, PTransform)
has been called on each component
PValue
returned by expand()
.