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
  • Subpackages
    • apache_beam.runners.dataflow.native_io package
      • Submodules
        • apache_beam.runners.dataflow.native_io.iobase module
        • apache_beam.runners.dataflow.native_io.streaming_create module
  • Submodules
    • apache_beam.runners.dataflow.dataflow_metrics module
    • apache_beam.runners.dataflow.dataflow_runner module
    • apache_beam.runners.dataflow.ptransform_overrides module
    • apache_beam.runners.dataflow.test_dataflow_runner module
• 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.transform_evaluator module
    • apache_beam.runners.direct.util module
    • apache_beam.runners.direct.watermark_manager module
• apache_beam.runners.experimental package
  • Subpackages
    • apache_beam.runners.experimental.python_rpc_direct package
      • Submodules
        • apache_beam.runners.experimental.python_rpc_direct.python_rpc_direct_runner module
        • apache_beam.runners.experimental.python_rpc_direct.server module
• apache_beam.runners.job package
  • Submodules
    • apache_beam.runners.job.manager module
    • apache_beam.runners.job.utils module

Submodules

• apache_beam.runners.pipeline_context module
• apache_beam.runners.runner module
• apache_beam.runners.sdf_common module