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[source]

Bases: apache_beam.runners.runner.PipelineRunner

Executes a single pipeline on the local machine.

apply_CombinePerKey(transform, pcoll)[source]
apply__GroupByKeyOnly(transform, pcoll)[source]
apply__GroupAlsoByWindow(transform, pcoll)[source]
apply_ReadStringsFromPubSub(transform, pcoll)[source]
apply_WriteStringsToPubSub(transform, pcoll)[source]
run(pipeline)[source]

Execute the entire pipeline and returns an DirectPipelineResult.

cache