Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
0.7.0-incubating
-
None
-
None
-
None
Description
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.