apache_beam.runners.direct.direct_userstate module

Support for user state in the BundleBasedDirectRunner.

class apache_beam.runners.direct.direct_userstate.DirectUserStateContext(step_context, dofn, key_coder)

Bases: apache_beam.transforms.userstate.UserStateContext

userstate.UserStateContext for the BundleBasedDirectRunner.

The DirectUserStateContext buffers up updates that are to be committed by the TransformEvaluator after running a DoFn.

get_timer(timer_spec, key, window)

get_state(state_spec, key, window)

commit()