root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity
kafka/streams/streams-scala
History
Matthias J. Sax 8a237f599a KAFKA-6455: Session Aggregation should use window-end-time as record timestamp (#6645) 
For session-windows, the result record should have the window-end timestamp as record timestamp.

Rebased to resolve merge conflicts. Removed unused classes TupleForwarder and ForwardingCacheFlushListener (replace with TimestampedTupleForwarder, SessionTupleForwarder, TimestampedCacheFlushListerner, and SessionCacheFlushListener)

Reviewers: John Roesler <john@confluent.io>, Bruno Cadonna <bruno@confluent.io>, Boyang Chen <boyang@confluent.io>, Bill Bejeck <bill@confluent.io>, Guozhang Wang <wangguoz@gmail.com>
 		2019-05-12 15:31:44 -07:00
..
src KAFKA-6455: Session Aggregation should use window-end-time as record timestamp (#6645) 2019-05-12 15:31:44 -07:00
.gitignore KAFKA-6670: Implement a Scala wrapper library for Kafka Streams 2018-04-23 13:33:35 -07:00
NOTICE KAFKA-6670: Implement a Scala wrapper library for Kafka Streams 2018-04-23 13:33:35 -07:00