tumbling-window-floor-division

Status: IN

`TumblingWindowAggregator` assigns windows by floor-dividing the timestamp by window size, producing aligned non-overlapping boundaries regardless of when events arrive

Source: entries/2026/05/29/stream-join-processor-stream_join_processor.md

Example

def _window_key(self, timestamp):
    return int(timestamp // self._window.duration)

JSON