gfw.common.beam.pipeline.Dag#

class Dag[source]#

Abstract base class for DAG construction logic.

Methods

apply

Applies a series of PTransforms to the pipeline.

abstractmethod apply(pipeline)[source]#

Applies a series of PTransforms to the pipeline.

Return type:

PCollection