PBegin

PBegin is a marker PInput (of root PTransforms).

Creating Instance

PBegin takes a Pipeline to be created.

PBegin is created using PBegin.in utility.

in Utility

PBegin in(Pipeline pipeline)

in creates a PBegin for the given Pipeline.

Demo

import org.apache.beam.sdk.Pipeline
val p = Pipeline.create()

import org.apache.beam.sdk.values.PBegin
val begin = PBegin.in(p)