apache_beam.runners.direct.util module

Utility classes used by the DirectRunner.

For internal use only. No backwards compatibility guarantees.

class apache_beam.runners.direct.util.TransformResult(transform_evaluator, uncommitted_output_bundles, unprocessed_bundles, counters, keyed_watermark_holds, undeclared_tag_values=None)

Bases: future.types.newobject.newobject

Result of evaluating an AppliedPTransform with a TransformEvaluator.

class apache_beam.runners.direct.util.TimerFiring(encoded_key, window, name, time_domain, timestamp)

Bases: future.types.newobject.newobject

A single instance of a fired timer.

class apache_beam.runners.direct.util.KeyedWorkItem(encoded_key, timer_firings=None, elements=None)

Bases: future.types.newobject.newobject

A keyed item that can either be a timer firing or a list of elements.