Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
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:
KTable aggregateByKey(aggregator)
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.