You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by sa...@apache.org on 2015/04/22 07:19:42 UTC
phoenix git commit: PHOENIX-1899 Performance regression for
non-aggregate, unordered queries returning 0 or few records
Repository: phoenix
Updated Branches:
refs/heads/4.x-HBase-0.98 97f28b1cc -> 080767878
PHOENIX-1899 Performance regression for non-aggregate, unordered queries returning 0 or few records
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/08076787
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/08076787
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/08076787
Branch: refs/heads/4.x-HBase-0.98
Commit: 080767878a4b1d9356edeaf59d13874870eb05e1
Parents: 97f28b1
Author: Samarth <sa...@salesforce.com>
Authored: Tue Apr 21 22:19:29 2015 -0700
Committer: Samarth <sa...@salesforce.com>
Committed: Tue Apr 21 22:19:29 2015 -0700
----------------------------------------------------------------------
.../main/java/org/apache/phoenix/iterate/ParallelIterators.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/08076787/phoenix-core/src/main/java/org/apache/phoenix/iterate/ParallelIterators.java
----------------------------------------------------------------------
diff --git a/phoenix-core/src/main/java/org/apache/phoenix/iterate/ParallelIterators.java b/phoenix-core/src/main/java/org/apache/phoenix/iterate/ParallelIterators.java
index 97270ef..be10c20 100644
--- a/phoenix-core/src/main/java/org/apache/phoenix/iterate/ParallelIterators.java
+++ b/phoenix-core/src/main/java/org/apache/phoenix/iterate/ParallelIterators.java
@@ -92,6 +92,10 @@ public class ParallelIterators extends BaseResultIterators {
logger.debug(LogUtil.addCustomAnnotations("Id: " + scanId + ", Time: " + (System.currentTimeMillis() - startTime) + "ms, Scan: " + scan, ScanUtil.getCustomAnnotations(scan)));
}
PeekingResultIterator iterator = iteratorFactory.newIterator(context, scanner, scan);
+
+ // Fill the scanner's cache. This helps reduce latency since we are parallelizing the I/O needed.
+ iterator.peek();
+
allIterators.add(iterator);
return iterator;
}