Google Cloud Dataflow SDK for Java, version 1.9.1
Interface POutput
-
- All Known Subinterfaces:
- PCollectionView<T>, PValue
- All Known Implementing Classes:
- PCollection, PCollectionList, PCollectionTuple, PDone, POutputValueBase, PValueBase, TypedPValue
public interface POutput
The interface for things that might be output from aPTransform
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description Collection<? extends PValue>
expand()
void
finishSpecifyingOutput()
As part of applying the producingPTransform
, finalizes this output to make it ready for being used as an input and for running.Pipeline
getPipeline()
void
recordAsOutput(AppliedPTransform<?,?,?> transform)
Records that thisPOutput
is an output of the givenPTransform
.
-
-
-
Method Detail
-
getPipeline
Pipeline getPipeline()
-
expand
Collection<? extends PValue> expand()
Expands thisPOutput
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
-
recordAsOutput
void recordAsOutput(AppliedPTransform<?,?,?> transform)
Records that thisPOutput
is an output of the givenPTransform
.For a compound
POutput
, it is advised to call this method on each componentPOutput
.This is not intended to be invoked by user code, but is automatically invoked as part of applying the producing
PTransform
.
-
finishSpecifyingOutput
void finishSpecifyingOutput()
As part of applying the producingPTransform
, finalizes this output to make it ready for being used as an input and for running.This includes ensuring that all
PCollections
haveCoders
specified or defaulted.Automatically invoked whenever this
POutput
is used as aPInput
to anotherPTransform
, or if never used as aPInput
, whenPipeline.run()
is called, so users do not normally call this explicitly.
-
-