【闫云鹏】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这种来支持的，但是测试了几次都没成功，能给个实例？

闫云鹏

回复