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

Packages that use RocksDBNativeMetricOptions

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

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

Methods in org.apache.flink.contrib.streaming.state 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(ReadableConfig config)	Creates a RocksDBNativeMetricOptions based on an external configuration.

Methods in org.apache.flink.contrib.streaming.state 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.contrib.streaming.state with parameters of type RocksDBNativeMetricOptions

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

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

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

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