POutput

POutput is an abstraction of output values of PTransforms.

Contract

getPipeline Method

Pipeline getPipeline()

The owning Pipeline of the POutput

expand Method

Map<TupleTag<?>, PValue> expand()

finishSpecifyingOutput Method

void finishSpecifyingOutput(
  String transformName,
  PInput input,
  PTransform<?, ?> transform)

Available POutputs

Table 1. POutputs (Direct Implementations and Extensions Only)
POutput Description

PCollectionList

PCollectionTuple

PDone

PValue

Result

WriteFilesResult