像如下这种JSON输入,

{
  "id": 1,
  "many_names": [
    {"name": "foo"},
    {"name": "bar"}
  ]
}

输出表两行  id 1, name foo  |  id 1, name bar

最佳实践是从Kafka读到后,调用TableFunction这个UDTF转出多行?
还是Flink SQL有更方便的操作,从Source读出来就能把数组展开。


来自 Outlook<http://aka.ms/weboutlook>

回复