Fabian Hueske created FLINK-3234: ------------------------------------ Summary: SortPartition does not support KeySelectorFunctions Key: FLINK-3234 URL: https://issues.apache.org/jira/browse/FLINK-3234 Project: Flink Issue Type: Improvement Components: DataSet API Affects Versions: 0.10.1, 1.0.0 Reporter: Fabian Hueske Fix For: 1.0.0
The following is not supported by the DataSet API: {code} DataSet<MyObject> data = ... DataSet<MyObject> data.sortPartition( new KeySelector<MyObject, Long>() { public Long getKey(MyObject v) { ... } }, Order.ASCENDING); {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)