ArkFlow 文档

ArkFlow 是一个用 Rust 编写的高性能流处理引擎。它从任意数据源消费数据,用 SQL / Python / VRL 进行处理,再投递到任意下游——具备预写日志(WAL)持久化、检查点状态,以及用于运行机群的可选控制平面。

🚀 快速上手

安装二进制文件,五分钟内运行你的第一条流水线,并让它经受住崩溃的考验。

🔧 构建

流、作业与 DAG;组件目录;持久化与投递语义;面向任务的实战配方。

🗄️ SQL

完整的 SQL 语言能力:数据类型、SELECT、聚合、窗口函数和用户自定义函数(UDF)。

🛠️ 运维

Kubernetes 部署、控制平面与 Web 控制台、可观测性,以及一份恢复手册。

📖 参考

CLI、完整的 HTTP API、配置 Schema,以及自动生成的组件清单。

⚙️ 开发

统一执行内核、插件编写,以及来自源码的性能笔记。

选择你的路径

你是……	从这里开始
正在评估 ArkFlow	快速入门 → 架构
正在编写流水线	流 → 组件 → 实战配方
正从 Kafka Connect / Flink 迁移	兼容性策略 → 投递语义
正在生产环境运行	Kubernetes → 可观测性 → 恢复
正在运行机群	控制平面 → Web 控制台
正在扩展引擎	编写插件 → 执行内核