在 SQL 任务里面经常会遇到一列转多行的需求,下面就来总结一下在 Flink SQL 里面如何实现列转行的,先来看下面的一个具体案例.
需求
原始数据格式如下:
name | data |
---|---|
test | [{"content_type":"flink","url":"111"},{"content_type":"spark","url":"222"},{"content_type":"hadoop","url":"333"}] |
data 格式化
{"name": "test","data": [{"content_type": "flink","url": "111"}, {"content_type": "spark","url": "222"},{"content_type": "hadoop&