[GitHub] [rocketmq-flink] kongslove opened a new issue #24: rocketMQ connector how to handle nested json

[GitBox <gi...@apache.org>]

kongslove opened a new issue #24:
URL: https://github.com/apache/rocketmq-flink/issues/24


   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
     }
    }
   }


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org