@@ -833,14 +833,14 @@ public SingleOutputStreamOperator<T> minBy(int positionToMinBy) {
833
833
834
834
/**
835
835
* Applies an aggregation that gives the minimum element of every window of
836
- * the data stream by the given position . If more elements have the same
836
+ * the data stream by the given field . If more elements have the same
837
837
* minimum value the operator returns the first element by default.
838
838
*
839
- * @param positionToMinBy The position to minimize by
839
+ * @param field The field to minimize by
840
840
* @return The transformed DataStream.
841
841
*/
842
- public SingleOutputStreamOperator <T > minBy (String positionToMinBy ) {
843
- return this .minBy (positionToMinBy , true );
842
+ public SingleOutputStreamOperator <T > minBy (String field ) {
843
+ return this .minBy (field , true );
844
844
}
845
845
846
846
/**
@@ -912,15 +912,15 @@ public SingleOutputStreamOperator<T> maxBy(int positionToMaxBy) {
912
912
913
913
/**
914
914
* Applies an aggregation that gives the maximum element of every window of
915
- * the data stream by the given position . If more elements have the same
915
+ * the data stream by the given field . If more elements have the same
916
916
* maximum value the operator returns the first by default.
917
917
*
918
- * @param positionToMaxBy
919
- * The position to maximize by
918
+ * @param field
919
+ * The field to maximize by
920
920
* @return The transformed DataStream.
921
921
*/
922
- public SingleOutputStreamOperator <T > maxBy (String positionToMaxBy ) {
923
- return this .maxBy (positionToMaxBy , true );
922
+ public SingleOutputStreamOperator <T > maxBy (String field ) {
923
+ return this .maxBy (field , true );
924
924
}
925
925
926
926
/**
0 commit comments