Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/1856#discussion_r67345484
--- Diff:
flink-scala/src/main/scala/org/apache/flink/api/scala/GroupedDataSet.scala ---
@@ -356,6 +357,40 @@ class GroupedDataSet[T: ClassTag](
}
/**
+ * Applies a special case of a reduce transformation `maxBy` on a
grouped [[DataSet]]
+ * The transformation consecutively calls a [[ReduceFunction]]
+ * until only a single element remains which is the result of the
transformation.
+ * A ReduceFunction combines two elements into one new element of the
same type.
+ *
+ * @param fields Keys taken into account for finding the minimum.
+ * @return A [[ReduceOperator]] representing the minimum.
--- End diff --
The return type is not correct. You can remove `@param` and `@return` as
these are not used for the other methods in this class either.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
