[
https://issues.apache.org/jira/browse/FLINK-2138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14605711#comment-14605711
]
ASF GitHub Bot commented on FLINK-2138:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/872#issuecomment-116710090
I am confused now, what is it going to be?
1. Overloading, such that it is Scala function and Partitioner, at the
cost of redundant APIs.
2. Only partitioner (sync with batch API)
3. Only Scala function (break with batch API)
I am not a big fan of (1), as these redundant options are confusing
blow-ups of the APIs.
> 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)
