Fabian Hueske created FLINK-1461: ------------------------------------ Summary: Add sortPartition operator Key: FLINK-1461 URL: https://issues.apache.org/jira/browse/FLINK-1461 Project: Flink Issue Type: New Feature Components: Java API, Local Runtime, Optimizer, Scala API Reporter: Fabian Hueske Priority: Minor
A {{sortPartition()}} operator can be used to * sort the input of a {{mapPartition()}} operator * enforce a certain sorting of the input of a given operator of a program. -- This message was sent by Atlassian JIRA (v6.3.4#6332)