KAFKA-13785: [10/N][emit final] more unit test for session store and disable...
KAFKA-13785: [10/N][emit final] more unit test for session store and disable cache for emit final sliding window (#12370) (#7137)
1. Added more unit test for RocksDBTimeOrderedSessionStore and RocksDBTimeOrderedSessionSegmentedBytesStore
2. Disable cache for sliding window if emit strategy is ON_WINDOW_CLOSE
Reviewers: Matthias J. Sax <matthias@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
Co-authored-by: Hao Li <1127478+lihaosky@users.noreply.github.com>
显示
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java 3 个添加, 0 个删除...streams/kstream/internals/SessionWindowedKStreamImpl.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/SlidingWindowedKStreamImpl.java 3 个添加, 1 个删除...streams/kstream/internals/SlidingWindowedKStreamImpl.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedSessionKeySchemas.java 7 个添加, 7 个删除...ka/streams/state/internals/PrefixedSessionKeySchemas.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionSegmentedBytesStore.java 4 个添加, 4 个删除...ternals/RocksDBTimeOrderedSessionSegmentedBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionStore.java 4 个添加, 4 个删除...reams/state/internals/RocksDBTimeOrderedSessionStore.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractDualSchemaRocksDBSegmentedBytesStoreTest.java 138 个添加, 0 个删除...als/AbstractDualSchemaRocksDBSegmentedBytesStoreTest.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/AbstractSessionBytesStoreTest.java 124 个添加, 0 个删除...treams/state/internals/AbstractSessionBytesStoreTest.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/InMemorySessionStoreTest.java 2 个添加, 39 个删除...fka/streams/state/internals/InMemorySessionStoreTest.java
- streams/src/test/java/org/apache/kafka/streams/state/internals/RocksDBSessionStoreTest.java 6 个添加, 51 个删除...afka/streams/state/internals/RocksDBSessionStoreTest.java
加载中
想要评论请 注册 或 登录