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 1dacfd29a30 KAFKA-20194: Ensure backward compatibility for Windowed
Store (#21922)
add 482694c9d36 KAFKA-20173: Ensure Metered window-stores pass headers
correctly (#21936)
No new revisions were added by this update.
Summary of changes:
.../state/internals/MeteredKeyValueStore.java | 19 ++-
.../state/internals/MeteredSessionStore.java | 10 --
.../internals/MeteredSessionStoreWithHeaders.java | 1 -
...MeteredTimestampedKeyValueStoreWithHeaders.java | 6 +-
.../internals/MeteredTimestampedWindowStore.java | 14 +-
.../MeteredTimestampedWindowStoreWithHeaders.java | 148 ++++++++++++-----
.../state/internals/MeteredWindowStore.java | 182 +++++++++++----------
.../internals/MeteredWindowStoreIterator.java | 4 -
.../internals/MeteredWindowedKeyValueIterator.java | 10 +-
.../streams/state/internals/WindowKeySchema.java | 11 --
.../kstream/internals/KTableAggregateTest.java | 7 +-
...teredTimestampedWindowStoreWithHeadersTest.java | 21 +--
12 files changed, 240 insertions(+), 193 deletions(-)
