io.druid.query.topn

Class TimeExtractionTopNAlgorithm

java.lang.Object

io.druid.query.topn.BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

io.druid.query.topn.TimeExtractionTopNAlgorithm

All Implemented Interfaces:

TopNAlgorithm<int[],TopNParams>

public class TimeExtractionTopNAlgorithm
extends BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

Nested Class Summary

Nested classes/interfaces inherited from class io.druid.query.topn.BaseTopNAlgorithm

BaseTopNAlgorithm.AggregatorArrayProvider, BaseTopNAlgorithm.BaseArrayProvider<T>

Field Summary

Fields

Modifier and Type	Field and Description
static int[]	EMPTY_INTS

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

EMPTY_ARRAY, INIT_POSITION_VALUE, SKIP_POSITION_VALUE

Constructor Summary

Constructors

Constructor and Description
TimeExtractionTopNAlgorithm(Capabilities capabilities, TopNQuery query)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(TopNParams params)
protected void	closeAggregators(Map<String,Aggregator[]> stringMap)
protected Map<String,Aggregator[]>	makeDimValAggregateStore(TopNParams params)
protected int[]	makeDimValSelector(TopNParams params, int numProcessed, int numToProcess)
TopNParams	makeInitParams(DimensionSelector dimSelector, Cursor cursor)
protected void	scanAndAggregate(TopNParams params, int[] dimValSelector, Map<String,Aggregator[]> aggregatesStore, int numProcessed)
protected int[]	updateDimValSelector(int[] dimValSelector, int numProcessed, int numToProcess)
protected void	updateResults(TopNParams params, int[] dimValSelector, Map<String,Aggregator[]> aggregatesStore, TopNResultBuilder resultBuilder)

Methods inherited from class io.druid.query.topn.BaseTopNAlgorithm

makeAggregators, makeBufferAggregators, makeResultBuilder, run

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY_INTS

public static final int[] EMPTY_INTS

Constructor Detail

TimeExtractionTopNAlgorithm

public TimeExtractionTopNAlgorithm(Capabilities capabilities,
                           TopNQuery query)

Method Detail

makeInitParams

public TopNParams makeInitParams(DimensionSelector dimSelector,
                        Cursor cursor)

makeDimValSelector

protected int[] makeDimValSelector(TopNParams params,
                       int numProcessed,
                       int numToProcess)

Specified by:

makeDimValSelector in class BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

updateDimValSelector

protected int[] updateDimValSelector(int[] dimValSelector,
                         int numProcessed,
                         int numToProcess)

Specified by:

updateDimValSelector in class BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

makeDimValAggregateStore

protected Map<String,Aggregator[]> makeDimValAggregateStore(TopNParams params)

Specified by:

makeDimValAggregateStore in class BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

scanAndAggregate

protected void scanAndAggregate(TopNParams params,
                    int[] dimValSelector,
                    Map<String,Aggregator[]> aggregatesStore,
                    int numProcessed)

Specified by:

scanAndAggregate in class BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

updateResults

protected void updateResults(TopNParams params,
                 int[] dimValSelector,
                 Map<String,Aggregator[]> aggregatesStore,
                 TopNResultBuilder resultBuilder)

Specified by:

updateResults in class BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

closeAggregators

protected void closeAggregators(Map<String,Aggregator[]> stringMap)

Specified by:

closeAggregators in class BaseTopNAlgorithm<int[],Map<String,Aggregator[]>,TopNParams>

cleanup

public void cleanup(TopNParams params)