【flink】udf数组类型参数 row[]

阅读量：

文章结构概览

- - - 要求
  - 探索
  - 最终确定的解决策略

需求

需对具有特定结构的kafka数据源（以json格式呈现）进行处理，统计满足f1.name与f0.name相等的记录数量。

在这里插入图片描述

尝试

复制代码

    create view f0_view as
    select
    session_id,
    proc_time,
    	name
    from gsy_ods,unnest(persons) as t(name, age);
    
    
    create view f1_view as
    select
    session_id,
    proc_time,
    name
    from gsy_ods,unnest(f1) as t(name ,age);
    
    create view a as
    select
    a.session_id,
    a.proc_time,
    a.pername
    from

全部评论 (0)

还没有任何评论哟~