Package org.apache.druid.query.topn

Class HeapBasedTopNAlgorithm

java.lang.Object

org.apache.druid.query.topn.BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

org.apache.druid.query.topn.HeapBasedTopNAlgorithm

All Implemented Interfaces:

TopNAlgorithm<Aggregator[][],TopNParams>

public class HeapBasedTopNAlgorithm
extends BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

Heap based topn algorithm that handles aggregates on dimension extractions and numeric typed dimension columns. 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 org.apache.druid.query.topn.BaseTopNAlgorithm

BaseTopNAlgorithm.AggregatorArrayProvider, BaseTopNAlgorithm.BaseArrayProvider<T>

Field Summary

Fields inherited from class org.apache.druid.query.topn.BaseTopNAlgorithm

cursorInspector

Fields inherited from interface org.apache.druid.query.topn.TopNAlgorithm

EMPTY_ARRAY, INIT_POSITION_VALUE, SKIP_POSITION_VALUE

Constructor Summary

Constructors

Constructor	Description
HeapBasedTopNAlgorithm(TopNQuery query, TopNCursorInspector cursorInspector)

Method Summary

Modifier and Type	Method	Description
void	cleanup(TopNParams params)
protected TopNColumnAggregatesProcessor	makeDimValAggregateStore(TopNParams params)
protected Aggregator[][]	makeDimValSelector(TopNParams params, int numProcessed, int numToProcess)
TopNParams	makeInitParams(ColumnSelectorPlus<TopNColumnAggregatesProcessor> selectorPlus, Cursor cursor, CursorGranularizer granularizer)
protected void	resetAggregators(TopNColumnAggregatesProcessor processor)
protected long	scanAndAggregate(TopNParams params, Aggregator[][] rowSelector, TopNColumnAggregatesProcessor processor)	Returns the number of processed rows (i.
protected Aggregator[][]	updateDimValSelector(Aggregator[][] aggregators, int numProcessed, int numToProcess)
protected void	updateResults(TopNParams params, Aggregator[][] aggregators, TopNColumnAggregatesProcessor processor, TopNResultBuilder resultBuilder)

Methods inherited from class org.apache.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 Details

HeapBasedTopNAlgorithm

public HeapBasedTopNAlgorithm(TopNQuery query,
 TopNCursorInspector cursorInspector)

Method Details

makeInitParams

public TopNParams makeInitParams(ColumnSelectorPlus<TopNColumnAggregatesProcessor> selectorPlus,
 Cursor cursor,
 CursorGranularizer granularizer)

makeDimValSelector

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

Specified by:

makeDimValSelector in class BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

updateDimValSelector

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

Specified by:

updateDimValSelector in class BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

makeDimValAggregateStore

protected TopNColumnAggregatesProcessor makeDimValAggregateStore(TopNParams params)

Specified by:

makeDimValAggregateStore in class BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

scanAndAggregate

protected long scanAndAggregate(TopNParams params,
 Aggregator[][] rowSelector,
 TopNColumnAggregatesProcessor processor)

Description copied from class: BaseTopNAlgorithm

Returns the number of processed rows (i. e. after postFilters are applied inside the cursor being processed).

Specified by:

scanAndAggregate in class BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

updateResults

protected void updateResults(TopNParams params,
 Aggregator[][] aggregators,
 TopNColumnAggregatesProcessor processor,
 TopNResultBuilder resultBuilder)

Specified by:

updateResults in class BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

resetAggregators

protected void resetAggregators(TopNColumnAggregatesProcessor processor)

Specified by:

resetAggregators in class BaseTopNAlgorithm<Aggregator[][],TopNColumnAggregatesProcessor,TopNParams>

cleanup

public void cleanup(TopNParams params)