流计算能力功能说明

能力

说明

数据定义（DDL）

创建、修改、删除表、视图、函数等。

数据查询（DQL）

支持 SELECT、FROM、WHERE、GROUP BY、HAVING、ORDER BY、LIMIT、OFFSET；支持子查询（标量/行/表子查询）、JOIN（INNER/LEFT/RIGHT/FULL OUTER/CROSS/LATERAL）、窗口函数、表达式计算、类型转换、CASE WHEN 等。

数据操作（DML）

INSERT INTO 将查询结果写入目标表（支持追加或 UPSERT 模式）；流模式下不支持 UPDATE/DELETE 语句。

事务性 DML

依赖 Sink 实现幂等或事务性写入（如 Kafka 事务）。

能力

说明

时间属性

支持事件时间（Event Time）与处理时间（Processing Time）。

水印（Watermark）

处理乱序事件，控制延迟容忍度。

窗口（Windowing）

支持滚动窗口（Tumbling）、滑动窗口（Hopping）、会话窗口（Session）、累积窗口（Cumulative）、基于元素数量的窗口（Count-based）。

窗口 TVF

支持 TUMBLE、HOP、SESSION、CUMULATE。

类别

示例

标量函数

UPPER()、SUBSTRING()、ROUND()、COALESCE()

聚合函数

COUNT、SUM、AVG、MAX、MIN、ARRAY_AGG、JSON_OBJECTAGG

窗口函数

ROW_NUMBER()、RANK()、LEAD()、LAG()、FIRST_VALUE()

时间函数

CURRENT_TIMESTAMP、DATE_FORMAT、TIMESTAMPDIFF、LOCALTIMESTAMP

JSON 函数

JSON_VALUE、JSON_QUERY、JSON_EXISTS、JSON_OBJECT、JSON_ARRAY

条件函数

CASE WHEN、IF、NULLIF、COALESCE

类型转换

CAST(value AS TYPE)