[
https://issues.apache.org/jira/browse/FLINK-2105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625409#comment-14625409
]
ASF GitHub Bot commented on FLINK-2105:
---------------------------------------
GitHub user r-pogalz opened a pull request:
https://github.com/apache/flink/pull/907
FLINK-2105: Implement Sort-Merge Outer Join algorithm
This pull request relates to
[FLINK-2105](https://issues.apache.org/jira/browse/FLINK-2105) and includes:
* Extraction of the MergeMatchIterator logic, so that also the
SMOuterJoinIterators can use it
* Extension of the TestData.Generator to provide meaningful test cases
* Implementation of the NonReusing- and ReusingMergeOuterJoinIterator +
test cases for both iterators
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/r-pogalz/flink feature/FLINK-2105
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/907.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 #907
----
commit 0ef246aba5d303198a71c20110c365dd0d0202c5
Author: Johann Kovacs <[email protected]>
Date: 2015-07-10T15:21:58Z
[FLINK-2105] Extract abstract superclass, interface from
MergeMatchIterators, KeyGroupedIterators
commit 93108e0135f009810d05895bfec0b64159c62d6b
Author: Johann Kovacs <[email protected]>
Date: 2015-07-10T15:26:05Z
[FLINK-2105] Add support for sorted but sparse test data generation
commit 02721139d2b129d66379800b30e2eaabc4c6e9e9
Author: r-pogalz <[email protected]>
Date: 2015-07-10T15:27:46Z
[FLINK-2105] Implement Sort-Merge Outer Join algorithm
----
> Implement Sort-Merge Outer Join algorithm
> -----------------------------------------
>
> Key: FLINK-2105
> URL: https://issues.apache.org/jira/browse/FLINK-2105
> Project: Flink
> Issue Type: Sub-task
> Components: Local Runtime
> Reporter: Fabian Hueske
> Assignee: Ricky Pogalz
> Priority: Minor
> Fix For: pre-apache
>
>
> Flink does not natively support outer joins at the moment.
> This issue proposes to implement a sort-merge outer join algorithm that can
> cover left, right, and full outer joins.
> The implementation can be based on the regular sort-merge join iterator
> ({{ReusingMergeMatchIterator}} and {{NonReusingMergeMatchIterator}}, see also
> {{MatchDriver}} class)
> The Reusing and NonReusing variants differ in whether object instances are
> reused or new objects are created. I would start with the NonReusing variant
> which is safer from a user's point of view and should also be easier to
> implement.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
