SQL 参考
ArkFlow 的 SQL 处理器由 Apache DataFusion 驱动。你可以在流水线中使用它对列式批次进行过滤、投影、聚合与重塑——窗口函数可用于事件时间分析,内置函数不够用时还可以注册用户自定义函数(UDF)。
| 章节 | 内容 |
|---|---|
| 数据类型(Data Types) | 受支持的 SQL 类型及其对应的 Arrow 类型。 |
| 运算符与字面量(Operators and Literals) | 算术、比较和逻辑运算符。 |
| SELECT | 查询语法,WHERE、GROUP BY、HAVING、ORDER BY、LIMIT。 |
| 子查询(Subqueries) | 标量、IN 与 EXISTS 子查询。 |
| 聚合函数(Aggregate Functions) | count、sum、avg 等聚合函数。 |
| 窗口函数(Window Functions) | OVER 子句、排名与分析函数。 |
| 标量函数(Scalar Functions) | 完整的内置函数目录。 |
| 特殊函数(Special Functions) | 编码、时间与实用函数。 |
| UDF | 注册和调用用户自定义函数。 |
FROM batch 子句指代流经流水线的当前 Arrow 批次——配置与语义参见 SQL 处理器,端到端用法参见实战配方。