This is an automated email from the ASF dual-hosted git repository.
bbejeck pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 0dbf95b MINOR: Fix documentation for updateCurrentReassignment (#7611)
add fc0f823 KAFKA-8980: Refactor state-store-level streams metrics (#7584)
No new revisions were added by this update.
Summary of changes:
.../internals/metrics/StreamsMetricsImpl.java | 39 +-
.../processor/internals/metrics/TaskMetrics.java | 14 +-
.../processor/internals/metrics/ThreadMetrics.java | 4 +-
.../AbstractRocksDBSegmentedBytesStore.java | 18 +-
.../state/internals/InMemorySessionStore.java | 20 +-
.../InMemoryTimeOrderedKeyValueBuffer.java | 29 +-
.../state/internals/InMemoryWindowStore.java | 17 +-
.../state/internals/MeteredKeyValueStore.java | 238 ++-------
.../state/internals/MeteredSessionStore.java | 174 ++-----
.../state/internals/MeteredWindowStore.java | 150 ++----
.../state/internals/metrics/NamedCacheMetrics.java | 4 +-
.../state/internals/metrics/RocksDBMetrics.java | 38 +-
.../streams/state/internals/metrics/Sensors.java | 117 -----
.../state/internals/metrics/StateStoreMetrics.java | 569 +++++++++++++++++++++
.../integration/MetricsIntegrationTest.java | 389 ++++++++++----
.../kstream/internals/metrics/TaskMetricsTest.java | 39 +-
.../KTableSuppressProcessorMetricsTest.java | 164 ++++--
.../internals/metrics/StreamsMetricsImplTest.java | 21 +-
.../internals/metrics/ThreadMetricsTest.java | 24 +-
.../AbstractRocksDBSegmentedBytesStoreTest.java | 91 +++-
.../state/internals/MeteredKeyValueStoreTest.java | 94 +++-
.../state/internals/MeteredSessionStoreTest.java | 88 +++-
.../MeteredTimestampedKeyValueStoreTest.java | 96 +++-
.../state/internals/MeteredWindowStoreTest.java | 148 +++++-
.../state/internals/SessionBytesStoreTest.java | 95 +++-
.../state/internals/WindowBytesStoreTest.java | 95 +++-
.../internals/metrics/NamedCacheMetricsTest.java | 2 +-
.../internals/metrics/StateStoreMetricsTest.java | 457 +++++++++++++++++
.../kafka/test/InternalMockProcessorContext.java | 16 +-
29 files changed, 2317 insertions(+), 933 deletions(-)
delete mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/Sensors.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetricsTest.java
