io.druid.query.topn

Class AggregateTopNMetricFirstAlgorithm

java.lang.Object

io.druid.query.topn.AggregateTopNMetricFirstAlgorithm

All Implemented Interfaces:

TopNAlgorithm<int[],TopNParams>

public class AggregateTopNMetricFirstAlgorithm
extends Object
implements TopNAlgorithm<int[],TopNParams>

Field Summary

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

EMPTY_ARRAY, INIT_POSITION_VALUE, SKIP_POSITION_VALUE

Constructor Summary

Constructors

Constructor and Description
AggregateTopNMetricFirstAlgorithm(Capabilities capabilities, TopNQuery query, NonBlockingPool<ByteBuffer> bufferPool)

Method Summary

Modifier and Type	Method and Description
void	cleanup(TopNParams params)
TopNParams	makeInitParams(ColumnSelectorPlus selectorPlus, Cursor cursor)
void	run(TopNParams params, TopNResultBuilder resultBuilder, int[] ints, TopNQueryMetrics queryMetrics)

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregateTopNMetricFirstAlgorithm

public AggregateTopNMetricFirstAlgorithm(Capabilities capabilities,
                                         TopNQuery query,
                                         NonBlockingPool<ByteBuffer> bufferPool)

Method Detail

makeInitParams

public TopNParams makeInitParams(ColumnSelectorPlus selectorPlus,
                                 Cursor cursor)

Specified by:

makeInitParams in interface TopNAlgorithm<int[],TopNParams>

run

public void run(TopNParams params,
                TopNResultBuilder resultBuilder,
                int[] ints,
                @Nullable
                TopNQueryMetrics queryMetrics)

Specified by:

run in interface TopNAlgorithm<int[],TopNParams>

cleanup

public void cleanup(TopNParams params)

Specified by:

cleanup in interface TopNAlgorithm<int[],TopNParams>