Package org.apache.flink.contrib.streaming.state

Class EmbeddedRocksDBStateBackend

java.lang.Object

org.apache.flink.runtime.state.AbstractStateBackend

org.apache.flink.runtime.state.AbstractManagedMemoryStateBackend

org.apache.flink.state.rocksdb.EmbeddedRocksDBStateBackend

org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend

All Implemented Interfaces:

Serializable, ConfigurableStateBackend, StateBackend

@Deprecated
@PublicEvolving
public class EmbeddedRocksDBStateBackend
extends EmbeddedRocksDBStateBackend

Deprecated.

This class has been moved to EmbeddedRocksDBStateBackend. Please use the one under the new package instead.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.state.rocksdb.EmbeddedRocksDBStateBackend

EmbeddedRocksDBStateBackend.PriorityQueueStateType

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	Description
EmbeddedRocksDBStateBackend()	Deprecated.
EmbeddedRocksDBStateBackend(boolean enableIncrementalCheckpointing)	Deprecated.
EmbeddedRocksDBStateBackend(TernaryBoolean enableIncrementalCheckpointing)	Deprecated.

Method Summary

Modifier and Type	Method	Description
EmbeddedRocksDBStateBackend	configure(ReadableConfig config, ClassLoader classLoader)	Deprecated. Creates a copy of this state backend that uses the values defined in the configuration for fields where that were not yet specified in this state backend.

Methods inherited from class org.apache.flink.state.rocksdb.EmbeddedRocksDBStateBackend

createKeyedStateBackend, createOperatorStateBackend, getDbStoragePaths, getMemoryConfiguration, getNumberOfTransferThreads, getPredefinedOptions, getPriorityQueueStateType, getRocksDBOptions, getWriteBatchSize, isIncrementalCheckpointsEnabled, setDbStoragePath, setDbStoragePaths, setNumberOfTransferThreads, setPredefinedOptions, setPriorityQueueStateType, setRocksDBMemoryFactory, setRocksDBOptions, setWriteBatchSize, supportsNoClaimRestoreMode, supportsSavepointFormat, toString

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

useManagedMemory

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

getCompressionDecorator

Methods inherited from class java.lang.Object

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

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

createAsyncKeyedStateBackend, getName, supportsAsyncKeyedStateBackend, useManagedMemory

Constructor Detail

EmbeddedRocksDBStateBackend

public EmbeddedRocksDBStateBackend()

Deprecated.

EmbeddedRocksDBStateBackend

public EmbeddedRocksDBStateBackend(boolean enableIncrementalCheckpointing)

Deprecated.

EmbeddedRocksDBStateBackend

public EmbeddedRocksDBStateBackend(TernaryBoolean enableIncrementalCheckpointing)

Deprecated.

Method Detail

configure

public EmbeddedRocksDBStateBackend configure(ReadableConfig config,
                                             ClassLoader classLoader)

Deprecated.

Creates a copy of this state backend that uses the values defined in the configuration for fields where that were not yet specified in this state backend.

Specified by:

configure in interface ConfigurableStateBackend

Overrides:

configure in class EmbeddedRocksDBStateBackend

Parameters:

config - The configuration.

classLoader - The class loader.

Returns:

The re-configured variant of the state backend