我正在使用 Apache nifi 处理来自不同资源的数据,并且我为每个数据流创建了独立的管道。我想结合这些数据进行进一步处理。有什么方法可以聚合数据并将其写入单个文件。数据以 Nifi 中的流文件属性的形式存在。
我有一个 Athena 表,它有一列包含值数组。我想从一行创建多行,以便数组的列可以更改为仅包含 1 个值。
例如:
Name Id PhoneNumber
Josh 123 [1236348475,5323794875]
Run Code Online (Sandbox Code Playgroud)
看起来像 :
Name Id PhoneNumber
Josh 123 1236348475
Josh 123 5323794875
Run Code Online (Sandbox Code Playgroud)
我该如何编写查询来实现这一目标?