Uses of Interface
org.apache.flink.contrib.streaming.state.sstmerge.RocksDBManualCompactionManager
-
Packages that use RocksDBManualCompactionManager Package Description org.apache.flink.contrib.streaming.state org.apache.flink.contrib.streaming.state.sstmerge -
-
Uses of RocksDBManualCompactionManager in org.apache.flink.contrib.streaming.state
Constructors in org.apache.flink.contrib.streaming.state with parameters of type RocksDBManualCompactionManager Constructor Description RocksDBKeyedStateBackend(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, org.apache.flink.api.common.ExecutionConfig executionConfig, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, org.apache.flink.runtime.state.metrics.LatencyTrackingStateConfig latencyTrackingStateConfig, org.rocksdb.RocksDB db, LinkedHashMap<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, Map<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, int keyGroupPrefixBytes, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistry, org.apache.flink.runtime.state.StreamCompressionDecorator keyGroupCompressionDecorator, org.apache.flink.util.ResourceGuard rocksDBResourceGuard, RocksDBSnapshotStrategyBase<K,?> checkpointSnapshotStrategy, RocksDBWriteBatchWrapper writeBatchWrapper, org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle, RocksDBNativeMetricMonitor nativeMetricMonitor, org.apache.flink.runtime.state.SerializedCompositeKeyBuilder<K> sharedRocksKeyBuilder, org.apache.flink.runtime.state.PriorityQueueSetFactory priorityQueueFactory, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, org.apache.flink.runtime.state.InternalKeyContext<K> keyContext, long writeBatchSize, CompletableFuture<Void> asyncCompactFuture, RocksDBManualCompactionManager rocksDBManualCompactionManager) -
Uses of RocksDBManualCompactionManager in org.apache.flink.contrib.streaming.state.sstmerge
Fields in org.apache.flink.contrib.streaming.state.sstmerge declared as RocksDBManualCompactionManager Modifier and Type Field Description static RocksDBManualCompactionManagerRocksDBManualCompactionManager. NO_OPMethods in org.apache.flink.contrib.streaming.state.sstmerge that return RocksDBManualCompactionManager Modifier and Type Method Description static RocksDBManualCompactionManagerRocksDBManualCompactionManager. create(org.rocksdb.RocksDB db, RocksDBManualCompactionConfig settings, ExecutorService ioExecutor)
-