Uses of Class
org.apache.flink.runtime.state.AbstractKeyedStateBackend

Packages that use AbstractKeyedStateBackend

Package	Description
org.apache.flink.runtime.state
org.apache.flink.runtime.state.filesystem
org.apache.flink.runtime.state.hashmap
org.apache.flink.runtime.state.heap	This package contains the classes for key/value state backends that store the state on the JVM heap as objects.
org.apache.flink.runtime.state.memory

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

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

Modifier and Type	Method	Description
abstract <K> AbstractKeyedStateBackend<K>	AbstractManagedMemoryStateBackend.createKeyedStateBackend(Environment env, org.apache.flink.api.common.JobID jobID, String operatorIdentifier, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, double managedMemoryFraction)
abstract <K> AbstractKeyedStateBackend<K>	AbstractStateBackend.createKeyedStateBackend(Environment env, org.apache.flink.api.common.JobID jobID, String operatorIdentifier, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)

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

Constructor	Description
AbstractKeyedStateBackend(AbstractKeyedStateBackend<K> abstractKeyedStateBackend)

Uses of AbstractKeyedStateBackend in org.apache.flink.runtime.state.filesystem

Methods in org.apache.flink.runtime.state.filesystem that return AbstractKeyedStateBackend

Modifier and Type	Method	Description
<K> AbstractKeyedStateBackend<K>	FsStateBackend.createKeyedStateBackend(Environment env, org.apache.flink.api.common.JobID jobID, String operatorIdentifier, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)	Deprecated.

Uses of AbstractKeyedStateBackend in org.apache.flink.runtime.state.hashmap

Methods in org.apache.flink.runtime.state.hashmap that return AbstractKeyedStateBackend

Modifier and Type	Method	Description
<K> AbstractKeyedStateBackend<K>	HashMapStateBackend.createKeyedStateBackend(Environment env, org.apache.flink.api.common.JobID jobID, String operatorIdentifier, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)

Uses of AbstractKeyedStateBackend in org.apache.flink.runtime.state.heap

Subclasses of AbstractKeyedStateBackend in org.apache.flink.runtime.state.heap

Modifier and Type	Class	Description
class	HeapKeyedStateBackend<K>	A AbstractKeyedStateBackend that keeps state on the Java Heap and will serialize state to streams provided by a CheckpointStreamFactory upon checkpointing.

Uses of AbstractKeyedStateBackend in org.apache.flink.runtime.state.memory

Methods in org.apache.flink.runtime.state.memory that return AbstractKeyedStateBackend

Modifier and Type	Method	Description
<K> AbstractKeyedStateBackend<K>	MemoryStateBackend.createKeyedStateBackend(Environment env, org.apache.flink.api.common.JobID jobID, String operatorIdentifier, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, org.apache.flink.metrics.MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)	Deprecated.