Details

    • Type: Sub-task
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 0.10.0.0
    • Component/s: None
    • Labels:
      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.

        Attachments

          Activity

            People

            • Assignee:
              guozhang Guozhang Wang
              Reporter:
              guozhang Guozhang Wang
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: