Guozhang Wang created KAFKA-3192:
------------------------------------
Summary: Add implicit unlimited windowed aggregation for KStream
Key: KAFKA-3192
URL: https://issues.apache.org/jira/browse/KAFKA-3192
Project: Kafka
Issue Type: Sub-task
Reporter: Guozhang Wang
Some users would want to have a convenient way to specify "unlimited windowed
aggregation" for KStreams. We can add that as a syntax-suger like the following:
{code}
KTable aggregateByKey(aggregator)
{code}
Where it computes the aggregate WITHOUT windowing, and the underlying
implementation just use a RocksDBStore instead of a RocksDBWindowStore, and the
returned type will be KTable, not KTable<Windowed, ?>.
With this we can also remove UnlimitedWindows specs.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
