如何在Flink SQL 1.13.6中将表值转为查询结果列名？

可以通过Flink SQL实现该需求，核心思路是利用CASE WHEN结合聚合函数完成行转列（透视）操作，具体实现如下：

实现SQL示例 #

假设目标表t2的sp_1、sp_2、sp_3等列已提前创建，执行以下SQL即可将t1的数据转换为期望的格式：

INSERT INTO t2
SELECT
  MAX(CASE WHEN name = 'sp_1' THEN value END) AS sp_1,
  MAX(CASE WHEN name = 'sp_2' THEN value END) AS sp_2,
  MAX(CASE WHEN name = 'sp_3' THEN value END) AS sp_3,
  -- 若存在其他sp_*列，按上述格式依次添加
FROM t1;

逻辑说明 #

1. 针对t2的每一列，用CASE WHEN匹配t1中name列的对应值，取出对应的value；
2. 使用MAX（或MIN、FIRST_VALUE等聚合函数）是因为每个name对应唯一的value，聚合操作能确保最终只返回该列对应的单个有效值，避免多行结果；
3. 若处理的是流式数据，需要根据业务场景添加合适的分组键（如GROUP BY某个维度）或窗口函数，确保聚合逻辑符合流式计算的语义。

局限性说明 #

Flink 1.13.6的SQL不支持动态透视（即自动根据t1中name的所有取值生成目标列），因为Flink SQL是静态类型系统，输出Schema需要提前确定。但由于你已明确t2的列已创建完成，上述静态编码的方式完全可以满足需求。

内容的提问来源于stack exchange，提问作者guangleiw