This is an automated email from the ASF dual-hosted git repository.
frankvicky pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 75e66426bf5 KAFKA-20768: Add transactional and IQ isolation to
time-ordered RocksDB stores (#22829)
add cacab1cc81f KAFKA-20705: IQv2 TimestampedWindowKeyWithHeadersQuery for
headers-aware window stores (KIP-1356) (#22799)
No new revisions were added by this update.
Summary of changes:
.../IQv2HeadersStoreIntegrationTest.java | 290 ++++++++++++++++++-
.../TimestampedWindowKeyWithHeadersQuery.java | 130 +++++++++
.../apache/kafka/streams/query/WindowKeyQuery.java | 4 +-
.../MeteredTimestampedWindowStoreWithHeaders.java | 138 +++++++++
.../state/internals/MeteredWindowStore.java | 2 +-
.../RocksDBTimeOrderedWindowStoreWithHeaders.java | 14 +-
.../RocksDBTimestampedWindowStoreWithHeaders.java | 10 +
...teredTimestampedWindowStoreWithHeadersTest.java | 168 +++++++++++
...cksDBTimeOrderedWindowStoreWithHeadersTest.java | 27 +-
...cksDBTimestampedWindowStoreWithHeadersTest.java | 40 ++-
...mestampedWindowStoreWithHeadersBuilderTest.java | 322 +++++++++++++++++++++
11 files changed, 1115 insertions(+), 30 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/query/TimestampedWindowKeyWithHeadersQuery.java
