Uses of Class
org.apache.flink.state.rocksdb.RocksDBNativeMetricMonitor

Packages that use RocksDBNativeMetricMonitor

Package	Description
org.apache.flink.state.rocksdb
org.apache.flink.state.rocksdb.restore

Uses of RocksDBNativeMetricMonitor in org.apache.flink.state.rocksdb

Methods in org.apache.flink.state.rocksdb with parameters of type RocksDBNativeMetricMonitor

Modifier and Type	Method	Description
static void	RocksDBOperationUtils.registerKvStateInformation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, RocksDBNativeMetricMonitor nativeMetricMonitor, String columnFamilyName, RocksDBKeyedStateBackend.RocksDbKvStateInfo registeredColumn)

Constructors in org.apache.flink.state.rocksdb with parameters of type RocksDBNativeMetricMonitor

Constructor

Description

RocksDBKeyedStateBackend(ClassLoader userCodeClassLoader, File instanceBasePath, RocksDBResourceContainer optionsContainer, 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.apache.flink.runtime.state.metrics.SizeTrackingStateConfig sizeTrackingStateConfig, 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.state.rocksdb.restore

Methods in org.apache.flink.state.rocksdb.restore that return RocksDBNativeMetricMonitor

Modifier and Type	Method	Description
RocksDBNativeMetricMonitor	RocksDBRestoreResult.getNativeMetricMonitor()

Constructors in org.apache.flink.state.rocksdb.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, Runnable asyncCompactTaskAfterRestore)