apache_beam.runners.direct package

Inprocess runner executes pipelines locally in a single process.

Anything in this package not imported here is an internal implementation detail with no backwards-compatibility guarantees.

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.test_stream_impl module
• apache_beam.runners.direct.transform_evaluator module
• apache_beam.runners.direct.util module
• apache_beam.runners.direct.watermark_manager module