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(Query queryParam, Map 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,
                                   BlockingPool<ByteBuffer> mergeBufferPool,
                                   com.fasterxml.jackson.databind.ObjectMapper spillMapper,
                                   String processingTmpDir)

Method Detail

run

public Sequence<Row> run(Query queryParam,
                         Map 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>

Returns: