apache_beam.runners.direct.direct_userstate module¶
Support for user state in the BundleBasedDirectRunner.
-
class
apache_beam.runners.direct.direct_userstate.
DirectRuntimeState
(state_spec, state_tag, current_value_accessor)[source]¶
-
class
apache_beam.runners.direct.direct_userstate.
ReadModifyWriteRuntimeState
(state_spec, state_tag, current_value_accessor)[source]¶ Bases:
apache_beam.runners.direct.direct_userstate.DirectRuntimeState
,apache_beam.transforms.userstate.ReadModifyWriteRuntimeState
-
class
apache_beam.runners.direct.direct_userstate.
BagRuntimeState
(state_spec, state_tag, current_value_accessor)[source]¶ Bases:
apache_beam.runners.direct.direct_userstate.DirectRuntimeState
,apache_beam.transforms.userstate.BagRuntimeState
-
class
apache_beam.runners.direct.direct_userstate.
SetRuntimeState
(state_spec, state_tag, current_value_accessor)[source]¶ Bases:
apache_beam.runners.direct.direct_userstate.DirectRuntimeState
,apache_beam.transforms.userstate.SetRuntimeState
-
class
apache_beam.runners.direct.direct_userstate.
CombiningValueRuntimeState
(state_spec, state_tag, current_value_accessor)[source]¶ Bases:
apache_beam.runners.direct.direct_userstate.DirectRuntimeState
,apache_beam.transforms.userstate.CombiningValueRuntimeState
Combining value state interface object passed to user code.
-
class
apache_beam.runners.direct.direct_userstate.
DirectUserStateContext
(step_context, dofn, key_coder)[source]¶ 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.