[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605880#comment-14605880
]
ASF GitHub Bot commented on FLINK-2138:
---------------------------------------
Github user gaborhermann commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116755999
Okay, then I will
* deprecate the partitioner implementation in the batch API
* add the function implementation to the batch API
* add the function implementation to the streaming API and remove the
partitioner implementation (so streaming will only have function
implementation). As this PR is not merged yet we do not break the streaming API.
Is it okay?
I guess it's worth it. This way Scala users will be able to write more
concise code and they will not get confused by the overloaded functions because
the ones with the partitioner will be deprecated.
> PartitionCustom for streaming
> -----------------------------
>
> Key: FLINK-2138
> URL: https://issues.apache.org/jira/browse/FLINK-2138
> Project: Flink
> Issue Type: New Feature
> Components: Streaming
> Affects Versions: 0.9
> Reporter: Márton Balassi
> Assignee: Gábor Hermann
> Priority: Minor
>
> The batch API has support for custom partitioning, this should be added for
> streaming with a similar signature.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
