You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ma...@apache.org on 2016/03/29 21:50:52 UTC
[19/30] phoenix git commit: PHOENIX-2756 FilteredKeyValueScanner
should not implement KeyValueScanner (addendum)
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 <td...@salesforce.com>
Authored: Mon Mar 14 14:47:30 2016 -0700
Committer: Thomas D'Silva <td...@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