GitHub user vasia opened a pull request:
https://github.com/apache/flink/pull/1632
[FLINK-3226] Translate logical joins to physical
This PR contains the logical to physical translation for joins.
- Joins with equality conditions only do not generate a join function.
- Joins with equality and non-equality conditions evaluate the non-equality
conditions inside a `FlatJoinFunction`.
- Joins without any equality conditions e.g. `in1.join.n2.where(a > b)` are
currently not supported. We could consider supporting those later by generating
a cross function.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/vasia/flink translateJoin
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1632.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 #1632
----
commit f4563cf2ea78a993b00f6398006b1a064ad83857
Author: vasia <va...@apache.org>
Date: 2016-02-11T17:04:45Z
[FLINK-3226] Translate logical joins to physical
----
---
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.
---
