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

[Yan,Yunpeng(DXM,PB)]

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

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



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

闫云鹏

[Danny Chan]

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

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

Best,
Danny Chan
在 2020年9月2日 +0800 PM3:54，[hidden email]，写道：
>
> [
> {
> f:f
> },{
> g:g
> }
> ]

[Yan,Yunpeng(DXM,PB)]

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

闫云鹏

 
 
在 2020/9/2 16:51，“Danny Chan”<[hidden email]> 写入:

    [
    {
    f:f
    },{
    g:g
    }
    ]
   
    可否用 Array<Map<>> 来表达？
   
    Best,
    Danny Chan
    在 2020年9月2日 +0800 PM3:54，[hidden email]，写道：
    >
    > [
    > {
    > f:f
    > },{
    > g:g
    > }
    > ]