Package org.apache.kafka.streams.state.internals.metrics

Class StateStoreMetrics

java.lang.Object

org.apache.kafka.streams.state.internals.metrics.StateStoreMetrics

public class StateStoreMetrics
extends Object

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.metrics.Sensor	allSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	deleteSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	expiredWindowRecordDropSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	fetchSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	flushSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	getSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	putAllSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	putIfAbsentSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	putSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	rangeSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	removeSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	restoreSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	suppressionBufferCountSensor(String threadId, String taskId, String storeType, String storeName, StreamsMetricsImpl streamsMetrics)
static org.apache.kafka.common.metrics.Sensor	suppressionBufferSizeSensor(String threadId, String taskId, String storeType, 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(String threadId,
                                                               String taskId,
                                                               String storeType,
                                                               String storeName,
                                                               StreamsMetricsImpl streamsMetrics)

putIfAbsentSensor

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

putAllSensor

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

getSensor

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

fetchSensor

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

allSensor

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

rangeSensor

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

flushSensor

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

deleteSensor

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

removeSensor

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

restoreSensor

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

expiredWindowRecordDropSensor

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

suppressionBufferCountSensor

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

suppressionBufferSizeSensor

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