[
https://issues.apache.org/jira/browse/FLINK-662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen resolved FLINK-662.
--------------------------------
Resolution: Fixed
Fix Version/s: (was: pre-apache)
0.7-incubating
Fixed with the introduction of the {{FlatJoinFunction}}
> JoinFunction with Collector
> ---------------------------
>
> Key: FLINK-662
> URL: https://issues.apache.org/jira/browse/FLINK-662
> Project: Flink
> Issue Type: Improvement
> Reporter: GitHub Import
> Labels: github-import
> Fix For: 0.7-incubating
>
>
> The new JoinFunction does not provide a collector for the output. In some
> cases it could be beneficial to have such an collector as in the previous
> API. I propose to create an additional function (name to be discusses) that
> offers a Join with collector (like map <-> flatMap, reduce <-> groupReduce).
> This issue came up by the implementation of a PageRank algorithm, where it is
> currently necessary to use an coGroup to simulate a join.
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/issues/662
> Created by: [markus-h|https://github.com/markus-h]
> Labels: enhancement, java api, user satisfaction,
> Created at: Mon Apr 07 11:56:59 CEST 2014
> State: open
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
