Flink CDC里flink-sql 中json_array 类型 怎么转成 array类型？

在Apache Flink SQL中，如果你有一个JSON_ARRAY类型的字段，并希望将其转换为Flink SQL中的ARRAY类型，你可以使用内置的JSON函数来实现这一转换。假设你的JSON_ARRAY是一个字符串形式，可以按照以下步骤进行转换：

-- 假设原始表中有名为json_column的JSON_ARRAY类型的列
SELECT 
    -- 使用from_json函数将JSON字符串转换为指定类型的行
    EXPLODE(
        -- 将JSON_ARRAY转换为ARRAY<ROW>
        from_json(json_column, 'ARRAY<ROW<...>>')
    ) as exploded_array
FROM 
    your_table;

这里的...需要替换为JSON数组中每个元素的具体结构，例如，如果JSON数组中的每个元素都是INT类型，那么可以这样写：

from_json(json_column, 'ARRAY<INT>')

如果数组元素是复杂对象，比如每个元素是一个包含多个字段的JSON对象，可以定义一个对应的ROW结构：

from_json(json_column, 'ARRAY<ROW<field1 STRING, field2 INT>>')

这里field1 STRING, field2 INT代表每个数组元素中预期的JSON对象结构。

需要注意的是，EXPLODE函数会将数组中的每个元素“炸裂”成多行，使得每行包含一个数组元素的内容。如果不希望展平数组，而是保持数组结构，只需去掉EXPLODE函数即可。

自定义udf函数。此回答来自钉群Flink CDC 社区。