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

Class RocksDBMetricsRecorder

java.lang.Object

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

public class RocksDBMetricsRecorder
extends Object

Constructor Summary

Constructors

Constructor	Description
RocksDBMetricsRecorder(String metricsScope, String threadId, String storeName)

Method Summary

Modifier and Type	Method	Description
void	addStatistics(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(String segmentName)
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(String metricsScope,
                              String threadId,
                              String storeName)

Method Detail

storeName

public 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(String segmentName,
                          org.rocksdb.Statistics statistics)

removeStatistics

public void removeStatistics(String segmentName)

record

public void record(long now)