Cloud-native stream processing. Distributed stream processing engine in Rust.

Transform, filter, aggregate, and join data streams by writing SQL, with sub-second results.
Scale from zero to millions of events per second.

Arroyo is a distributed stream processing engine written in Rust, designed to efficiently perform stateful computations on streams of data. Unlike traditional batch processing, streaming engines can operate on both bounded and unbounded sources, emitting results as soon as they are available.

• Arroyo @ GitHub.

Related contents:

• Fast columnar JSON decoding with arrow-rs @ arroyo.