Uses of Class
org.apache.flink.contrib.streaming.state.RocksDBPriorityQueueConfig

Packages that use RocksDBPriorityQueueConfig

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

Uses of RocksDBPriorityQueueConfig in org.apache.flink.contrib.streaming.state

Methods in org.apache.flink.contrib.streaming.state that return RocksDBPriorityQueueConfig

Modifier and Type	Method	Description
static RocksDBPriorityQueueConfig	RocksDBPriorityQueueConfig.buildWithPriorityQueueType(EmbeddedRocksDBStateBackend.PriorityQueueStateType type)
static RocksDBPriorityQueueConfig	RocksDBPriorityQueueConfig.fromOtherAndConfiguration(RocksDBPriorityQueueConfig other, org.apache.flink.configuration.ReadableConfig config)

Methods in org.apache.flink.contrib.streaming.state with parameters of type RocksDBPriorityQueueConfig

Modifier and Type	Method	Description
static RocksDBPriorityQueueConfig	RocksDBPriorityQueueConfig.fromOtherAndConfiguration(RocksDBPriorityQueueConfig other, org.apache.flink.configuration.ReadableConfig config)

Constructors in org.apache.flink.contrib.streaming.state with parameters of type RocksDBPriorityQueueConfig

Constructor

Description

RocksDBKeyedStateBackendBuilder(String operatorIdentifier, ClassLoader userCodeClassLoader, File instanceBasePath, RocksDBResourceContainer optionsContainer, java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, org.apache.flink.runtime.query.TaskKvStateRegistry kvStateRegistry, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.api.common.ExecutionConfig executionConfig, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig, RocksDBPriorityQueueConfig priorityQueueConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig, org.apache.flink.metrics.MetricGroup metricGroup, org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<org.apache.flink.runtime.state.KeyedStateHandle> stateHandles, org.apache.flink.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)