Uses of Class
org.apache.flink.contrib.streaming.state.RocksDBNativeMetricMonitor
-
Packages that use RocksDBNativeMetricMonitor Package Description org.apache.flink.contrib.streaming.state org.apache.flink.contrib.streaming.state.restore -
-
Uses of RocksDBNativeMetricMonitor in org.apache.flink.contrib.streaming.state
Methods in org.apache.flink.contrib.streaming.state with parameters of type RocksDBNativeMetricMonitor Modifier and Type Method Description static voidRocksDBOperationUtils. registerKvStateInformation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, RocksDBNativeMetricMonitor nativeMetricMonitor, String columnFamilyName, RocksDBKeyedStateBackend.RocksDbKvStateInfo registeredColumn)Constructors in org.apache.flink.contrib.streaming.state with parameters of type RocksDBNativeMetricMonitor 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 RocksDBNativeMetricMonitor in org.apache.flink.contrib.streaming.state.restore
Methods in org.apache.flink.contrib.streaming.state.restore that return RocksDBNativeMetricMonitor Modifier and Type Method Description RocksDBNativeMetricMonitorRocksDBRestoreResult. getNativeMetricMonitor()Constructors in org.apache.flink.contrib.streaming.state.restore with parameters of type RocksDBNativeMetricMonitor Constructor Description RocksDBRestoreResult(org.rocksdb.RocksDB db, org.rocksdb.ColumnFamilyHandle defaultColumnFamilyHandle, RocksDBNativeMetricMonitor nativeMetricMonitor, long lastCompletedCheckpointId, UUID backendUID, SortedMap<Long,Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle.HandleAndLocalPath>> restoredSstFiles, CompletableFuture<Void> asyncCompactAfterRestoreFuture)
-