Uses of Interface
org.apache.flink.api.common.state.KeyedStateStore

Packages that use KeyedStateStore

Package	Description
org.apache.flink.cep.nfa.sharedbuffer
org.apache.flink.runtime.state
org.apache.flink.state.api.functions
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.operators.windowing.functions

Uses of KeyedStateStore in org.apache.flink.cep.nfa.sharedbuffer

Constructors in org.apache.flink.cep.nfa.sharedbuffer with parameters of type KeyedStateStore

Constructor and Description
SharedBuffer(KeyedStateStore stateStore, TypeSerializer<V> valueSerializer)
SharedBuffer(KeyedStateStore stateStore, TypeSerializer<V> valueSerializer, SharedBufferCacheConfig cacheConfig)

Uses of KeyedStateStore in org.apache.flink.runtime.state

Classes in org.apache.flink.runtime.state that implement KeyedStateStore

Modifier and Type	Class and Description
class	DefaultKeyedStateStore Default implementation of KeyedStateStore that currently forwards state registration to a RuntimeContext.

Methods in org.apache.flink.runtime.state that return KeyedStateStore

Modifier and Type	Method and Description
KeyedStateStore	ManagedInitializationContext.getKeyedStateStore() Returns an interface that allows for registering keyed state with the backend.
KeyedStateStore	StateInitializationContextImpl.getKeyedStateStore()

Constructors in org.apache.flink.runtime.state with parameters of type KeyedStateStore

Constructor and Description
StateInitializationContextImpl(Long restoredCheckpointId, OperatorStateStore operatorStateStore, KeyedStateStore keyedStateStore, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStateInputs, Iterable<StatePartitionStreamProvider> rawOperatorStateInputs)

Uses of KeyedStateStore in org.apache.flink.state.api.functions

Methods in org.apache.flink.state.api.functions that return KeyedStateStore

Modifier and Type	Method and Description
KeyedStateStore	WindowReaderFunction.Context.globalState() State accessor for per-key global state.
KeyedStateStore	WindowReaderFunction.Context.windowState() State accessor for per-key and per-window state.

Uses of KeyedStateStore in org.apache.flink.state.api.runtime

Constructors in org.apache.flink.state.api.runtime with parameters of type KeyedStateStore

Constructor and Description
SavepointRuntimeContext(RuntimeContext ctx, KeyedStateStore keyedStateStore)

Uses of KeyedStateStore in org.apache.flink.streaming.api.functions.windowing

Methods in org.apache.flink.streaming.api.functions.windowing that return KeyedStateStore

Modifier and Type	Method and Description
KeyedStateStore	InternalProcessApplyWindowContext.globalState()
KeyedStateStore	InternalProcessApplyAllWindowContext.globalState()
abstract KeyedStateStore	ProcessWindowFunction.Context.globalState() State accessor for per-key global state.
abstract KeyedStateStore	ProcessAllWindowFunction.Context.globalState() State accessor for per-key global state.
KeyedStateStore	InternalProcessApplyWindowContext.windowState()
KeyedStateStore	InternalProcessApplyAllWindowContext.windowState()
abstract KeyedStateStore	ProcessWindowFunction.Context.windowState() State accessor for per-key and per-window state.
abstract KeyedStateStore	ProcessAllWindowFunction.Context.windowState() State accessor for per-key and per-window state.

Uses of KeyedStateStore in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return KeyedStateStore

Modifier and Type	Method and Description
KeyedStateStore	AbstractStreamOperator.getKeyedStateStore()

Methods in org.apache.flink.streaming.api.operators that return types with arguments of type KeyedStateStore

Modifier and Type	Method and Description
Optional<KeyedStateStore>	StreamOperatorStateHandler.getKeyedStateStore()
Optional<KeyedStateStore>	AbstractStreamOperatorV2.getKeyedStateStore()

Methods in org.apache.flink.streaming.api.operators with parameters of type KeyedStateStore

Modifier and Type	Method and Description
void	StreamingRuntimeContext.setKeyedStateStore(KeyedStateStore keyedStateStore)

Constructors in org.apache.flink.streaming.api.operators with parameters of type KeyedStateStore

Constructor and Description
StreamingRuntimeContext(Environment env, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup operatorMetricGroup, OperatorID operatorID, ProcessingTimeService processingTimeService, KeyedStateStore keyedStateStore, ExternalResourceInfoProvider externalResourceInfoProvider)

Uses of KeyedStateStore in org.apache.flink.streaming.runtime.operators.windowing

Classes in org.apache.flink.streaming.runtime.operators.windowing that implement KeyedStateStore

Modifier and Type	Class and Description
class	WindowOperator.AbstractPerWindowStateStore Base class for per-window KeyedStateStores.
class	WindowOperator.MergingWindowStateStore Special WindowOperator.AbstractPerWindowStateStore that doesn't allow access to per-window state.
class	WindowOperator.PerWindowStateStore Regular per-window state store for use with ProcessWindowFunction.

Methods in org.apache.flink.streaming.runtime.operators.windowing that return KeyedStateStore

Modifier and Type	Method and Description
KeyedStateStore	WindowOperator.WindowContext.globalState()
KeyedStateStore	WindowOperator.WindowContext.windowState()

Uses of KeyedStateStore in org.apache.flink.streaming.runtime.operators.windowing.functions

Methods in org.apache.flink.streaming.runtime.operators.windowing.functions that return KeyedStateStore

Modifier and Type	Method and Description
KeyedStateStore	InternalWindowFunction.InternalWindowContext.globalState()
KeyedStateStore	InternalProcessAllWindowContext.globalState()
KeyedStateStore	InternalProcessWindowContext.globalState()
KeyedStateStore	InternalWindowFunction.InternalWindowContext.windowState()
KeyedStateStore	InternalProcessAllWindowContext.windowState()
KeyedStateStore	InternalProcessWindowContext.windowState()