io.druid.query.topn

Class Historical1SimpleDoubleAggPooledTopNScannerPrototype

java.lang.Object

io.druid.query.topn.Historical1SimpleDoubleAggPooledTopNScannerPrototype

All Implemented Interfaces:

Historical1AggPooledTopNScanner<HistoricalDimensionSelector,HistoricalFloatColumnSelector,SimpleDoubleBufferAggregator>

public class Historical1SimpleDoubleAggPooledTopNScannerPrototype
extends Object
implements Historical1AggPooledTopNScanner<HistoricalDimensionSelector,HistoricalFloatColumnSelector,SimpleDoubleBufferAggregator>

Constructor Summary

Constructors

Constructor and Description
Historical1SimpleDoubleAggPooledTopNScannerPrototype()

Method Summary

Modifier and Type	Method and Description
long	scanAndAggregate(HistoricalDimensionSelector dimensionSelector, HistoricalFloatColumnSelector metricSelector, SimpleDoubleBufferAggregator aggregator, int aggregatorSize, HistoricalCursor cursor, int[] positions, ByteBuffer resultsBuffer)

Methods inherited from class java.lang.Object

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

Constructor Detail

Historical1SimpleDoubleAggPooledTopNScannerPrototype

public Historical1SimpleDoubleAggPooledTopNScannerPrototype()

Method Detail

scanAndAggregate

public long scanAndAggregate(HistoricalDimensionSelector dimensionSelector,
                             HistoricalFloatColumnSelector metricSelector,
                             SimpleDoubleBufferAggregator aggregator,
                             int aggregatorSize,
                             HistoricalCursor cursor,
                             int[] positions,
                             ByteBuffer resultsBuffer)

Specified by:

scanAndAggregate in interface Historical1AggPooledTopNScanner<HistoricalDimensionSelector,HistoricalFloatColumnSelector,SimpleDoubleBufferAggregator>

aggregatorSize - number of bytes required by aggregator for a single aggregation

positions - a cache for positions in resultsBuffer, where specific (indexed) dimension values are aggregated

Returns:

number of scanned rows, i. e. number of steps made with the given cursor