将列值设置为Flink SQL查询结果中的列名

Question

我想读取一个表，该表的值将成为Flink SQL查询结果的列名。例如，我将t1作为

name value
----------
sp_1 100
sp_2 200
sp_3 300
...  ...

现在我希望查询的结果如下(t2(：

sp_1 sp_2 sp_3 ...
100  200  300

假设所有sp_*都已在t2中创建。

有可能通过Flink SQL实现吗？

Flink版本：1.13.6

Answer 1

我相信使用PIVOT和UNPIVOT函数是可能的，在编写本文时，这些函数还不受支持。你可以跟踪https://issues.apache.org/jira/browse/FLINK-23179以获取更新。