回复: Flink SQL处理Array型的JSON

[hua mulan <de...@outlook.com>]

Hello，Leonard Xu

我这边JSON 不是

{
    "id": 2,
    "heap": [
        {
            "foo": 14,
            "bar": "foo"

        },
        {
            "foo": 16,
            "bar": "bar"
        }
    ],
}

而是直接一个Array

[
        {
            "foo": 14,
            "bar": "foo"

        },
        {
            "foo": 16,
            "bar": "bar"
        }
    ]

我发现DDL没法声明，SQL层面我不知道怎么做了。

可爱的木兰

________________________________
发件人: Leonard Xu <xb...@gmail.com>
发送时间: 2020年7月14日 10:42
收件人: user-zh <us...@flink.apache.org>
主题: Re: Flink SQL处理Array型的JSON

Hello，可爱的木兰

可以不用改json的，可以用 UNNEST 把数组拆成多行，也可以写UDTF自己解析对应字段，参考[1]

SELECT users, tag
FROM Orders CROSS JOIN UNNEST(tags) AS t (tag)

Best，
Leonard Xu
[1] https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/sql/queries.html <https://ci.apache.org/projects/flink/flink-docs-master/zh/dev/table/sql/queries.html>

> 在 2020年7月14日，10:34，hua mulan <de...@outlook.com> 写道：
>
> 可爱的木兰