flink sql 使用Table Function或Array Expansion 实现列转行(附源码实现)

阎阎宝
2023-12-01

1 需求

在使用flink sql处理数据时,经常会遇到一列转多行的需求。如将下面消息中转化为三条记录

{
   
    "name":"张三峰",
    "urls":[
        {
   
            "content_type":"tool",
            "url":"http://json.la/"
        },
        
 类似资料: