[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568812#comment-14568812 ] ASF GitHub Bot commented on FLINK-2103: --- Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/743#issuecomment-107875574 While merging realized, that it is missing from the windowed and connected datastreams and the from the scala API. Also adding those. > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568754#comment-14568754 ] ASF GitHub Bot commented on FLINK-2103: --- Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/743#issuecomment-107854661 Good point, will do that anyway because of the renaming discussed on the mailing list. > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568750#comment-14568750 ] ASF GitHub Bot commented on FLINK-2103: --- Github user aljoscha commented on the pull request: https://github.com/apache/flink/pull/743#issuecomment-107853775 We should first update the documentation. > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568742#comment-14568742 ] ASF GitHub Bot commented on FLINK-2103: --- Github user mbalassi commented on the pull request: https://github.com/apache/flink/pull/743#issuecomment-107853134 Merging. > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564379#comment-14564379 ] Márton Balassi commented on FLINK-2103: --- One slight difference is that the GroupedDataStream knows it goruping key and this way the output of the partitioning will not know the partitioning key. > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564372#comment-14564372 ] Márton Balassi commented on FLINK-2103: --- I see that the batch API also has it, so it makes no sense to not have it. +1 from my side. > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14564363#comment-14564363 ] Aljoscha Krettek commented on FLINK-2103: - For example if they want to make sure that elements always go to the same machine because they have some state for this key that they manually manage in a map function. > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14563759#comment-14563759 ] Márton Balassi commented on FLINK-2103: --- Why is this needed, why wouldn't the user explicitly group by in a case like this? > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Commented] (FLINK-2103) Expose partitionBy to the user in Stream API
[ https://issues.apache.org/jira/browse/FLINK-2103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14563227#comment-14563227 ] ASF GitHub Bot commented on FLINK-2103: --- GitHub user aljoscha opened a pull request: https://github.com/apache/flink/pull/743 [FLINK-2103] Expose partitionBy to user You can merge this pull request into a Git repository by running: $ git pull https://github.com/aljoscha/flink user-partition-by Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/743.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #743 commit b5ba40739008e988905e0b9d58d0a6e2cc37e73f Author: Aljoscha Krettek Date: 2015-05-28T08:40:56Z [FLINK-2103] Expose partitionBy to user > Expose partitionBy to the user in Stream API > > > Key: FLINK-2103 > URL: https://issues.apache.org/jira/browse/FLINK-2103 > Project: Flink > Issue Type: Improvement >Affects Versions: 0.9 >Reporter: Aljoscha Krettek >Assignee: Aljoscha Krettek > > Is there a reason why this is not exposed to the user? I could see cases > where this would be useful to have. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
