Class StateStoreMetrics


  • public class StateStoreMetrics
    extends java.lang.Object
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static org.apache.kafka.common.metrics.Sensor allSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor deleteSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor expiredWindowRecordDropSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor fetchSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor flushSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor getSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor putAllSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor putIfAbsentSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor putSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor rangeSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor removeSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor restoreSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor suppressionBufferCountSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      static org.apache.kafka.common.metrics.Sensor suppressionBufferSizeSensor​(java.lang.String threadId, java.lang.String taskId, java.lang.String storeType, java.lang.String storeName, StreamsMetricsImpl streamsMetrics)  
      • Methods inherited from class java.lang.Object

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

      • putSensor

        public static org.apache.kafka.common.metrics.Sensor putSensor​(java.lang.String threadId,
                                                                       java.lang.String taskId,
                                                                       java.lang.String storeType,
                                                                       java.lang.String storeName,
                                                                       StreamsMetricsImpl streamsMetrics)
      • putIfAbsentSensor

        public static org.apache.kafka.common.metrics.Sensor putIfAbsentSensor​(java.lang.String threadId,
                                                                               java.lang.String taskId,
                                                                               java.lang.String storeType,
                                                                               java.lang.String storeName,
                                                                               StreamsMetricsImpl streamsMetrics)
      • putAllSensor

        public static org.apache.kafka.common.metrics.Sensor putAllSensor​(java.lang.String threadId,
                                                                          java.lang.String taskId,
                                                                          java.lang.String storeType,
                                                                          java.lang.String storeName,
                                                                          StreamsMetricsImpl streamsMetrics)
      • getSensor

        public static org.apache.kafka.common.metrics.Sensor getSensor​(java.lang.String threadId,
                                                                       java.lang.String taskId,
                                                                       java.lang.String storeType,
                                                                       java.lang.String storeName,
                                                                       StreamsMetricsImpl streamsMetrics)
      • fetchSensor

        public static org.apache.kafka.common.metrics.Sensor fetchSensor​(java.lang.String threadId,
                                                                         java.lang.String taskId,
                                                                         java.lang.String storeType,
                                                                         java.lang.String storeName,
                                                                         StreamsMetricsImpl streamsMetrics)
      • allSensor

        public static org.apache.kafka.common.metrics.Sensor allSensor​(java.lang.String threadId,
                                                                       java.lang.String taskId,
                                                                       java.lang.String storeType,
                                                                       java.lang.String storeName,
                                                                       StreamsMetricsImpl streamsMetrics)
      • rangeSensor

        public static org.apache.kafka.common.metrics.Sensor rangeSensor​(java.lang.String threadId,
                                                                         java.lang.String taskId,
                                                                         java.lang.String storeType,
                                                                         java.lang.String storeName,
                                                                         StreamsMetricsImpl streamsMetrics)
      • flushSensor

        public static org.apache.kafka.common.metrics.Sensor flushSensor​(java.lang.String threadId,
                                                                         java.lang.String taskId,
                                                                         java.lang.String storeType,
                                                                         java.lang.String storeName,
                                                                         StreamsMetricsImpl streamsMetrics)
      • deleteSensor

        public static org.apache.kafka.common.metrics.Sensor deleteSensor​(java.lang.String threadId,
                                                                          java.lang.String taskId,
                                                                          java.lang.String storeType,
                                                                          java.lang.String storeName,
                                                                          StreamsMetricsImpl streamsMetrics)
      • removeSensor

        public static org.apache.kafka.common.metrics.Sensor removeSensor​(java.lang.String threadId,
                                                                          java.lang.String taskId,
                                                                          java.lang.String storeType,
                                                                          java.lang.String storeName,
                                                                          StreamsMetricsImpl streamsMetrics)
      • restoreSensor

        public static org.apache.kafka.common.metrics.Sensor restoreSensor​(java.lang.String threadId,
                                                                           java.lang.String taskId,
                                                                           java.lang.String storeType,
                                                                           java.lang.String storeName,
                                                                           StreamsMetricsImpl streamsMetrics)
      • expiredWindowRecordDropSensor

        public static org.apache.kafka.common.metrics.Sensor expiredWindowRecordDropSensor​(java.lang.String threadId,
                                                                                           java.lang.String taskId,
                                                                                           java.lang.String storeType,
                                                                                           java.lang.String storeName,
                                                                                           StreamsMetricsImpl streamsMetrics)
      • suppressionBufferCountSensor

        public static org.apache.kafka.common.metrics.Sensor suppressionBufferCountSensor​(java.lang.String threadId,
                                                                                          java.lang.String taskId,
                                                                                          java.lang.String storeType,
                                                                                          java.lang.String storeName,
                                                                                          StreamsMetricsImpl streamsMetrics)
      • suppressionBufferSizeSensor

        public static org.apache.kafka.common.metrics.Sensor suppressionBufferSizeSensor​(java.lang.String threadId,
                                                                                         java.lang.String taskId,
                                                                                         java.lang.String storeType,
                                                                                         java.lang.String storeName,
                                                                                         StreamsMetricsImpl streamsMetrics)