Expand description
Window-spec factory namespace.
Each function returns a WindowSpec compiled to the exact form the
server’s WindowEngine.parseSpec accepts.
Functions§
- count
- Event-count tumbling: closes after
nevents.count(100). - count_
sliding - Event-count sliding:
count_sliding(100, 10)= window, slide. - global
- Single unbounded window. Use for global aggregates.
- session
- Inactivity-bounded windows:
session("30s"). - sliding
- Overlapping windows:
sliding("10m", "1m")= size, slide. - tumbling
- Non-overlapping fixed windows:
tumbling("60s").