[
https://issues.apache.org/jira/browse/FLINK-3234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132317#comment-15132317
]
ASF GitHub Bot commented on FLINK-3234:
---------------------------------------
Github user fhueske commented on the pull request:
https://github.com/apache/flink/pull/1585#issuecomment-179835764
Hi @chiwanpark, thanks for picking up this issue and filling this gap in
the DataSet API.
Would be nice, if it could make it into the 1.0 release, IMO.
However, the implementation needs to be improved. I suggest to have a look
at the `PartitionOperator` and check how `KeySelector`s are handled there.
> 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: 1.0.0, 0.10.1
> Reporter: Fabian Hueske
> Assignee: Chiwan Park
> 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)
