Closed

Open

Watermark

Rows :
(..., ...)
(..., ...)
(..., ...)

States:
avg = 1.23

Waiting queue

Dispatched
- rows
- bytes

Task

Put
- rows
- bytes

Window
task

bytes_waiting =
+ bytes_put
- bytes_ dispatched
rows_waiting = ...

bytes_window =
+ bytes_states
+ bytes_rows

bytes =
+ bytes_waiting
+ bytes_window

Window queue

Task

Window queue