Uses of Class org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend.PriorityQueueStateType (Flink : State backends : RocksDB 1.18.1-cp3 API)

Packages that use EmbeddedRocksDBStateBackend.PriorityQueueStateType
Package Description

org.apache.flink.contrib.streaming.state

Uses of EmbeddedRocksDBStateBackend.PriorityQueueStateType in org.apache.flink.contrib.streaming.state

Fields in org.apache.flink.contrib.streaming.state with type parameters of type EmbeddedRocksDBStateBackend.PriorityQueueStateType
Modifier and Type	Field	Description
`static org.apache.flink.configuration.ConfigOption<EmbeddedRocksDBStateBackend.PriorityQueueStateType>`	RocksDBOptions.`TIMER_SERVICE_FACTORY`	Choice of timer service implementation.

Methods in org.apache.flink.contrib.streaming.state that return EmbeddedRocksDBStateBackend.PriorityQueueStateType
Modifier and Type	Method	Description
`EmbeddedRocksDBStateBackend.PriorityQueueStateType`	EmbeddedRocksDBStateBackend.`getPriorityQueueStateType()`	Gets the type of the priority queue state.
`static EmbeddedRocksDBStateBackend.PriorityQueueStateType`	EmbeddedRocksDBStateBackend.PriorityQueueStateType.`valueOf(String name)`	Returns the enum constant of this type with the specified name.
`static EmbeddedRocksDBStateBackend.PriorityQueueStateType[]`	EmbeddedRocksDBStateBackend.PriorityQueueStateType.`values()`	Returns an array containing the constants of this enum type, in the order they are declared.

Methods in org.apache.flink.contrib.streaming.state with parameters of type EmbeddedRocksDBStateBackend.PriorityQueueStateType
Modifier and Type	Method	Description
`void`	EmbeddedRocksDBStateBackend.`setPriorityQueueStateType(EmbeddedRocksDBStateBackend.PriorityQueueStateType priorityQueueStateType)`	Sets the type of the priority queue state.

Constructors in org.apache.flink.contrib.streaming.state with parameters of type EmbeddedRocksDBStateBackend.PriorityQueueStateType
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, 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)