Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5011#discussion_r151102649
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/utils/UserDefinedAggFunctions.scala
---
@@ -0,0 +1,107 @@
+package org.apache.flink.table.utils
+
+import org.apache.flink.table.functions.AggregateFunction
+import org.apache.flink.api.java.tuple.{Tuple2 => JTuple2}
+import java.lang.{Integer => JInt}
+import java.lang.{Float => JFloat}
+import java.util
+
+import org.apache.flink.api.common.typeinfo.TypeInformation
+import org.apache.flink.api.java.typeutils.{ObjectArrayTypeInfo,
TupleTypeInfo}
+import org.apache.flink.table.api.Types
+
+/**
+ * User-defined aggregation function to compute the TOP 10 most visited
pages.
--- End diff --
Adjust the comment:
```
User-defined aggregation function to compute the top 10 Int IDs with the
highest Float values.
We use an Array[Tuple2[Int, Float]] as accumulator to store the top 10
entries.
```
Could also be simplified to just store the Float.
---
