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, NonBlockingPool<ByteBuffer> processingBufferPool, BlockingPool<ByteBuffer> mergeBufferPool, int mergeBufferSize, 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

Constructor Detail

GroupByMergingQueryRunnerV2

public GroupByMergingQueryRunnerV2(GroupByQueryConfig config,
                                   ExecutorService exec,
                                   QueryWatcher queryWatcher,
                                   Iterable<QueryRunner<Row>> queryables,
                                   int concurrencyHint,
                                   NonBlockingPool<ByteBuffer> processingBufferPool,
                                   BlockingPool<ByteBuffer> mergeBufferPool,
                                   int mergeBufferSize,
                                   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>