Serialized Form

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

Class org.apache.flink.contrib.streaming.state.DefaultConfigurableOptionsFactory extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

configuredOptions

Map<K,V> configuredOptions

Class org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions extends Object implements Serializable

Class org.apache.flink.contrib.streaming.state.RocksDBMemoryConfiguration extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

useManagedMemory

Boolean useManagedMemory

Flag whether to use the managed memory budget for RocksDB. Null is not set.

fixedMemoryPerSlot

org.apache.flink.configuration.MemorySize fixedMemoryPerSlot

The total memory for all RocksDB instances at this slot. Null is not set.

writeBufferRatio

Double writeBufferRatio

The maximum fraction of the total shared memory consumed by the write buffers. Null if not set.

highPriorityPoolRatio

Double highPriorityPoolRatio

The high priority pool ratio in the shared cache, used for index & filter blocks. Null if not set.

Class org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions extends Object implements Serializable

Serialized Fields

properties

Set<E> properties

columnFamilyAsVariable

boolean columnFamilyAsVariable

Class org.apache.flink.contrib.streaming.state.RocksDBStateBackend extends org.apache.flink.runtime.state.AbstractStateBackend implements Serializable

serialVersionUID:

1L

Serialized Fields

checkpointStreamBackend

org.apache.flink.runtime.state.StateBackend checkpointStreamBackend

The state backend that we use for creating checkpoint streams.

localRocksDbDirectories

File[] localRocksDbDirectories

Base paths for RocksDB directory, as configured. Null if not yet set, in which case the configuration values will be used. The configuration defaults to the TaskManager's temp directories.

predefinedOptions

PredefinedOptions predefinedOptions

The pre-configured option settings.

rocksDbOptionsFactory

RocksDBOptionsFactory rocksDbOptionsFactory

The options factory to create the RocksDB options in the cluster.

enableIncrementalCheckpointing

org.apache.flink.util.TernaryBoolean enableIncrementalCheckpointing

This determines if incremental checkpointing is enabled.

numberOfTransferThreads

int numberOfTransferThreads

Thread number used to transfer (download and upload) state, default value: 1.

enableTtlCompactionFilter

org.apache.flink.util.TernaryBoolean enableTtlCompactionFilter

This determines if compaction filter to cleanup state with TTL is enabled.

Note: User can still decide in state TTL configuration in state descriptor whether the filter is active for particular state or not.

memoryConfiguration

RocksDBMemoryConfiguration memoryConfiguration

The configuration for memory settings (pool sizes, etc.).

priorityQueueStateType

RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType

This determines the type of priority queue state.

defaultMetricOptions

RocksDBNativeMetricOptions defaultMetricOptions

The default rocksdb metrics options.

writeBatchSize

long writeBatchSize

Max consumed memory size for one batch in RocksDBWriteBatchWrapper, default value 2mb.