跳到主要内容
版本:Next

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 处理器,端到端用法参见实战配方。