Flink SQL 行列转换:UNNEST 展开、LISTAGG 聚合与 JSON 数组处理
「我的数据空间」实时计算实践笔记 Flink SQL 系列 Flink SQL 行列转换
使用 UNNEST 将一行转换为多行
-- 创建输入表
CREATE TABLE input_table (id INT,names ARRAY<STRING>
) WITH (...
);-- 使用 UNNEST 展开数组
SELECT id, name
FROM input_table CROSS JOIN UN…
2026/8/27 10:58:27