arroyo

Arroyo 是一个用 Rust 编写的分布式流处理引擎，支持高吞吐、低延迟的有状态实时数据计算。核心功能包括基于 SQL 的流式管道定义、时间窗口与多流 Join、精确一次（exactly-once）语义下的状态快照与容错恢复，以及 Kafka、Iceberg 等主流数据源/汇的原生连接器。其采用 Dataflow 模型，兼顾无界与有界流处理，单集群可支撑百万级事件每秒。适用于实时风控、业务指标看板、数仓实时入湖、机器学习特征在线生成等需要亚秒级响应的生产场景。