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

Packages that use RocksDBNativeMetricOptions

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

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 and Description
default RocksDBNativeMetricOptions	OptionsFactory.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.Configuration config) Creates a RocksDBNativeMetricOptions based on an external configuration.
RocksDBNativeMetricOptions	RocksDBStateBackend.getMemoryWatcherOptions()

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

Modifier and Type	Method and Description
default RocksDBNativeMetricOptions	OptionsFactory.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 and Description

RocksDBKeyedStateBackend(String operatorIdentifier, ClassLoader userCodeClassLoader, File instanceBasePath, org.rocksdb.DBOptions dbOptions, org.rocksdb.ColumnFamilyOptions columnFamilyOptions, org.apache.flink.runtime.query.TaskKvStateRegistry kvStateRegistry, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, int numberOfKeyGroups, org.apache.flink.runtime.state.KeyGroupRange keyGroupRange, org.apache.flink.api.common.ExecutionConfig executionConfig, boolean enableIncrementalCheckpointing, org.apache.flink.runtime.state.LocalRecoveryConfig localRecoveryConfig, RocksDBStateBackend.PriorityQueueStateType priorityQueueStateType, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, RocksDBNativeMetricOptions metricOptions, org.apache.flink.metrics.MetricGroup metricGroup)