Ho to convert flat json to nested complex json in Flink sql?

[1095193...@qq.com]

Hi community,
I'll receive json message from Kafka, convert flat json to nested json and send 
it back to Kafka.
receive message from Kafka: {“id”:"001","name":"wang"}
send message back to Kafka:  {"employee":{“id”:"001","name":"wang"}} 
How to do it in Flink sql?



1095193...@qq.com