This is an automated email from the ASF dual-hosted git repository.
cmccabe pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 8bdfc57 MINOR: adding docs for failed stream thread metric (#9974)
add 1711cfa KAFKA-12209: Add the timeline data structures for the KIP-631
controller (#9901)
No new revisions were added by this update.
Summary of changes:
build.gradle | 1 +
checkstyle/import-control-jmh-benchmarks.xml | 1 +
.../jmh/timeline/TimelineHashMapBenchmark.java | 90 ++++
.../org/apache/kafka/timeline/BaseHashTable.java | 246 +++++++++++
.../main/java/org/apache/kafka/timeline/Delta.java | 15 +-
.../java/org/apache/kafka/timeline/Revertable.java | 16 +-
.../java/org/apache/kafka/timeline/Snapshot.java | 98 +++++
.../apache/kafka/timeline/SnapshotRegistry.java | 251 ++++++++++++
.../kafka/timeline/SnapshottableHashTable.java | 455 +++++++++++++++++++++
.../org/apache/kafka/timeline/TimelineHashMap.java | 414 +++++++++++++++++++
.../org/apache/kafka/timeline/TimelineHashSet.java | 261 ++++++++++++
.../apache/kafka/timeline/BaseHashTableTest.java | 124 ++++++
.../kafka/timeline/SnapshotRegistryTest.java | 88 ++++
.../kafka/timeline/SnapshottableHashTableTest.java | 236 +++++++++++
.../apache/kafka/timeline/TimelineHashMapTest.java | 113 +++++
.../apache/kafka/timeline/TimelineHashSetTest.java | 113 +++++
16 files changed, 2506 insertions(+), 16 deletions(-)
create mode 100644
jmh-benchmarks/src/main/java/org/apache/kafka/jmh/timeline/TimelineHashMapBenchmark.java
create mode 100644
metadata/src/main/java/org/apache/kafka/timeline/BaseHashTable.java
copy
tools/src/main/java/org/apache/kafka/trogdor/task/WorkerStatusTracker.java =>
metadata/src/main/java/org/apache/kafka/timeline/Delta.java (72%)
copy
tools/src/main/java/org/apache/kafka/trogdor/task/WorkerStatusTracker.java =>
metadata/src/main/java/org/apache/kafka/timeline/Revertable.java (67%)
create mode 100644
metadata/src/main/java/org/apache/kafka/timeline/Snapshot.java
create mode 100644
metadata/src/main/java/org/apache/kafka/timeline/SnapshotRegistry.java
create mode 100644
metadata/src/main/java/org/apache/kafka/timeline/SnapshottableHashTable.java
create mode 100644
metadata/src/main/java/org/apache/kafka/timeline/TimelineHashMap.java
create mode 100644
metadata/src/main/java/org/apache/kafka/timeline/TimelineHashSet.java
create mode 100644
metadata/src/test/java/org/apache/kafka/timeline/BaseHashTableTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/timeline/SnapshotRegistryTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/timeline/SnapshottableHashTableTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/timeline/TimelineHashMapTest.java
create mode 100644
metadata/src/test/java/org/apache/kafka/timeline/TimelineHashSetTest.java
