You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by cm...@apache.org on 2021/02/02 19:35:28 UTC
[kafka] branch trunk updated (8bdfc57 -> 1711cfa)

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