Gyula Fora created FLINK-1121:
---------------------------------
Summary: 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)
