This is an automated email from the ASF dual-hosted git repository.
vvcephei pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 76ac43b MINOR: Share BrokerMetadataPublisher code for coordinators
(#11525)
add 1e09165 KAFKA-13117: migrate TupleForwarder and CacheFlushListener to
new Record API (#11481)
No new revisions were added by this update.
Summary of changes:
.../kstream/internals/KStreamAggregate.java | 4 +-
.../streams/kstream/internals/KStreamReduce.java | 4 +-
.../internals/KStreamSessionWindowAggregate.java | 9 +-
.../internals/KStreamSlidingWindowAggregate.java | 181 ++++++++++-----------
.../kstream/internals/KStreamWindowAggregate.java | 7 +-
.../streams/kstream/internals/KTableAggregate.java | 4 +-
.../kstream/internals/KTableKTableJoinMerger.java | 2 +-
.../streams/kstream/internals/KTableMapValues.java | 2 +-
.../streams/kstream/internals/KTableReduce.java | 4 +-
.../streams/kstream/internals/KTableSource.java | 2 +-
.../kstream/internals/KTableTransformValues.java | 2 +-
.../internals/SessionCacheFlushListener.java | 14 --
.../kstream/internals/SessionTupleForwarder.java | 11 +-
.../internals/TimestampedCacheFlushListener.java | 39 +----
.../internals/TimestampedTupleForwarder.java | 28 ----
.../state/internals/CacheFlushListener.java | 9 -
.../state/internals/CachingKeyValueStore.java | 17 +-
.../state/internals/CachingSessionStore.java | 17 +-
.../state/internals/CachingWindowStore.java | 17 +-
.../state/internals/MeteredKeyValueStore.java | 34 +---
.../state/internals/MeteredSessionStore.java | 38 ++---
.../state/internals/MeteredWindowStore.java | 38 ++---
...KStreamSessionWindowAggregateProcessorTest.java | 4 +-
.../internals/SessionCacheFlushListenerTest.java | 8 +-
.../internals/SessionTupleForwarderTest.java | 16 +-
.../TimestampedCacheFlushListenerTest.java | 39 +++--
.../internals/TimestampedTupleForwarderTest.java | 18 +-
.../state/internals/CacheFlushListenerStub.java | 14 --
.../internals/CachingInMemorySessionStoreTest.java | 24 +--
.../CachingPersistentSessionStoreTest.java | 16 --
30 files changed, 241 insertions(+), 381 deletions(-)
