PDone

PDone is a POutput (of output PTransforms).

Creating Instance

PDone takes a Pipeline to be created.

PDone is created using PDone.in utility.

in Utility

PDone in(
  Pipeline pipeline)

in creates a PDone for the given Pipeline.

Demo

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

import org.apache.beam.sdk.values.PDone
val done = PDone.in(p)