io.druid.query.groupby.epinephelinae

Class GroupByMergingQueryRunnerV2

java.lang.Object

io.druid.query.groupby.epinephelinae.GroupByMergingQueryRunnerV2

All Implemented Interfaces:

QueryRunner<Row>

public class GroupByMergingQueryRunnerV2
extends Object
implements QueryRunner<Row>

Constructor Summary

Constructors

Constructor and Description
GroupByMergingQueryRunnerV2(GroupByQueryConfig config, ExecutorService exec, QueryWatcher queryWatcher, Iterable<QueryRunner<Row>> queryables, int concurrencyHint, BlockingPool<ByteBuffer> mergeBufferPool, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir)

Method Summary

Modifier and Type	Method and Description
Sequence<Row>	run(QueryPlus<Row> queryPlus, Map<String,Object> responseContext) Runs the given query and returns results in a time-ordered sequence.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.druid.query.QueryRunner

run

Constructor Detail

GroupByMergingQueryRunnerV2

public GroupByMergingQueryRunnerV2(GroupByQueryConfig config,
                                   ExecutorService exec,
                                   QueryWatcher queryWatcher,
                                   Iterable<QueryRunner<Row>> queryables,
                                   int concurrencyHint,
                                   BlockingPool<ByteBuffer> mergeBufferPool,
                                   com.fasterxml.jackson.databind.ObjectMapper spillMapper,
                                   String processingTmpDir)

Method Detail

run

public Sequence<Row> run(QueryPlus<Row> queryPlus,
                         Map<String,Object> responseContext)

Description copied from interface: QueryRunner

Runs the given query and returns results in a time-ordered sequence.

Specified by:

run in interface QueryRunner<Row>