类的使用
org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.PriorityQueueStateType

使用EmbeddedRocksDBStateBackend.PriorityQueueStateType的程序包

程序包	说明
org.apache.flink.contrib.streaming.state

org.apache.flink.contrib.streaming.state中EmbeddedRocksDBStateBackend.PriorityQueueStateType的使用

类型参数类型为EmbeddedRocksDBStateBackend.PriorityQueueStateType的org.apache.flink.contrib.streaming.state中的字段

限定符和类型	字段和说明
static org.apache.flink.configuration.ConfigOption<EmbeddedRocksDBStateBackend.PriorityQueueStateType>	RocksDBOptions.TIMER_SERVICE_FACTORY Choice of timer service implementation.

返回EmbeddedRocksDBStateBackend.PriorityQueueStateType的org.apache.flink.contrib.streaming.state中的方法

限定符和类型	方法和说明
EmbeddedRocksDBStateBackend.PriorityQueueStateType	EmbeddedRocksDBStateBackend.getPriorityQueueStateType() Gets the type of the priority queue state.
static EmbeddedRocksDBStateBackend.PriorityQueueStateType	EmbeddedRocksDBStateBackend.PriorityQueueStateType.valueOf(String name) 返回带有指定名称的该类型的枚举常量。
static EmbeddedRocksDBStateBackend.PriorityQueueStateType[]	EmbeddedRocksDBStateBackend.PriorityQueueStateType.values() 按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

参数类型为EmbeddedRocksDBStateBackend.PriorityQueueStateType的org.apache.flink.contrib.streaming.state中的方法

限定符和类型	方法和说明
void	EmbeddedRocksDBStateBackend.setPriorityQueueStateType(EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType) Sets the type of the priority queue state.

参数类型为EmbeddedRocksDBStateBackend.PriorityQueueStateType的org.apache.flink.contrib.streaming.state中的构造器

构造器和说明

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, EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.KeyedStateHandle> stateHandles, org.apache.flink.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry)