Flink实战系列Flink SQL 字符串类型的字段如何实现列转行？

Posted 2022-12-06 JasonLee实时计算

Flink SQL 字符串类型的字段如何实现列转行？

问题描述

普通的列转行可以参考这篇文章，https://mp.weixin.qq.com/s/3oQRUO0A8G96qbM97UuisA

通常情况下，列转行的需求都是在一个 Array 里面是 Row 类型这样的结构下才可以使用上面的方式，那如果字段是 String 类型的，而且不想通过 UDTF 的方式实现，只使用 Flink SQL 内置函数有什么解决方案吗？

原始数据

   
	"id": "1",
	"tag": "tag1,tag2,tag3"

期望数据