Arcon

Arcon 是一个用于在 Rust 中构建以状态优先的流式应用程序的库。

项目状态

Arcon 正处于开发中，应被视为实验性，直到另行通知。

API 可能会更改，您不应使用重要数据运行 Arcon！

Rust 版本

Arcon 针对最新稳定版本进行构建，当前 MSRV 为 1.56.1

路线图

请参阅路线图 此处

亮点

• 乱序处理
• 事件时间 & 水印
• 用于精确一次处理的纪元快照
• 混合行（Protobuf）/ 列（Arrow）系统
• 模块化状态后端抽象

示例

#[arcon::app]
fn main() {
    (0..100u64)
        .to_stream(|conf| conf.set_arcon_time(ArconTime::Process))
        .filter(|x| *x > 50)
        .map(|x| x * 10)
        .print()
}

更多示例可以在 此处 找到。

项目布局

• arcon: Arcon 包
• arcon_build: Protobuf 构建器
• arcon_macros: Arcon derive 宏
• arcon_tests: 集成测试
• arcon_util: 公共 Arcon 工具
• examples: 示例应用程序
• website: 项目网站

贡献

请参阅 贡献

社区

Arcon 是一个雄心勃勃的项目，具有许多不同的开发和研究领域。

如果您对 Arcon 感兴趣并想了解更多，请加入 Zulip 社区！

致谢

Arcon受到了许多优秀项目的启发，无论是在实现、代码实践还是项目结构方面。

• Tokio
• Datafusion
• Apache Flink
• Sled

许可证

本项目采用Apache-2.0许可证，具体请见此处。

贡献

除非您明确声明，否则您提交给Arcon的任何有意贡献都应按照Apache-2.0许可证授权，无需附加条款或条件。