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/c19c3215 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c19c3215 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c19c3215 Branch: refs/heads/calcite Commit: c19c32157a2ef4b65e4ef13ff1ba8c4ef9ef4597 Parents: 4377e33 Author: Thomas D'Silva <tdsi...@salesforce.com> Authored: Mon Mar 14 14:47:30 2016 -0700 Committer: Thomas D'Silva <tdsi...@salesforce.com> Committed: Mon Mar 14 14:57:40 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/c19c3215/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 b4282ab..330cb0e 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