[
https://issues.apache.org/jira/browse/FLINK-2184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960760#comment-15960760
]
ASF GitHub Bot commented on FLINK-2184:
---------------------------------------
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3110
Thanks @gallenvara, the changes look good to me but we would also need a
few tests.
@aljoscha, what do you think about this change? Should we add it to be
consistent with the Java API or do you think it would bloat the API too much?
IIRC, there have been some discussions about the built-in aggregation functions.
Best, Fabian
> Cannot get last element with maxBy/minBy
> ----------------------------------------
>
> Key: FLINK-2184
> URL: https://issues.apache.org/jira/browse/FLINK-2184
> Project: Flink
> Issue Type: Improvement
> Components: DataStream API, Scala API
> Reporter: Gábor Hermann
> Priority: Minor
>
> In the streaming Scala API there is no method
> {{maxBy(int positionToMaxBy, boolean first)}}
> nor
> {{minBy(int positionToMinBy, boolean first)}}
> like in the Java API, where _first_ set to {{true}} indicates that the latest
> found element will return.
> These methods should be added to the Scala API too, in order to be consistent.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
