Repository: phoenix Updated Branches: refs/heads/4.5-HBase-1.0 4d8b5d28b -> c7d017144
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/c7d01714 Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/c7d01714 Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/c7d01714 Branch: refs/heads/4.5-HBase-1.0 Commit: c7d0171445b5bba41eec82155534435419fc18b5 Parents: 4d8b5d2 Author: Cody Marcel <cmar...@cmarcel-wsl1.internal.salesforce.com> Authored: Fri Sep 11 10:04:06 2015 -0700 Committer: Cody Marcel <cmar...@cmarcel-wsl1.internal.salesforce.com> Committed: Fri Sep 11 10:39:44 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/c7d01714/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; }
