kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bbej...@apache.org
Subject [kafka] branch trunk updated (0dbf95b -> fc0f823)
Date Wed, 30 Oct 2019 16:25:39 GMT
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


Mime
View raw message