Блог

Я изучаю способ достижения этого, как приведенный ниже SQL в flink.

 SELECT a_tag,NEST(type) AS type_arr FROM a GROUP BY a_tag
 

NEST() является user defined function ли совокупность whitch int array<int> .

Но я не могу изменить тип вывода, потому что класс UDF расширяется AggregateFunction

Есть ли какие-либо предложения?Большое спасибо.

Flink предоставил встроенную функцию агрегирования под названием collect() whitch, которая может справиться с этой ситуацией.

Обратите внимание, что тип результата collect() будет MULTISET