ArroyoSystems / arroyo

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

Properly plan subqueries with async UDFs #780

Closed mwylde closed 2 weeks ago

mwylde commented 2 weeks ago

This fixes #779 by planning subquery inputs to an async UDF as a separate node.