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: apache_beam.runners.direct.executor._TransformEvaluationState)[source]¶ Bases:
apache_beam.runners.direct.executor.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.