[FLINK-7404] [table] Generate code for non-equi join conditions only. This closes #4507.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/50f6c752 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/50f6c752 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/50f6c752 Branch: refs/heads/release-1.3 Commit: 50f6c752de4d509d24980b75c799c5898aa1f811 Parents: 0e2e9cb Author: Fabian Hueske <fhue...@apache.org> Authored: Wed Aug 9 17:41:10 2017 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Tue Sep 5 15:54:18 2017 +0200 ---------------------------------------------------------------------- .../org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/50f6c752/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala ---------------------------------------------------------------------- diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala index e6f8ca4..ba0af45 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/dataset/DataSetJoin.scala @@ -177,7 +177,8 @@ class DataSetJoin( |""".stripMargin } else { - val condition = generator.generateExpression(joinCondition) + val nonEquiPredicates = joinInfo.getRemaining(this.cluster.getRexBuilder) + val condition = generator.generateExpression(nonEquiPredicates) body = s""" |${condition.code} |if (${condition.resultTerm}) {
