Package org.apache.beam.sdk.state

Classes and interfaces for interacting with state.

See: Description

Interface Summary

Interface	Description
BagState<T>	A ReadableState cell containing a bag of values.
CombiningState<InputT,AccumT,OutputT>	A ReadableState cell defined by a Combine.CombineFn, accepting multiple input values, combining them as specified into accumulators, and producing a single output value.
GroupingState<InputT,OutputT>	A ReadableState cell that combines multiple input values and outputs a single value of a different type.
MapState<K,V>	A ReadableState cell mapping keys to values.
ReadableState<T>	A State that can be read via ReadableState.read().
SetState<T>	A ReadableState cell containing a set of elements.
State	A state cell, supporting a State.clear() operation.
StateBinder	For internal use only; no backwards-compatibility guarantees.
StateContext<W extends BoundedWindow>	For internal use only; no backwards-compatibility guarantees.
StateSpec<StateT extends State>	A specification of a persistent state cell.
Timer	A timer for a specified time domain that can be set to register the desire for further processing at particular time in its specified time domain.
Timers	Interface for interacting with time.
TimerSpec	A specification for a Timer.
ValueState<T>	A ReadableState cell containing a single value.
WatermarkHoldState	For internal use only; no backwards-compatibility guarantees.

Class Summary

Class	Description
ReadableStates	For internal use only; no backwards-compatibility guarantees.
StateContexts	For internal use only; no backwards-compatibility guarantees.
StateSpecs	Static methods for working with StateSpecs.
TimerSpecs	Static methods for working with TimerSpecs.

Enum Summary

Enum	Description
TimeDomain	TimeDomain specifies whether an operation is based on timestamps of elements or current "real-world" time as reported while processing.

Package org.apache.beam.sdk.state Description

Classes and interfaces for interacting with state.