DRILL-1277: Rewrite compound identifiers in 'ON' clause as item operator
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/d4a07dbc Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/d4a07dbc Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/d4a07dbc Branch: refs/heads/master Commit: d4a07dbc6e492f5c9a071772c470b6f4b54c10d1 Parents: a74fe3d Author: Mehant Baid <meha...@gmail.com> Authored: Mon Aug 11 11:37:06 2014 -0700 Committer: Aditya Kishore <adi...@maprtech.com> Committed: Mon Aug 18 14:56:52 2014 +0530 ---------------------------------------------------------------------- .../drill/exec/planner/sql/parser/CompoundIdentifierConverter.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/d4a07dbc/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/parser/CompoundIdentifierConverter.java ---------------------------------------------------------------------- diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/parser/CompoundIdentifierConverter.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/parser/CompoundIdentifierConverter.java index 9a44f9c..061524d 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/parser/CompoundIdentifierConverter.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/parser/CompoundIdentifierConverter.java @@ -22,6 +22,7 @@ import java.util.Map; import org.eigenbase.sql.SqlCall; import org.eigenbase.sql.SqlIdentifier; +import org.eigenbase.sql.SqlJoin; import org.eigenbase.sql.SqlNode; import org.eigenbase.sql.SqlSelect; import org.eigenbase.sql.util.SqlShuttle; @@ -144,6 +145,7 @@ public class CompoundIdentifierConverter extends SqlShuttle { rules.put(SqlShowFiles.class, R(D)); rules.put(SqlShowSchemas.class, R(D, D)); rules.put(SqlUseSchema.class, R(D)); + rules.put(SqlJoin.class, R(D, D, D, D, D, E)); REWRITE_RULES = ImmutableMap.copyOf(rules); }
