apache_beam.runners.direct.executor module¶
An executor that schedules and executes applied ptransforms.
-
class
apache_beam.runners.direct.executor.
TransformExecutor
(transform_evaluator_registry, evaluation_context, input_bundle, fired_timers, applied_ptransform, completion_callback, transform_evaluation_state)[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.