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
  • Submodules
    • apache_beam.runners.dataflow.dataflow_exercise_metrics_pipeline module
    • apache_beam.runners.dataflow.dataflow_exercise_streaming_metrics_pipeline module
    • 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.direct_userstate 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
• apache_beam.runners.interactive package
  • Subpackages
    • apache_beam.runners.interactive.caching package
      • Submodules
        • apache_beam.runners.interactive.caching.streaming_cache module
    • apache_beam.runners.interactive.display package
      • Submodules
        • apache_beam.runners.interactive.display.display_manager module
        • apache_beam.runners.interactive.display.interactive_pipeline_graph module
        • apache_beam.runners.interactive.display.pcoll_visualization module
        • apache_beam.runners.interactive.display.pipeline_graph module
        • apache_beam.runners.interactive.display.pipeline_graph_renderer module
  • Submodules
    • apache_beam.runners.interactive.cache_manager module
    • apache_beam.runners.interactive.interactive_beam module
    • apache_beam.runners.interactive.interactive_environment module
    • apache_beam.runners.interactive.interactive_runner module
    • apache_beam.runners.interactive.pipeline_analyzer module
    • apache_beam.runners.interactive.pipeline_instrument module
• apache_beam.runners.internal package
  • Submodules
    • apache_beam.runners.internal.names 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.utils module