arroyo

Arroyo是一个用Rust编写的分布式流处理引擎，专为高效执行数据流上的状态计算而设计。其核心功能包括支持SQL流处理管道、每秒可处理数百万事件的高扩展性、提供窗口和连接等状态操作以及通过状态检查点实现容错和恢复。此外，Arroyo采用Dataflow模型进行时间导向的流处理，并支持Kafka和Iceberg等多种连接器。适用于需要实时分析大量数据的场景，如欺诈检测、实时业务分析、数据仓库或数据湖的实时摄入以及机器学习特征生成等。