io.druid.query.topn

Class BaseTopNAlgorithm<DimValSelector,DimValAggregateStore,Parameters extends TopNParams>

java.lang.Object

io.druid.query.topn.BaseTopNAlgorithm<DimValSelector,DimValAggregateStore,Parameters>

All Implemented Interfaces:

TopNAlgorithm<DimValSelector,Parameters>

Direct Known Subclasses:

DimExtractionTopNAlgorithm, PooledTopNAlgorithm

public abstract class BaseTopNAlgorithm<DimValSelector,DimValAggregateStore,Parameters extends TopNParams>
extends Object
implements TopNAlgorithm<DimValSelector,Parameters>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	BaseTopNAlgorithm.AggregatorArrayProvider
protected static class	BaseTopNAlgorithm.BaseArrayProvider<T>

Field Summary

Fields inherited from interface io.druid.query.topn.TopNAlgorithm

EMPTY_ARRAY, INIT_POSITION_VALUE, SKIP_POSITION_VALUE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseTopNAlgorithm(Capabilities capabilities)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract void	closeAggregators(DimValAggregateStore dimValAggregateStore)
protected static Aggregator[]	makeAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)
protected static BufferAggregator[]	makeBufferAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)
protected abstract DimValAggregateStore	makeDimValAggregateStore(Parameters params)
protected abstract DimValSelector	makeDimValSelector(Parameters params, int numProcessed, int numToProcess)
static TopNResultBuilder	makeResultBuilder(TopNParams params, TopNQuery query)
void	run(Parameters params, TopNResultBuilder resultBuilder, DimValSelector dimValSelector)
protected abstract void	scanAndAggregate(Parameters params, DimValSelector dimValSelector, DimValAggregateStore dimValAggregateStore, int numProcessed)
protected abstract DimValSelector	updateDimValSelector(DimValSelector dimValSelector, int numProcessed, int numToProcess)
protected abstract void	updateResults(Parameters params, DimValSelector dimValSelector, DimValAggregateStore dimValAggregateStore, TopNResultBuilder resultBuilder)

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.topn.TopNAlgorithm

cleanup, makeInitParams

Constructor Detail

BaseTopNAlgorithm

protected BaseTopNAlgorithm(Capabilities capabilities)

Method Detail

makeAggregators

protected static Aggregator[] makeAggregators(Cursor cursor,
                           List<AggregatorFactory> aggregatorSpecs)

makeBufferAggregators

protected static BufferAggregator[] makeBufferAggregators(Cursor cursor,
                                       List<AggregatorFactory> aggregatorSpecs)

run

public void run(Parameters params,
       TopNResultBuilder resultBuilder,
       DimValSelector dimValSelector)

Specified by:

run in interface TopNAlgorithm<DimValSelector,Parameters extends TopNParams>

makeDimValSelector

protected abstract DimValSelector makeDimValSelector(Parameters params,
                                int numProcessed,
                                int numToProcess)

updateDimValSelector

protected abstract DimValSelector updateDimValSelector(DimValSelector dimValSelector,
                                  int numProcessed,
                                  int numToProcess)

makeDimValAggregateStore

protected abstract DimValAggregateStore makeDimValAggregateStore(Parameters params)

scanAndAggregate

protected abstract void scanAndAggregate(Parameters params,
                    DimValSelector dimValSelector,
                    DimValAggregateStore dimValAggregateStore,
                    int numProcessed)

updateResults

protected abstract void updateResults(Parameters params,
                 DimValSelector dimValSelector,
                 DimValAggregateStore dimValAggregateStore,
                 TopNResultBuilder resultBuilder)

closeAggregators

protected abstract void closeAggregators(DimValAggregateStore dimValAggregateStore)

makeResultBuilder

public static TopNResultBuilder makeResultBuilder(TopNParams params,
                                  TopNQuery query)