Package org.apache.flink.state.forst

Class ForStNativeMetricMonitor

java.lang.Object

org.apache.flink.state.forst.ForStNativeMetricMonitor

All Implemented Interfaces:

Closeable, AutoCloseable

@Internal
public class ForStNativeMetricMonitor
extends Object
implements Closeable

A monitor which pulls {RocksDB} native metrics and forwards them to Flink's metric group. All metrics are unsigned longs and are reported at the column family level.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	close()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ForStNativeMetricMonitor

public ForStNativeMetricMonitor(@Nonnull
                                ForStNativeMetricOptions options,
                                @Nonnull
                                org.apache.flink.metrics.MetricGroup metricGroup,
                                @Nonnull
                                org.rocksdb.RocksDB rocksDB,
                                @Nullable
                                org.rocksdb.Statistics statistics)

Method Detail

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable