Repository: phoenix
Updated Branches:
  refs/heads/4.x-HBase-0.98 92f2551db -> f0b76dd80


PHOENIX-2756 FilteredKeyValueScanner should not implement KeyValueScanner 
(addendum)


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

Branch: refs/heads/4.x-HBase-0.98
Commit: f0b76dd80437213f6db504ba260d6b9d2722e26d
Parents: 92f2551
Author: Thomas D'Silva <[email protected]>
Authored: Mon Mar 14 14:47:30 2016 -0700
Committer: Thomas D'Silva <[email protected]>
Committed: Mon Mar 14 14:56:09 2016 -0700

----------------------------------------------------------------------
 .../org/apache/phoenix/hbase/index/scanner/ScannerBuilder.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/phoenix/blob/f0b76dd8/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/scanner/ScannerBuilder.java
----------------------------------------------------------------------
diff --git 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/scanner/ScannerBuilder.java
 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/scanner/ScannerBuilder.java
index 4333de6..23e64b3 100644
--- 
a/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/scanner/ScannerBuilder.java
+++ 
b/phoenix-core/src/main/java/org/apache/phoenix/hbase/index/scanner/ScannerBuilder.java
@@ -144,13 +144,13 @@ public class ScannerBuilder {
         if (peek != null) {
           int compare = KeyValue.COMPARATOR.compare(peek, next);
           if (compare < 0) {
-            return kvScanner.reseek(KeyValueUtil.ensureKeyValue(next));
+            return kvScanner.reseek(next);
           } else if (compare == 0) {
             // we are already at the given key!
             return true;
           }
         }
-        return kvScanner.seek(KeyValueUtil.ensureKeyValue(next));
+        return kvScanner.seek(next);
       }
 
       @Override

Reply via email to