io.druid.query

Class ResultMergeQueryRunner<T>

java.lang.Object

io.druid.query.BySegmentSkippingQueryRunner<T>

io.druid.query.ResultMergeQueryRunner<T>

All Implemented Interfaces:

QueryRunner<T>

public abstract class ResultMergeQueryRunner<T>
extends BySegmentSkippingQueryRunner<T>

Constructor Summary

Constructors

Constructor and Description
ResultMergeQueryRunner(QueryRunner<T> baseRunner)

Method Summary

Modifier and Type	Method and Description
protected abstract BinaryFn<T,T,T>	createMergeFn(Query<T> query)
Sequence<T>	doRun(QueryRunner<T> baseRunner, QueryPlus<T> queryPlus, Map<String,Object> context)
protected abstract com.google.common.collect.Ordering<T>	makeOrdering(Query<T> query)

Methods inherited from class io.druid.query.BySegmentSkippingQueryRunner

run

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultMergeQueryRunner

public ResultMergeQueryRunner(QueryRunner<T> baseRunner)

Method Detail

doRun

public Sequence<T> doRun(QueryRunner<T> baseRunner,
                         QueryPlus<T> queryPlus,
                         Map<String,Object> context)

Specified by:

doRun in class BySegmentSkippingQueryRunner<T>

makeOrdering

protected abstract com.google.common.collect.Ordering<T> makeOrdering(Query<T> query)

createMergeFn

protected abstract BinaryFn<T,T,T> createMergeFn(Query<T> query)