apache_beam.runners.direct.executor module

An executor that schedules and executes applied ptransforms.

class apache_beam.runners.direct.executor.TransformExecutor(transform_evaluator_registry: TransformEvaluatorRegistry, evaluation_context: EvaluationContext, input_bundle: _Bundle, fired_timers, applied_ptransform, completion_callback, transform_evaluation_state: _TransformEvaluationState)[source]

Bases: CallableTask

For internal use only; no backwards-compatibility guarantees.

TransformExecutor will evaluate a bundle using an applied ptransform.

A CallableTask responsible for constructing a TransformEvaluator and evaluating it on some bundle of input, and registering the result using the completion callback.

call(state_sampler)[source]
attempt_call(metrics_container, side_input_values, start_state, process_state, finish_state)[source]

Attempts to run a bundle.

class apache_beam.runners.direct.executor.Executor(*args, **kwargs)[source]

Bases: object

For internal use only; no backwards-compatibility guarantees.

start(roots)[source]
await_completion()[source]
shutdown()[source]