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 7035f02a61a MINOR: Use wildcard generics instead of defensive copies
in TaskManager (#21528)
add 794f6ceebb2 KAFKA-20134: Implement TimestampedWindowStoreWithHeaders
(3/N) (#21486)
No new revisions were added by this update.
Summary of changes:
...java => TimestampedWindowStoreWithHeaders.java} | 14 +-
.../MeteredTimestampedWindowStoreWithHeaders.java | 86 ++++++++++++
.../state/internals/MeteredWindowStore.java | 21 +--
...eredTimestampedWindowStoreWithHeadersTest.java} | 147 +++++++++++----------
4 files changed, 183 insertions(+), 85 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/state/{TimestampedWindowStore.java
=> TimestampedWindowStoreWithHeaders.java} (72%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedWindowStoreWithHeaders.java
copy
streams/src/test/java/org/apache/kafka/streams/state/internals/{MeteredTimestampedWindowStoreTest.java
=> MeteredTimestampedWindowStoreWithHeadersTest.java} (69%)
