Class RocksDBMetricsRecordingTrigger
- java.lang.Object
-
- org.apache.kafka.streams.state.internals.metrics.RocksDBMetricsRecordingTrigger
-
- All Implemented Interfaces:
java.lang.Runnable
public class RocksDBMetricsRecordingTrigger extends java.lang.Object implements java.lang.Runnable
-
-
Constructor Summary
Constructors Constructor Description RocksDBMetricsRecordingTrigger(org.apache.kafka.common.utils.Time time)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addMetricsRecorder(RocksDBMetricsRecorder metricsRecorder)
void
removeMetricsRecorder(RocksDBMetricsRecorder metricsRecorder)
void
run()
-
-
-
Method Detail
-
addMetricsRecorder
public void addMetricsRecorder(RocksDBMetricsRecorder metricsRecorder)
-
removeMetricsRecorder
public void removeMetricsRecorder(RocksDBMetricsRecorder metricsRecorder)
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
-