rocketMQ connector how to handle nested json

[kongslove]

How do I handle nested json in SQL, use ROW or Map like kafka,such as : { "funcName": "test", "data": { "snapshots": [{ "content_type": "application/x-gzip-compressed-jpeg", "url": "https://blog.csdn.net/xianpanjia4616" }], "audio": [{ "content_type": "audio/wav", "url": " https://bss.csdn.net/m/topic/blog_star2020/detail?username=xianpanjia4616" }] }, "resultMap": { "result": { "cover": "/data/test/log.txt" }, "isSuccess": true }, "meta": { "video_type": "normal" }, "type": 2, "timestamp": 1610549997263, "arr": [{ "address": "北京市海淀区", "city": "beijing" }, { "address": "北京市海淀区", "city": "beijing" }, { "address": "北京市海淀区", "city": "beijing" }], "map": { "flink": 456 }, "doublemap": { "inner_map": { "key": 123 } } }

[SteNicholas]

@kongslove, you should use map() to handle the body of the MessageExt with the nested json.