org.apache.flink.runtime.state

Class AbstractManagedMemoryStateBackend

java.lang.Object

org.apache.flink.runtime.state.AbstractStateBackend

org.apache.flink.runtime.state.AbstractManagedMemoryStateBackend

All Implemented Interfaces:

Serializable, StateBackend

Direct Known Subclasses:

EmbeddedRocksDBStateBackend, RocksDBStateBackend

public abstract class AbstractManagedMemoryStateBackend
extends AbstractStateBackend

Abstract base class for state backends that use managed memory.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.runtime.state.AbstractStateBackend

latencyTrackingConfigBuilder

Constructor Summary

Constructors

Constructor and Description
AbstractManagedMemoryStateBackend()

Method Summary

Modifier and Type	Method and Description
abstract <K> AbstractKeyedStateBackend<K>	createKeyedStateBackend(Environment env, JobID jobID, String operatorIdentifier, TypeSerializer<K> keySerializer, int numberOfKeyGroups, KeyGroupRange keyGroupRange, TaskKvStateRegistry kvStateRegistry, TtlTimeProvider ttlTimeProvider, MetricGroup metricGroup, Collection<KeyedStateHandle> stateHandles, CloseableRegistry cancelStreamRegistry, double managedMemoryFraction) Creates a new CheckpointableKeyedStateBackend with the given managed memory fraction.
boolean	useManagedMemory() Whether the state backend uses Flink's managed memory.

Methods inherited from class org.apache.flink.runtime.state.AbstractStateBackend

createKeyedStateBackend, createOperatorStateBackend, getCompressionDecorator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.runtime.state.StateBackend

getName, supportsNoClaimRestoreMode, supportsSavepointFormat

Constructor Detail

AbstractManagedMemoryStateBackend

public AbstractManagedMemoryStateBackend()

Method Detail

createKeyedStateBackend

public abstract <K> AbstractKeyedStateBackend<K> createKeyedStateBackend(Environment env,
                                                                         JobID jobID,
                                                                         String operatorIdentifier,
                                                                         TypeSerializer<K> keySerializer,
                                                                         int numberOfKeyGroups,
                                                                         KeyGroupRange keyGroupRange,
                                                                         TaskKvStateRegistry kvStateRegistry,
                                                                         TtlTimeProvider ttlTimeProvider,
                                                                         MetricGroup metricGroup,
                                                                         @Nonnull
                                                                         Collection<KeyedStateHandle> stateHandles,
                                                                         CloseableRegistry cancelStreamRegistry,
                                                                         double managedMemoryFraction)
                                                                  throws Exception

Description copied from interface: StateBackend

Creates a new CheckpointableKeyedStateBackend with the given managed memory fraction. Backends that use managed memory are required to implement this interface.

Throws:

Exception

useManagedMemory

public boolean useManagedMemory()

Description copied from interface: StateBackend

Whether the state backend uses Flink's managed memory.