Uses of Interface
org.apache.flink.runtime.state.CheckpointableKeyedStateBackend
-
Packages that use CheckpointableKeyedStateBackend Package Description org.apache.flink.runtime.state 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. -
-
Uses of CheckpointableKeyedStateBackend in org.apache.flink.runtime.state
Classes in org.apache.flink.runtime.state that implement CheckpointableKeyedStateBackend Modifier and Type Class Description classAbstractKeyedStateBackend<K>Base implementation of KeyedStateBackend.Methods in org.apache.flink.runtime.state that return CheckpointableKeyedStateBackend Modifier and Type Method Description <K> CheckpointableKeyedStateBackend<K>StateBackend. 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)Creates a newCheckpointableKeyedStateBackendthat is responsible for holding keyed state and checkpointing it.default <K> CheckpointableKeyedStateBackend<K>StateBackend. 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)Creates a newCheckpointableKeyedStateBackendwith the given managed memory fraction. -
Uses of CheckpointableKeyedStateBackend in org.apache.flink.runtime.state.heap
Classes in org.apache.flink.runtime.state.heap that implement CheckpointableKeyedStateBackend Modifier and Type Class Description classHeapKeyedStateBackend<K>AAbstractKeyedStateBackendthat keeps state on the Java Heap and will serialize state to streams provided by aCheckpointStreamFactoryupon checkpointing.
-