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

Class RocksDBMetrics

java.lang.Object

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

public class RocksDBMetrics
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RocksDBMetrics.RocksDBMetricContext

Method Summary

Modifier and Type	Method	Description
static org.apache.kafka.common.metrics.Sensor	blockCacheDataHitRatioSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	blockCacheFilterHitRatioSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	blockCacheIndexHitRatioSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	bytesReadDuringCompactionSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	bytesReadFromDatabaseSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	bytesWrittenDuringCompactionSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	bytesWrittenToDatabaseSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	compactionTimeAvgSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	compactionTimeMaxSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	compactionTimeMinSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	memtableAvgFlushTimeSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	memtableBytesFlushedSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	memtableHitRatioSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	memtableMaxFlushTimeSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	memtableMinFlushTimeSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	numberOfFileErrorsSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	numberOfOpenFilesSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)
static org.apache.kafka.common.metrics.Sensor	writeStallDurationSensor(StreamsMetricsImpl streamsMetrics, RocksDBMetrics.RocksDBMetricContext metricContext)

Methods inherited from class java.lang.Object

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

Method Detail

bytesWrittenToDatabaseSensor

public static org.apache.kafka.common.metrics.Sensor bytesWrittenToDatabaseSensor(StreamsMetricsImpl streamsMetrics,
                                                                                  RocksDBMetrics.RocksDBMetricContext metricContext)

bytesReadFromDatabaseSensor

public static org.apache.kafka.common.metrics.Sensor bytesReadFromDatabaseSensor(StreamsMetricsImpl streamsMetrics,
                                                                                 RocksDBMetrics.RocksDBMetricContext metricContext)

memtableBytesFlushedSensor

public static org.apache.kafka.common.metrics.Sensor memtableBytesFlushedSensor(StreamsMetricsImpl streamsMetrics,
                                                                                RocksDBMetrics.RocksDBMetricContext metricContext)

memtableHitRatioSensor

public static org.apache.kafka.common.metrics.Sensor memtableHitRatioSensor(StreamsMetricsImpl streamsMetrics,
                                                                            RocksDBMetrics.RocksDBMetricContext metricContext)

memtableAvgFlushTimeSensor

public static org.apache.kafka.common.metrics.Sensor memtableAvgFlushTimeSensor(StreamsMetricsImpl streamsMetrics,
                                                                                RocksDBMetrics.RocksDBMetricContext metricContext)

memtableMinFlushTimeSensor

public static org.apache.kafka.common.metrics.Sensor memtableMinFlushTimeSensor(StreamsMetricsImpl streamsMetrics,
                                                                                RocksDBMetrics.RocksDBMetricContext metricContext)

memtableMaxFlushTimeSensor

public static org.apache.kafka.common.metrics.Sensor memtableMaxFlushTimeSensor(StreamsMetricsImpl streamsMetrics,
                                                                                RocksDBMetrics.RocksDBMetricContext metricContext)

writeStallDurationSensor

public static org.apache.kafka.common.metrics.Sensor writeStallDurationSensor(StreamsMetricsImpl streamsMetrics,
                                                                              RocksDBMetrics.RocksDBMetricContext metricContext)

blockCacheDataHitRatioSensor

public static org.apache.kafka.common.metrics.Sensor blockCacheDataHitRatioSensor(StreamsMetricsImpl streamsMetrics,
                                                                                  RocksDBMetrics.RocksDBMetricContext metricContext)

blockCacheIndexHitRatioSensor

public static org.apache.kafka.common.metrics.Sensor blockCacheIndexHitRatioSensor(StreamsMetricsImpl streamsMetrics,
                                                                                   RocksDBMetrics.RocksDBMetricContext metricContext)

blockCacheFilterHitRatioSensor

public static org.apache.kafka.common.metrics.Sensor blockCacheFilterHitRatioSensor(StreamsMetricsImpl streamsMetrics,
                                                                                    RocksDBMetrics.RocksDBMetricContext metricContext)

bytesReadDuringCompactionSensor

public static org.apache.kafka.common.metrics.Sensor bytesReadDuringCompactionSensor(StreamsMetricsImpl streamsMetrics,
                                                                                     RocksDBMetrics.RocksDBMetricContext metricContext)

bytesWrittenDuringCompactionSensor

public static org.apache.kafka.common.metrics.Sensor bytesWrittenDuringCompactionSensor(StreamsMetricsImpl streamsMetrics,
                                                                                        RocksDBMetrics.RocksDBMetricContext metricContext)

compactionTimeAvgSensor

public static org.apache.kafka.common.metrics.Sensor compactionTimeAvgSensor(StreamsMetricsImpl streamsMetrics,
                                                                             RocksDBMetrics.RocksDBMetricContext metricContext)

compactionTimeMinSensor

public static org.apache.kafka.common.metrics.Sensor compactionTimeMinSensor(StreamsMetricsImpl streamsMetrics,
                                                                             RocksDBMetrics.RocksDBMetricContext metricContext)

compactionTimeMaxSensor

public static org.apache.kafka.common.metrics.Sensor compactionTimeMaxSensor(StreamsMetricsImpl streamsMetrics,
                                                                             RocksDBMetrics.RocksDBMetricContext metricContext)

numberOfOpenFilesSensor

public static org.apache.kafka.common.metrics.Sensor numberOfOpenFilesSensor(StreamsMetricsImpl streamsMetrics,
                                                                             RocksDBMetrics.RocksDBMetricContext metricContext)

numberOfFileErrorsSensor

public static org.apache.kafka.common.metrics.Sensor numberOfFileErrorsSensor(StreamsMetricsImpl streamsMetrics,
                                                                              RocksDBMetrics.RocksDBMetricContext metricContext)