Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

rename file

This commit is contained in:
Fangjin Yang 2012-11-08 13:42:58 -08:00
parent 3ddfdfc702
commit 09e81be14c
2 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/src/main/java/com/metamx/druid/query/QueryRunnerFactories.java → server/src/main/java/com/metamx/druid/query/QueryRunnerHelper.java
View File

@ -37,9 +37,9 @@ import java.util.List;
/**
*/
public class QueryRunnerFactories
public class QueryRunnerHelper
{
private static final Logger log = new Logger(QueryRunnerFactories.class);
private static final Logger log = new Logger(QueryRunnerHelper.class);
public static Aggregator[] makeAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)
{

11
server/src/main/java/com/metamx/druid/query/timeseries/TimeseriesQueryRunnerFactory.java
View File

@ -20,12 +20,10 @@
package com.metamx.druid.query.timeseries;
import com.google.common.base.Function;
import com.google.common.collect.Lists;
import com.metamx.common.ISE;
import com.metamx.common.guava.BaseSequence;
import com.metamx.common.guava.Sequence;
import com.metamx.druid.Query;
import com.metamx.druid.SearchResultBuilder;
import com.metamx.druid.StorageAdapter;
import com.metamx.druid.TimeseriesResultBuilder;
import com.metamx.druid.aggregation.Aggregator;
@ -35,14 +33,11 @@ import com.metamx.druid.index.brita.Filters;
import com.metamx.druid.index.v1.processing.Cursor;
import com.metamx.druid.query.ChainedExecutionQueryRunner;
import com.metamx.druid.query.QueryRunner;
import com.metamx.druid.query.QueryRunnerFactories;
import com.metamx.druid.query.QueryRunnerHelper;
import com.metamx.druid.query.QueryRunnerFactory;
import com.metamx.druid.query.QueryToolChest;
import com.metamx.druid.query.group.GroupByQuery;
import com.metamx.druid.query.timeboundary.TimeBoundaryQuery;
import com.metamx.druid.query.timeboundary.TimeBoundaryQueryQueryToolChest;
import com.metamx.druid.result.Result;
import com.metamx.druid.result.TimeBoundaryResultValue;
import com.metamx.druid.result.TimeseriesResultValue;
import java.util.Iterator;
@ -76,7 +71,7 @@ public class TimeseriesQueryRunnerFactory
@Override
public Iterator<Result<TimeseriesResultValue>> make()
{
return QueryRunnerFactories.makeCursorBasedQuery(
return QueryRunnerHelper.makeCursorBasedQuery(
adapter,
query.getQuerySegmentSpec().getIntervals(),
Filters.convertDimensionFilters(query.getDimensionsFilter()),
@ -89,7 +84,7 @@ public class TimeseriesQueryRunnerFactory
@Override
public Result<TimeseriesResultValue> apply(Cursor cursor)
{
Aggregator[] aggregators = QueryRunnerFactories.makeAggregators(cursor, aggregatorSpecs);
Aggregator[] aggregators = QueryRunnerHelper.makeAggregators(cursor, aggregatorSpecs);
while (!cursor.isDone()) {
for (Aggregator aggregator : aggregators) {