This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from fb66b3668b KAFKA-13799: Improve documentation for Kafka zero-copy
(#12052)
add d83fccd65f KAFKA-13785: [5/N][emit final] cache for time ordered
window store (#12030)
No new revisions were added by this update.
Summary of changes:
...stractDualSchemaRocksDBSegmentedBytesStore.java | 6 +-
.../MergedSortedCacheWindowStoreIterator.java | 14 +-
...rgedSortedCacheWindowStoreKeyValueIterator.java | 33 +-
.../state/internals/PrefixedWindowKeySchemas.java | 20 ++
.../internals/RocksDBTimeOrderedWindowStore.java | 7 +-
...ore.java => TimeOrderedCachingWindowStore.java} | 390 +++++++++++++--------
.../internals/TimestampedWindowStoreBuilder.java | 19 +
...dSortedCacheWrappedWindowStoreIteratorTest.java | 105 ++++--
...acheWrappedWindowStoreKeyValueIteratorTest.java | 83 ++++-
...meOrderedCachingPersistentWindowStoreTest.java} | 238 ++++++++++---
.../TimestampedWindowStoreBuilderTest.java | 46 ++-
11 files changed, 726 insertions(+), 235 deletions(-)
copy
streams/src/main/java/org/apache/kafka/streams/state/internals/{CachingWindowStore.java
=> TimeOrderedCachingWindowStore.java} (56%)
copy
streams/src/test/java/org/apache/kafka/streams/state/internals/{CachingPersistentWindowStoreTest.java
=> TimeOrderedCachingPersistentWindowStoreTest.java} (85%)
