Fabian Hueske created FLINK-3665: ------------------------------------ Summary: Range partitioning lacks support to define sort orders Key: FLINK-3665 URL: https://issues.apache.org/jira/browse/FLINK-3665 Project: Flink Issue Type: Improvement Components: DataSet API Affects Versions: 1.0.0 Reporter: Fabian Hueske Fix For: 1.1.0
{{DataSet.partitionByRange()}} does not allow to specify the sort order of fields. This is fine if range partitioning is used to reduce skewed partitioning. However, it is not sufficient if range partitioning is used to sort a data set in parallel. Since {{DataSet.partitionByRange()}} is {{@Public}} API and cannot be easily changed, I propose to add a method {{withOrders(Order... orders)}} to {{PartitionOperator}}. The method should throw an exception if the partitioning method of {{PartitionOperator}} is not range partitioning. -- This message was sent by Atlassian JIRA (v6.3.4#6332)