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.