flink实战 -- flink SQL 实现列转行
在 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&