DRILL-1403: HBase predicate pushdown filters are not getting applied
Project: http://git-wip-us.apache.org/repos/asf/incubator-drill/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-drill/commit/9e164662 Tree: http://git-wip-us.apache.org/repos/asf/incubator-drill/tree/9e164662 Diff: http://git-wip-us.apache.org/repos/asf/incubator-drill/diff/9e164662 Branch: refs/heads/master Commit: 9e164662f5296f7048c880c40bc551030fb58cca Parents: 676f5df Author: Aditya Kishore <adi...@maprtech.com> Authored: Thu Sep 11 19:12:33 2014 -0700 Committer: Aditya Kishore <adi...@maprtech.com> Committed: Thu Sep 11 19:25:29 2014 -0700 ---------------------------------------------------------------------- .../org/apache/drill/exec/store/hbase/HBaseFilterBuilder.java | 6 ++++++ 1 file changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/9e164662/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseFilterBuilder.java ---------------------------------------------------------------------- diff --git a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseFilterBuilder.java b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseFilterBuilder.java index ad26972..ee011a5 100644 --- a/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseFilterBuilder.java +++ b/contrib/storage-hbase/src/main/java/org/apache/drill/exec/store/hbase/HBaseFilterBuilder.java @@ -19,6 +19,7 @@ package org.apache.drill.exec.store.hbase; import java.util.Arrays; +import org.apache.drill.common.expression.BooleanOperator; import org.apache.drill.common.expression.FunctionCall; import org.apache.drill.common.expression.LogicalExpression; import org.apache.drill.common.expression.SchemaPath; @@ -73,6 +74,11 @@ public class HBaseFilterBuilder extends AbstractExprVisitor<HBaseScanSpec, Void, } @Override + public HBaseScanSpec visitBooleanOperator(BooleanOperator op, Void value) throws RuntimeException { + return visitFunctionCall(op, value); + } + + @Override public HBaseScanSpec visitFunctionCall(FunctionCall call, Void value) throws RuntimeException { HBaseScanSpec nodeScanSpec = null; String functionName = call.getName();
