Package | Description |
---|---|
org.apache.flink.contrib.streaming.state |
Modifier and Type | Method and Description |
---|---|
RocksDBStateBackend.PriorityQueueStateType |
RocksDBStateBackend.getPriorityQueueStateType()
Gets the type of the priority queue state.
|
static RocksDBStateBackend.PriorityQueueStateType |
RocksDBStateBackend.PriorityQueueStateType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static RocksDBStateBackend.PriorityQueueStateType[] |
RocksDBStateBackend.PriorityQueueStateType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
RocksDBStateBackend.setPriorityQueueStateType(RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType)
Sets the type of the priority queue state.
|
Constructor and Description |
---|
RocksDBKeyedStateBackendBuilder(String operatorIdentifier,
ClassLoader userCodeClassLoader,
File instanceBasePath,
RocksDBResourceContainer optionsContainer,
java.util.function.Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory,
TaskKvStateRegistry kvStateRegistry,
TypeSerializer<K> keySerializer,
int numberOfKeyGroups,
KeyGroupRange keyGroupRange,
ExecutionConfig executionConfig,
LocalRecoveryConfig localRecoveryConfig,
RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType,
TtlTimeProvider ttlTimeProvider,
MetricGroup metricGroup,
Collection<KeyedStateHandle> stateHandles,
StreamCompressionDecorator keyGroupCompressionDecorator,
CloseableRegistry cancelStreamRegistry) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.