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, ForStStateBackend, RocksDBStateBackend

public abstract class AbstractManagedMemoryStateBackend
extends AbstractStateBackend

Abstract base class for state backends that use managed memory.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.state.StateBackend

StateBackend.CustomInitializationMetrics, StateBackend.KeyedStateBackendParameters<K>, StateBackend.OperatorStateBackendParameters

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(StateBackend.KeyedStateBackendParameters<K> parameters) Creates a new CheckpointableKeyedStateBackend that is responsible for holding keyed state and checkpointing it.
boolean	useManagedMemory() Whether the state backend uses Flink's managed memory.

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

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

createAsyncKeyedStateBackend, getName, supportsAsyncKeyedStateBackend, supportsNoClaimRestoreMode, supportsSavepointFormat

Constructor Detail

AbstractManagedMemoryStateBackend

public AbstractManagedMemoryStateBackend()

Method Detail

createKeyedStateBackend

public abstract <K> AbstractKeyedStateBackend<K> createKeyedStateBackend(StateBackend.KeyedStateBackendParameters<K> parameters)
                                                                  throws IOException

Description copied from interface: StateBackend

Creates a new CheckpointableKeyedStateBackend that is responsible for holding keyed state and checkpointing it.

Keyed State is state where each value is bound to a key.

Specified by:

createKeyedStateBackend in interface StateBackend

Specified by:

createKeyedStateBackend in class AbstractStateBackend

Type Parameters:

K - The type of the keys by which the state is organized.

Parameters:

parameters - The arguments bundle for creating CheckpointableKeyedStateBackend.

Returns:

The Keyed State Backend for the given job, operator, and key group range.

Throws:

IOException

useManagedMemory

public boolean useManagedMemory()

Description copied from interface: StateBackend

Whether the state backend uses Flink's managed memory.