[ https://issues.apache.org/jira/browse/FLINK-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14315786#comment-14315786 ]
ASF GitHub Bot commented on FLINK-1461: --------------------------------------- GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/381 [FLINK-1461][api-extending] Add SortPartition operator to Java and Scala APIs. Adds the sortPartition operator to locally sort partitions of a DataSet. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fhueske/flink sortPartition Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/381.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #381 ---- commit 4f4708afdc8624fa4cbe28d21e8423a7a57a8946 Author: Fabian Hueske <fhue...@apache.org> Date: 2015-02-10T17:35:13Z [FLINK-1461][api-extending] Add SortPartition operator to Java and Scala APIs. This closes #381 ---- > 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 > Assignee: 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)