[
https://issues.apache.org/jira/browse/FLINK-1121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Márton Balassi resolved FLINK-1121.
-----------------------------------
Resolution: Fixed
Resolved in the following commit:
https://github.com/apache/incubator-flink/commit/70464bb0a44f682c155fdfdd2a6b0a6cc1203663
> Add minBy and maxBy operators to the streaming api
> --------------------------------------------------
>
> Key: FLINK-1121
> URL: https://issues.apache.org/jira/browse/FLINK-1121
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Affects Versions: 0.7-incubating
> Reporter: Gyula Fora
> Assignee: Gyula Fora
> Priority: Minor
>
> The minBy and maxBy operators are missing from the streaming api, so a
> similar operator as in batch should be added.
> The operator would always return the current min/max element in the
> datastream so far. An optional parameter should be added to choose to return
> the first or last min/max value occurance.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
