io.druid.query.topn

Class DimExtractionTopNAlgorithm

java.lang.Object

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

io.druid.query.topn.DimExtractionTopNAlgorithm

All Implemented Interfaces:

TopNAlgorithm<Aggregator[][],TopNParams>

public class DimExtractionTopNAlgorithm
extends BaseTopNAlgorithm<Aggregator[][],Map<Comparable,Aggregator[]>,TopNParams>

This has to be its own strategy because the pooled topn algorithm assumes each index is unique, and cannot handle multiple index numerals referencing the same dimension value.

Nested Class Summary

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

BaseTopNAlgorithm.AggregatorArrayProvider, BaseTopNAlgorithm.BaseArrayProvider<T>

Field Summary

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

capabilities

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

EMPTY_ARRAY, INIT_POSITION_VALUE, SKIP_POSITION_VALUE

Constructor Summary

Constructors

Constructor and Description
DimExtractionTopNAlgorithm(Capabilities capabilities, TopNQuery query)

Method Summary

Modifier and Type	Method and Description
void	cleanup(TopNParams params)
protected void	closeAggregators(Map<Comparable,Aggregator[]> valueMap)
protected Map<Comparable,Aggregator[]>	makeDimValAggregateStore(TopNParams params)
protected Aggregator[][]	makeDimValSelector(TopNParams params, int numProcessed, int numToProcess)
TopNParams	makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus, Cursor cursor)
void	scanAndAggregate(TopNParams params, Aggregator[][] rowSelector, Map<Comparable,Aggregator[]> aggregatesStore, int numProcessed)
protected Aggregator[][]	updateDimValSelector(Aggregator[][] aggregators, int numProcessed, int numToProcess)
protected void	updateResults(TopNParams params, Aggregator[][] rowSelector, Map<Comparable,Aggregator[]> aggregatesStore, TopNResultBuilder resultBuilder)

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

computeNewLength, makeAggregators, makeBufferAggregators, makeResultBuilder, run

Methods inherited from class java.lang.Object

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

Constructor Detail

DimExtractionTopNAlgorithm

public DimExtractionTopNAlgorithm(Capabilities capabilities,
                                  TopNQuery query)

Method Detail

makeInitParams

public TopNParams makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
                                 Cursor cursor)

makeDimValSelector

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

Specified by:

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

updateDimValSelector

protected Aggregator[][] updateDimValSelector(Aggregator[][] aggregators,
                                              int numProcessed,
                                              int numToProcess)

Specified by:

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

makeDimValAggregateStore

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

Specified by:

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

scanAndAggregate

public void scanAndAggregate(TopNParams params,
                             Aggregator[][] rowSelector,
                             Map<Comparable,Aggregator[]> aggregatesStore,
                             int numProcessed)

Specified by:

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

updateResults

protected void updateResults(TopNParams params,
                             Aggregator[][] rowSelector,
                             Map<Comparable,Aggregator[]> aggregatesStore,
                             TopNResultBuilder resultBuilder)

Specified by:

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

closeAggregators

protected void closeAggregators(Map<Comparable,Aggregator[]> valueMap)

Specified by:

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

cleanup

public void cleanup(TopNParams params)