Uses of Class
org.apache.flink.state.forst.sync.ForStPriorityQueueConfig

Packages that use ForStPriorityQueueConfig

Package	Description
org.apache.flink.state.forst
org.apache.flink.state.forst.sync

Uses of ForStPriorityQueueConfig in org.apache.flink.state.forst

Constructors in org.apache.flink.state.forst with parameters of type ForStPriorityQueueConfig

Constructor

Description

ForStKeyedStateBackendBuilder(String operatorIdentifier, ClassLoader userCodeClassLoader, ForStResourceContainer optionsContainer, Function<String,org.forstdb.ColumnFamilyOptions> columnFamilyOptionsFactory, 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, ForStPriorityQueueConfig priorityQueueConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, 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.core.fs.CloseableRegistry cancelStreamRegistry)

Uses of ForStPriorityQueueConfig in org.apache.flink.state.forst.sync

Methods in org.apache.flink.state.forst.sync that return ForStPriorityQueueConfig

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

Methods in org.apache.flink.state.forst.sync with parameters of type ForStPriorityQueueConfig

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

Constructors in org.apache.flink.state.forst.sync with parameters of type ForStPriorityQueueConfig

Constructor

Description

ForStSyncKeyedStateBackendBuilder(String operatorIdentifier, ClassLoader userCodeClassLoader, ForStResourceContainer optionsContainer, Function<String,org.forstdb.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, ForStPriorityQueueConfig priorityQueueConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig, org.apache.flink.runtime.state.metrics.SizeTrackingStateConfig sizeTrackingStateConfig, 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)