apache_beam.runners.direct.direct_runner module

DirectRunner, executing on the local machine.

The DirectRunner is a runner implementation that executes the entire graph of transformations belonging to a pipeline on the local machine.

class apache_beam.runners.direct.direct_runner.DirectRunner

Bases: apache_beam.runners.runner.PipelineRunner

Executes a single pipeline on the local machine.

apply_CombinePerKey(transform, pcoll)

apply__GroupByKeyOnly(transform, pcoll)

apply__GroupAlsoByWindow(transform, pcoll)

apply_ReadStringsFromPubSub(transform, pcoll)

apply_WriteStringsToPubSub(transform, pcoll)

run(pipeline)

Execute the entire pipeline and returns an DirectPipelineResult.

cache