You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by ad...@apache.org on 2016/09/13 01:31:55 UTC

[08/50] [abbrv] drill git commit: Applying DRILL-3621 (Wrong results when Drill on HBase query contains rowkey "or" or "IN") to MapRDB plugin

Applying DRILL-3621 (Wrong results when Drill on HBase query contains rowkey "or" or "IN") to MapRDB plugin

Already in json_support branch, exclude while merging.


Project: http://git-wip-us.apache.org/repos/asf/drill/repo
Commit: http://git-wip-us.apache.org/repos/asf/drill/commit/75aa0511
Tree: http://git-wip-us.apache.org/repos/asf/drill/tree/75aa0511
Diff: http://git-wip-us.apache.org/repos/asf/drill/diff/75aa0511

Branch: refs/heads/master
Commit: 75aa0511f174288c612f105fc8aebdc6bb40d7e1
Parents: 2a45749
Author: Aditya <ad...@mapr.com>
Authored: Fri Nov 6 15:45:21 2015 -0800
Committer: Aditya Kishore <ad...@apache.org>
Committed: Fri Sep 9 10:08:29 2016 -0700

----------------------------------------------------------------------
 .../apache/drill/exec/store/maprdb/MapRDBFilterBuilder.java    | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/drill/blob/75aa0511/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/maprdb/MapRDBFilterBuilder.java
----------------------------------------------------------------------
diff --git a/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/maprdb/MapRDBFilterBuilder.java b/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/maprdb/MapRDBFilterBuilder.java
index a4a3938..a240719 100644
--- a/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/maprdb/MapRDBFilterBuilder.java
+++ b/contrib/format-maprdb/src/main/java/org/apache/drill/exec/store/maprdb/MapRDBFilterBuilder.java
@@ -187,8 +187,10 @@ public class MapRDBFilterBuilder extends AbstractExprVisitor<HBaseScanSpec, Void
     case "equal":
       compareOp = CompareOp.EQUAL;
       if (isRowKey) {
-        startRow = stopRow = fieldValue;
-        compareOp = null;
+        startRow = fieldValue;
+        /* stopRow should be just greater than 'value'*/
+        stopRow = Arrays.copyOf(fieldValue, fieldValue.length+1);
+        compareOp = CompareOp.EQUAL;
       }
       break;
     case "not_equal":