Package org.apache.beam.sdk.state

@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class) package org.apache.beam.sdk.state

Classes and interfaces for interacting with state.

Related Packages

Package	Description
org.apache.beam.sdk	Provides a simple, powerful model for building both batch and streaming parallel data processing Pipelines.

Class	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.
MultimapState<K,V>	A ReadableState cell mapping keys to bags of values.
OrderedListState<T>	A ReadableState cell containing a list of values sorted by timestamp.
ReadableState<T>	A State that can be read via ReadableState.read().
ReadableStates	For internal use only; no backwards-compatibility guarantees.
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.
StateContexts	For internal use only; no backwards-compatibility guarantees.
StateKeySpec
StateSpec<StateT extends State>	A specification of a persistent state cell.
StateSpec.Cases<ResultT>	Cases for doing a "switch" on the type of StateSpec.
StateSpec.Cases.WithDefault<ResultT>	A base class for a visitor with a default method for cases it is not interested in.
StateSpecs	Static methods for working with StateSpecs.
TimeDomain	TimeDomain specifies whether an operation is based on timestamps of elements or current "real-world" time as reported while processing.
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.
TimerMap
Timers	Interface for interacting with time.
TimerSpec	A specification for a Timer.
TimerSpecs	Static methods for working with TimerSpecs.
ValueState<T>	A ReadableState cell containing a single value.
WatermarkHoldState	For internal use only; no backwards-compatibility guarantees.