Skip to content

v2.2.0a

Choose a tag to compare

View all tags
released this 25 Jan 18:10
· 590 commits to main since this release
v2.2.0a
428d567
This commit was created on GitHub.com and signed with GitHub’s verified signature.
GPG key ID: B5690EEEBB952194
Verified
Learn about vigilant mode.

What's Changed

Added Windowed Aggregations

  • Implemented two types of time-based windows:

    • Tumbling windows slice time into even non-overlapping periods.
      Example: [0, 10), [10, 20), [20,30)

    • Hopping windows slice time into even overlapping periods with a fixed step.
      Example: [0,10), [1, 11), [2, 12)

  • Support for various aggregation functions: sum, count, mean, min, max, reduce
  • Two modes of emitting aggregated results:
    • final - to emit results when the window is closed
    • current - to emit results for each incoming message as it's processed
  • Support for out-of-order processing

Find more about Windowed Aggregations in the docs

Full Changelog: v2.1.4a...v2.2.0a

Assets 2
Loading