Package org.apache.flink.api.common.state

Interface Summary

Interface	Description
CheckpointListener	This interface is typically only needed for transactional interaction with the "outside world", like committing external side effects on checkpoints.
InternalCheckpointListener	The internal checkpoint listener add another InternalCheckpointListener.notifyCheckpointSubsumed(long) interface for internal usage.
KeyedStateStore	This interface contains methods for registering keyed state with a managed store.
OperatorStateStore	This interface contains methods for registering operator state with a managed store.

Class Summary

Class	Description
AggregatingStateDescriptor<IN,ACC,OUT>	A StateDescriptor for AggregatingState.
ListStateDescriptor<T>	A StateDescriptor for ListState.
MapStateDescriptor<UK,UV>	A StateDescriptor for MapState.
ReducingStateDescriptor<T>	StateDescriptor for ReducingState.
StateDescriptor<S extends org.apache.flink.api.common.state.State,T>	Base class for state descriptors.
StateTtlConfig	Configuration of state TTL logic.
StateTtlConfig.Builder	Builder for the StateTtlConfig.
StateTtlConfig.CleanupStrategies	TTL cleanup strategies.
StateTtlConfig.IncrementalCleanupStrategy	Configuration of cleanup strategy while taking the full snapshot.
StateTtlConfig.RocksdbCompactFilterCleanupStrategy	Configuration of cleanup strategy using custom compaction filter in RocksDB.
ValueStateDescriptor<T>	StateDescriptor for ValueState.

Enum Summary

Enum	Description
StateDescriptor.Type	An enumeration of the types of supported states.
StateTtlConfig.StateVisibility	This option configures whether expired user value can be returned or not.
StateTtlConfig.TtlTimeCharacteristic	This option configures time scale to use for ttl.
StateTtlConfig.UpdateType	This option value configures when to update last access timestamp which prolongs state TTL.