ArroyoSystems / arroyo

Distributed stream processing engine in Rust
https://arroyo.dev
Apache License 2.0
3.67k stars 206 forks source link

Support reinvocation of hop and tumble window functions in nested aggregates. #583

Closed jacksonrnewhouse closed 6 months ago

jacksonrnewhouse commented 6 months ago

We'd intended to allow users to reinvoke window functions even if they don't have an active field corresponding to the window in the input plan. However, it wasn't quite working. This change implements this by detecting when we don't have the input and, for tumble and hop, recomputing the window from the _timestamp field.