You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "Yan,Yunpeng(DXM,PB)" <ya...@duxiaoman.com> on 2020/09/02 06:52:03 UTC

【闫云鹏】Flink sql 写入es实现object嵌套形式

Hi
       我使用flink sql mysql作为原表，多表join后将结果写入es的时候如何实现这种Object结构

{
   a:a,
   b:{
          c:c
          d:d
},
e:[
{
   f:f
},{
   g:g
}
]
}



看到了sql中支持的数据类型是有map 或者 row这种来支持的，但是测试了几次都没成功，能给个实例？

闫云鹏

Re: [DKIM Failure] Re: 【闫云鹏】Flink sql 写入es实现object嵌套形式

Posted by "Yan,Yunpeng(DXM,PB)" <ya...@duxiaoman.com>.

Hi:
	那使用sql怎么表示了？ 查询的结果怎么放入 arrya<Map<>>中  我刚才尝试使用GROUP_CONCAT来实现sql的拼接，但是flinksql不支持

闫云鹏

 
 
在 2020/9/2 16:51，“Danny Chan”<yu...@gmail.com> 写入:

    [
    {
    f:f
    },{
    g:g
    }
    ]
    
    可否用 Array<Map<>> 来表达？
    
    Best,
    Danny Chan
    在 2020年9月2日 +0800 PM3:54，user-zh@flink.apache.org，写道：
    >
    > [
    > {
    > f:f
    > },{
    > g:g
    > }
    > ]

Re:【闫云鹏】Flink sql写入es实现object嵌套形式

Posted by Danny Chan <yu...@gmail.com>.

[
{
f:f
},{
g:g
}
]

可否用 Array<Map<>> 来表达？

Best,
Danny Chan
在 2020年9月2日 +0800 PM3:54，user-zh@flink.apache.org，写道：
>
> [
> {
> f:f
> },{
> g:g
> }
> ]