Поддерживает ли Flink совокупные пользовательские функции для API DataSet?

Question

Я знаю, что вы можете зарегистрировать агрегатный UDF (AggregateFunction) и использовать его в таблице API.Но можете ли вы сделать то же самое в API DataSet?Могу ли я, например, сделать следующее?

env.fromElements(...)
    .groupBy(0)
    .aggregate(MYUDFHERE, 1)
    .print();