You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by co...@apache.org on 2015/09/11 19:24:44 UTC
phoenix git commit: PHOENIX-2252 - QueryExecutor creates a Differ for
performance test
Repository: phoenix
Updated Branches:
refs/heads/master f76062c90 -> 29535f342
PHOENIX-2252 - QueryExecutor creates a Differ for performance test
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/29535f34
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/29535f34
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/29535f34
Branch: refs/heads/master
Commit: 29535f342ff53dbdef03dc5822a5e7583be32cbb
Parents: f76062c
Author: Cody Marcel <cm...@cmarcel-wsl1.internal.salesforce.com>
Authored: Fri Sep 11 10:04:06 2015 -0700
Committer: Cody Marcel <cm...@cmarcel-wsl1.internal.salesforce.com>
Committed: Fri Sep 11 10:04:06 2015 -0700
----------------------------------------------------------------------
.../org/apache/phoenix/pherf/workload/QueryExecutor.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/29535f34/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
----------------------------------------------------------------------
diff --git a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
index 5a7c49f..50d7190 100644
--- a/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
+++ b/phoenix-pherf/src/main/java/org/apache/phoenix/pherf/workload/QueryExecutor.java
@@ -260,13 +260,13 @@ public class QueryExecutor implements Workload {
Runnable thread;
if (workloadExecutor.isPerformance()) {
thread =
- new MultithreadedDiffer(threadTime.getThreadName(), queryResult, threadTime,
- querySet.getNumberOfExecutions(), querySet.getExecutionDurationInMs());
- } else {
- thread =
new MultiThreadedRunner(threadTime.getThreadName(), queryResult,
dataModelResult, threadTime, querySet.getNumberOfExecutions(),
querySet.getExecutionDurationInMs());
+ } else {
+ thread =
+ new MultithreadedDiffer(threadTime.getThreadName(), queryResult, threadTime,
+ querySet.getNumberOfExecutions(), querySet.getExecutionDurationInMs());
}
return thread;
}