Package org.apache.beam.sdk.values

Interface PInput

All Known Subinterfaces:

PCollectionView<T>, PValue

All Known Implementing Classes:

DicomIO.ReadStudyMetadata.Result, FhirIO.Read.Result, FhirIO.Search.Result, FhirIOPatientEverything.Result, HL7v2IO.HL7v2Read.Result, HL7v2IO.Read.Result, KeyedPCollectionTuple, PBegin, PCollection, PCollectionList, PCollectionRowTuple, PCollectionTuple, PCollectionViews.SimplePCollectionView, PValueBase, WithFailures.Result

public interface PInput

The interface for things that might be input to a PTransform.

Method Summary

Modifier and Type	Method	Description
Map<TupleTag<?>,PValue>	expand()	Expands this PInput into a list of its component output PValues.
Pipeline	getPipeline()	Returns the owning Pipeline of this PInput.

Method Details

getPipeline

Pipeline getPipeline()

Returns the owning Pipeline of this PInput.

expand

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

Expands this PInput into a list of its component output PValues.

• A PValue expands to itself.
• A tuple or list of PValues (such as PCollectionTuple or PCollectionList) expands to its component PValue PValues.

Not intended to be invoked directly by user code.