GitHub user lincoln-lil opened a pull request:
https://github.com/apache/flink/pull/3379
[FLINK-5498] [table] Add support for left/right outer joins with non-â¦
â¦equality predicates (and 1+ equality predicates)
Support left/right outer joins with non-equi-join conditions via coGroup
operator with a generated OuterJoinCoGroupFunction.
It should be noted that current implementation is not memory safe when do a
many-to-one outer
join which will copy the opposite side input into an ArrayList buffer. It's
a work-around for now due to the backend limitation of shared iterator instance.
In the long run, I think we should extend the runtime join operators to
support such more join conditions.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/lincoln-lil/flink FLINK-5498
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3379.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 #3379
----
commit 224ff229feb62db974c910f82bf9aea403949712
Author: lincoln-lil <lincoln.8...@gmail.com>
Date: 2017-02-16T09:05:49Z
[FLINK-5498] [table] Add support for left/right outer joins with
non-equality predicates (and 1+ equality predicates)
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
