Hey everyone, We have a Apache Spark job that is using a UDAF to aggregate

List[Int] -> Map[Int, Int]

, Can some one point me to use UDAF aggregations in Flink. I tried to search but have not found any example.

There’s documentation and an example here: https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/table/functions/udfs/#aggregate-functions

Thank you @David Anderson, my bad worked too much on spark need to clear my head. I was searching for UDAF specifically 🙂 hvn’t thought UDF section might contained all the info.