[CALCITE-1723] Match DruidProjectFilterTransposeRule against DruidQuery (Nishant Bangarwa)
Close apache/calcite#407 Project: http://git-wip-us.apache.org/repos/asf/calcite/repo Commit: http://git-wip-us.apache.org/repos/asf/calcite/commit/aa0bf32c Tree: http://git-wip-us.apache.org/repos/asf/calcite/tree/aa0bf32c Diff: http://git-wip-us.apache.org/repos/asf/calcite/diff/aa0bf32c Branch: refs/heads/master Commit: aa0bf32c626db0f3b72f15df5d69f1ae6c0e612d Parents: 0209b16 Author: Nishant Bangarwa <[email protected]> Authored: Mon Mar 27 19:30:19 2017 +0100 Committer: Jesus Camacho Rodriguez <[email protected]> Committed: Mon Mar 27 19:55:27 2017 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/calcite/adapter/druid/DruidRules.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/calcite/blob/aa0bf32c/druid/src/main/java/org/apache/calcite/adapter/druid/DruidRules.java ---------------------------------------------------------------------- diff --git a/druid/src/main/java/org/apache/calcite/adapter/druid/DruidRules.java b/druid/src/main/java/org/apache/calcite/adapter/druid/DruidRules.java index a417698..0bc6b34 100644 --- a/druid/src/main/java/org/apache/calcite/adapter/druid/DruidRules.java +++ b/druid/src/main/java/org/apache/calcite/adapter/druid/DruidRules.java @@ -644,7 +644,8 @@ public class DruidRules { private DruidProjectFilterTransposeRule() { super( operand(Project.class, - operand(Filter.class, any())), + operand(Filter.class, + operand(DruidQuery.class, none()))), PushProjector.ExprCondition.FALSE, RelFactories.LOGICAL_BUILDER); }
