[FLINK-3234] SortPartition does not support KeySelectorFunctions

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Affects Version/s: 0.10.1, 1.0.0
• Fix Version/s: 1.0.0
• Component/s: API / DataSet
• Assignee: Chiwan Park
• Reporter: Fabian Hueske
• Created: 14/Jan/16 10:35
• Updated: 10/Feb/16 11:06
• Resolved: 10/Feb/16 11:06

Description

The following is not supported by the DataSet API:

DataSet<MyObject> data = ...
DataSet<MyObject> data.sortPartition(
  new KeySelector<MyObject, Long>() {
    public Long getKey(MyObject v) {
      ...
    }
  }, 
  Order.ASCENDING);