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

Packages that use RocksDBNativeMetricOptions

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

Uses of RocksDBNativeMetricOptions in org.apache.flink.contrib.streaming.state

Subclasses of RocksDBNativeMetricOptions in org.apache.flink.contrib.streaming.state

Modifier and Type	Class	Description
class	RocksDBNativeMetricOptions	Deprecated. This class has been moved to RocksDBNativeMetricOptions.

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

Methods in org.apache.flink.state.rocksdb that return RocksDBNativeMetricOptions

Modifier and Type	Method	Description
default RocksDBNativeMetricOptions	RocksDBOptionsFactory.createNativeMetricsOptions(RocksDBNativeMetricOptions nativeMetricOptions)	This method should enable certain RocksDB metrics to be forwarded to Flink's metrics reporter.
static RocksDBNativeMetricOptions	RocksDBNativeMetricOptions.fromConfig(org.apache.flink.configuration.ReadableConfig config)	Creates a RocksDBNativeMetricOptions based on an external configuration.

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

Modifier and Type	Method	Description
default RocksDBNativeMetricOptions	RocksDBOptionsFactory.createNativeMetricsOptions(RocksDBNativeMetricOptions nativeMetricOptions)	This method should enable certain RocksDB metrics to be forwarded to Flink's metrics reporter.

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

Constructor	Description
RocksDBNativeMetricMonitor(RocksDBNativeMetricOptions options, org.apache.flink.metrics.MetricGroup metricGroup, org.rocksdb.RocksDB rocksDB, org.rocksdb.Statistics statistics)

Uses of RocksDBNativeMetricOptions in org.apache.flink.state.rocksdb.restore

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

Constructor	Description
RocksDBFullRestoreOperation(org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, org.apache.flink.core.fs.ICloseableRegistry cancelStreamRegistryForRestore)
RocksDBHeapTimersFullRestoreOperation(org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int numberOfKeyGroups, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, LinkedHashMap<String,org.apache.flink.runtime.state.heap.HeapPriorityQueueSnapshotRestoreWrapper<?>> registeredPQStates, org.apache.flink.runtime.state.heap.HeapPriorityQueueSetFactory priorityQueueFactory, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, Collection<org.apache.flink.runtime.state.KeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, org.apache.flink.core.fs.ICloseableRegistry cancelStreamRegistryForRestore)
RocksDBIncrementalRestoreOperation(String operatorIdentifier, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, int keyGroupPrefixBytes, int numberOfTransferringThreads, org.apache.flink.util.ResourceGuard dbResourceGuard, org.apache.flink.core.fs.CloseableRegistry cancelStreamRegistryForRestore, org.apache.flink.core.fs.CloseableRegistry cancelRegistryForBackend, ClassLoader userCodeClassLoader, Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, org.apache.flink.runtime.state.StateSerializerProvider<K> keySerializerProvider, File instanceBasePath, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, org.apache.flink.runtime.state.StateBackend.CustomInitializationMetrics customInitializationMetrics, Collection<org.apache.flink.runtime.state.IncrementalKeyedStateHandle> restoreStateHandles, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, long writeBatchSize, Long writeBufferManagerCapacity, double overlapFractionThreshold, boolean useIngestDbRestoreMode, boolean asyncCompactAfterRescale, boolean useDeleteFilesInRange, ExecutorService ioExecutor, org.apache.flink.runtime.taskmanager.AsyncExceptionHandler asyncExceptionHandler)
RocksDBNoneRestoreOperation(Map<String,RocksDBKeyedStateBackend.RocksDbKvStateInfo> kvStateInformation, File instanceRocksDBPath, org.rocksdb.DBOptions dbOptions, Function<String,org.rocksdb.ColumnFamilyOptions> columnFamilyOptionsFactory, RocksDBNativeMetricOptions nativeMetricOptions, org.apache.flink.metrics.MetricGroup metricGroup, RocksDbTtlCompactFiltersManager ttlCompactFiltersManager, Long writeBufferManagerCapacity)