public class GroupByParallelQueryRunner<T> extends Object implements QueryRunner<T>
Constructor and Description |
---|
GroupByParallelQueryRunner(ExecutorService exec,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool,
Iterable<QueryRunner<T>> queryables) |
Modifier and Type | Method and Description |
---|---|
com.metamx.common.guava.Sequence<T> |
run(Query<T> queryParam,
Map<String,Object> responseContext)
Runs the given query and returns results in a time-ordered sequence
|
public GroupByParallelQueryRunner(ExecutorService exec, com.google.common.base.Supplier<GroupByQueryConfig> configSupplier, QueryWatcher queryWatcher, StupidPool<ByteBuffer> bufferPool, Iterable<QueryRunner<T>> queryables)
public com.metamx.common.guava.Sequence<T> run(Query<T> queryParam, Map<String,Object> responseContext)
QueryRunner
run
in interface QueryRunner<T>
Copyright © 2011–2016. All rights reserved.