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

enjoy编程

于 2021-09-17 14:36:26 发布

阅读量3.3k

点赞数 2

分类专栏： flink实战文章标签： flink udf udtf 列转行 flink sql

本文链接：https://blog.csdn.net/penriver/article/details/120345728

版权

flink实战专栏收录该内容

30 篇文章 ¥29.90 ¥99.00

订阅专栏

超级会员免费看

本文档介绍了在Flink SQL中如何处理列转行的需求，通过自定义UDTF（用户定义表值函数）和使用UNNEST操作。详细讲述了如何进入SQL客户端进行测试，包括基于UNNEST的数组扩展测试和UDTF函数测试，以及不同类型的JOIN操作在处理UDTF时的行为。同时，展示了如何将处理后的数据写入Kafka，并提供了源代码供参考。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

1 需求

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

{
   
    "name":"张三峰",
    "urls":[
        {
   
            "content_type":"tool",
            "url"<

了解本专栏

超级会员免费看