如何在 flink 中将 int 列聚合到 array<int>？
How can I aggregate int column to array<int> in flink?
我正在探索一种方法来实现这一点，就像下面在 flink 中的 SQL。
SELECT a_tag,NEST(type) AS type_arr FROM a GROUP BY a_tag
NEST() 是 user defined function 聚合 int 到 array<int>。
但我无法更改输出类型，因为 UDF class 扩展了 AggregateFunction
有什么建议吗？非常感谢。
Flink 提供了一个内置的聚合函数 collect() 可以处理这种情况。
请注意 collect() 的结果类型将为 MULTISET
我正在探索一种方法来实现这一点，就像下面在 flink 中的 SQL。
SELECT a_tag,NEST(type) AS type_arr FROM a GROUP BY a_tag
NEST() 是 user defined function 聚合 int 到 array<int>。
但我无法更改输出类型，因为 UDF class 扩展了 AggregateFunction
有什么建议吗？非常感谢。
Flink 提供了一个内置的聚合函数 collect() 可以处理这种情况。
请注意 collect() 的结果类型将为 MULTISET