Class RocksDBMetricsRecorder


  • public class RocksDBMetricsRecorder
    extends java.lang.Object
    • Constructor Summary

      Constructors 
      Constructor Description
      RocksDBMetricsRecorder​(java.lang.String metricsScope, java.lang.String threadId, java.lang.String storeName)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void addStatistics​(java.lang.String segmentName, org.rocksdb.Statistics statistics)  
      void init​(StreamsMetricsImpl streamsMetrics, TaskId taskId)
      The initialisation of the metrics recorder is idempotent.
      void record​(long now)  
      void removeStatistics​(java.lang.String segmentName)  
      java.lang.String storeName()  
      TaskId taskId()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • RocksDBMetricsRecorder

        public RocksDBMetricsRecorder​(java.lang.String metricsScope,
                                      java.lang.String threadId,
                                      java.lang.String storeName)
    • Method Detail

      • storeName

        public java.lang.String storeName()
      • taskId

        public TaskId taskId()
      • init

        public void init​(StreamsMetricsImpl streamsMetrics,
                         TaskId taskId)
        The initialisation of the metrics recorder is idempotent.
      • addStatistics

        public void addStatistics​(java.lang.String segmentName,
                                  org.rocksdb.Statistics statistics)
      • removeStatistics

        public void removeStatistics​(java.lang.String segmentName)
      • record

        public void record​(long now)