flinksql切分数组

在 Flink SQL 中，可以使用 `LATERAL TABLE` 和 `TABLE()` 函数对数组进行切分。

假设有一个包含数组的表，例如：

CREATE TABLE my_table (
  id INT,
  arr ARRAY<STRING>
) WITH (
  'connector.type' = 'filesystem',
  'connector.path' = '/path/to/my_table',
  'format.type' = 'csv'
);

要将数组切分成多行，可以使用以下语句：

SELECT id, item
FROM my_table
LATERAL TABLE(
  TABLE(arr)
) AS T(item)

这将生成一个包含每个数组元素的新行，其中 `id` 列与原始表中的相同。

如果要将数组切分成多列，则可以使用以下语句：

SELECT id, item1, item2, item3
FROM my_table
LATERAL TABLE(
  TABLE(arr)
) AS T(item1, item2, item3)

这将生成一个新行，其中包含每个数组元素的值作为新列。注意，这需要指定与数组元素数量相同的列。

希望这可以帮助到你。