Re: [DKIM Failure] Re: flink-CDC client 一对多问题

Mon, 21 Sep 2020 00:00:58 -0700 

Fink sql cdc client 好多sql函数都不支持呀，比如CONCAT(a,b,c) 或者 GROUP_CONCAT（a,b）

是我还需要引入什么包么？如果支持的话，上面说的这种格式就可以用GROUP_CONCAT 很好的解决了，

另外Fink sql cdc client只支持部分sql操作么？具体支持那些函数，有相关的官方文档么？


在 2020/9/21 下午1:42，“Jark Wu”<imj...@gmail.com> 写入:

    你可以通过 groupby collect 来将一对多的关系聚合起来，代码类似如下：
    
    select userId, collect(userBankTime)
    from (
      select  userId, concat(userBankNo, '_', createTime) as userBankTime
      from aa as a left join bb as b where a.userId=b.userId
    ) group by userId;
    
    
    Best,
    Jark
    
    On Mon, 21 Sep 2020 at 12:20, Li,Qian(DXM,PB) <liq...@duxiaoman.com> wrote:
    
    > 请问：
    >
    > 我在使用Flink CDC SQL CLI的时候，想将关联的两张表的一对多关系
    > 映射成ARRAY[ROW(userBankNo,createTime)]的形式，要怎么映射呢？
    >   表aa
    >   id, userId
    >   表 bb
    >   userId,userBankNo,createTime
    >
    > select  * from aa as a left join bb as b where a.userId=b.userId
    >
    > 谢谢！
    >
    >

回复