PInput

PInput is an abstraction of input values to PTransforms.

Contract

getPipeline Method

Pipeline getPipeline()

The owning Pipeline of the PInput

expand Method

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

A PValue always expands into itself.

Used when TransformHierarchy.Node is created (for a PTransform).

Available PInputs

Table 1. PInputs (Direct Implementations and Extensions Only)
PInput Description

KeyedPCollectionTuple

PBegin

PCollectionList

PCollectionTuple

PValue

Result