flinksql把"area": [ "1", "2","3" ],读取成行
时间: 2023-09-10 15:13:24 浏览: 113
基于Flink+SQL实现数据同步.doc
你可以使用Flink SQL中的LATERAL TABLE函数将"area"数组展开为行。以下是一个示例代码:
```sql
SELECT id, areaVal
FROM myTable, LATERAL TABLE(UNNEST(area)) AS T(areaVal)
```
假设你的输入数据流中有一个名为"myTable"的表,其中包含"area"字段作为一个数组。上述查询将展开"area"数组,并输出每个元素所属的"id"。你可以根据需要调整查询来适应其他需求。
请注意,这是Flink中的一种处理数组的方法,具体实现可能因版本和环境而异。确保你的Flink版本支持LATERAL TABLE和UNNEST函数。
阅读全文