kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (d88f104 -> cfa1067)
Date Mon, 07 Oct 2019 21:51:16 GMT
This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from d88f104  KAFKA-8179: Part 7, cooperative rebalancing in Streams (#7386)
     add cfa1067  KAFKA-7245: Deprecate WindowStore#put(key, value) (#7105)

No new revisions were added by this update.

Summary of changes:
 .../processor/internals/ProcessorContextImpl.java        |  2 ++
 .../java/org/apache/kafka/streams/state/WindowStore.java |  6 ++++++
 .../streams/state/internals/CachingWindowStore.java      |  1 +
 .../state/internals/ChangeLoggingWindowBytesStore.java   |  1 +
 .../streams/state/internals/InMemoryWindowStore.java     |  1 +
 .../streams/state/internals/MeteredWindowStore.java      |  1 +
 .../streams/state/internals/RocksDBWindowStore.java      |  1 +
 .../state/internals/TimestampedWindowStoreBuilder.java   |  1 +
 .../WindowToTimestampedWindowByteStoreAdapter.java       |  1 +
 .../org/apache/kafka/streams/perf/SimpleBenchmark.java   |  2 +-
 .../processor/internals/ProcessorContextImplTest.java    |  9 +++++++--
 .../streams/state/internals/CachingWindowStoreTest.java  | 16 +++++++++++++++-
 .../ChangeLoggingTimestampedWindowBytesStoreTest.java    |  2 ++
 .../internals/ChangeLoggingWindowBytesStoreTest.java     |  2 ++
 .../streams/state/internals/InMemoryWindowStoreTest.java |  1 +
 .../internals/MeteredTimestampedWindowStoreTest.java     |  2 ++
 .../streams/state/internals/MeteredWindowStoreTest.java  |  1 +
 .../streams/state/internals/RocksDBWindowStoreTest.java  |  4 ++++
 .../streams/state/internals/WindowBytesStoreTest.java    |  8 ++++++++
 .../kafka/streams/internals/WindowStoreFacade.java       |  1 +
 .../kafka/streams/internals/WindowStoreFacadeTest.java   |  1 +
 21 files changed, 60 insertions(+), 4 deletions(-)


Mime
View raw message