[9/N][Emit final] Emit final for session window aggregations (#12204)
* Add a new API for session windows to range query session window by end time (KIP related). * Augment session window aggregator with emit strategy. * Minor: consolidated some dup classes. * Test: unit test on session window aggregator. Reviewers: Guozhang Wang <wangguoz@gmail.com>
显示
- streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java 4 个添加, 1 个删除.../apache/kafka/streams/kstream/SessionWindowedKStream.java
- streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java 1 个添加, 0 个删除...org/apache/kafka/streams/kstream/TimeWindowedKStream.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractKStreamTimeWindowAggregateProcessor.java 5 个添加, 6 个删除...nternals/AbstractKStreamTimeWindowAggregateProcessor.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java 2 个添加, 0 个删除...ms/kstream/internals/CogroupedStreamAggregateBuilder.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java 207 个添加, 65 个删除...eams/kstream/internals/KStreamSessionWindowAggregate.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java 0 个添加, 7 个删除...fka/streams/kstream/internals/KStreamWindowAggregate.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionTupleForwarder.java 0 个添加, 56 个删除...afka/streams/kstream/internals/SessionTupleForwarder.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java 24 个添加, 5 个删除...streams/kstream/internals/SessionWindowedKStreamImpl.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimeWindowedKStreamImpl.java 33 个添加, 22 个删除...ka/streams/kstream/internals/TimeWindowedKStreamImpl.java
- streams/src/main/java/org/apache/kafka/streams/kstream/internals/TimestampedTupleForwarder.java 2 个添加, 1 个删除.../streams/kstream/internals/TimestampedTupleForwarder.java
- streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java 6 个添加, 0 个删除...reams/processor/internals/AbstractReadWriteDecorator.java
- streams/src/main/java/org/apache/kafka/streams/state/SessionStore.java 13 个添加, 0 个删除...ain/java/org/apache/kafka/streams/state/SessionStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBTimeOrderedSegmentedBytesStore.java 2 个添加, 4 个删除...ernals/AbstractRocksDBTimeOrderedSegmentedBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java 9 个添加, 3 个删除...reams/state/internals/ChangeLoggingSessionBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java 16 个添加, 5 个删除...e/kafka/streams/state/internals/InMemorySessionStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java 12 个添加, 0 个删除...he/kafka/streams/state/internals/MeteredSessionStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedSessionKeySchemas.java 7 个添加, 6 个删除...ka/streams/state/internals/PrefixedSessionKeySchemas.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionSegmentedBytesStore.java 32 个添加, 1 个删除...ternals/RocksDBTimeOrderedSessionSegmentedBytesStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedSessionStore.java 7 个添加, 0 个删除...reams/state/internals/RocksDBTimeOrderedSessionStore.java
- streams/src/main/java/org/apache/kafka/streams/state/internals/SegmentIterator.java 1 个添加, 1 个删除...apache/kafka/streams/state/internals/SegmentIterator.java
加载中
想要评论请 注册 或 登录