apache_beam.runners package¶
Runner objects execute a Pipeline.
This package defines runners, which are used to execute a pipeline.
Subpackages¶
- apache_beam.runners.dataflow package
- apache_beam.runners.direct package
- Submodules
- apache_beam.runners.direct.bundle_factory module
- apache_beam.runners.direct.clock module
- apache_beam.runners.direct.consumer_tracking_pipeline_visitor module
- apache_beam.runners.direct.direct_metrics module
- apache_beam.runners.direct.direct_runner module
- apache_beam.runners.direct.evaluation_context module
- apache_beam.runners.direct.executor module
- apache_beam.runners.direct.helper_transforms module
- apache_beam.runners.direct.sdf_direct_runner module
- apache_beam.runners.direct.test_direct_runner module
- apache_beam.runners.direct.transform_evaluator module
- apache_beam.runners.direct.util module
- apache_beam.runners.direct.watermark_manager module
- Submodules
- apache_beam.runners.interactive package
- Submodules
- apache_beam.runners.interactive.cache_manager module
- apache_beam.runners.interactive.display_manager module
- apache_beam.runners.interactive.interactive_pipeline_graph module
- apache_beam.runners.interactive.interactive_runner module
- apache_beam.runners.interactive.pipeline_analyzer module
- apache_beam.runners.interactive.pipeline_graph module
- Submodules
- apache_beam.runners.job package