| Package | Description | 
|---|---|
| io.druid.query | |
| io.druid.query.topn | |
| io.druid.query.topn.types | |
| io.druid.segment | |
| io.druid.segment.historical | |
| io.druid.segment.incremental | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> Sequence<Result<T>> | 
QueryRunnerHelper.makeCursorBasedQuery(StorageAdapter adapter,
                    List<org.joda.time.Interval> queryIntervals,
                    Filter filter,
                    VirtualColumns virtualColumns,
                    boolean descending,
                    Granularity granularity,
                    com.google.common.base.Function<Cursor,Result<T>> mapFn)  | 
| Modifier and Type | Method and Description | 
|---|---|
Cursor | 
TopNParams.getCursor()  | 
| Modifier and Type | Method and Description | 
|---|---|
Result<TopNResultValue> | 
TopNMapFn.apply(Cursor cursor,
     TopNQueryMetrics queryMetrics)  | 
void | 
TopNQueryMetrics.cursor(Cursor cursor)
This method is called exactly once with each cursor, processed for the query. 
 | 
void | 
DefaultTopNQueryMetrics.cursor(Cursor cursor)  | 
static Aggregator[] | 
BaseTopNAlgorithm.makeAggregators(Cursor cursor,
               List<AggregatorFactory> aggregatorSpecs)  | 
protected static BufferAggregator[] | 
BaseTopNAlgorithm.makeBufferAggregators(Cursor cursor,
                     List<AggregatorFactory> aggregatorSpecs)  | 
TopNParams | 
TopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
              Cursor cursor)  | 
TopNParams | 
DimExtractionTopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
              Cursor cursor)  | 
TopNParams | 
TimeExtractionTopNAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
              Cursor cursor)  | 
PooledTopNAlgorithm.PooledTopNParams | 
PooledTopNAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
              Cursor cursor)  | 
TopNParams | 
AggregateTopNMetricFirstAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
              Cursor cursor)  | 
long | 
Generic2AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator1,
                int aggregator1Size,
                BufferAggregator aggregator2,
                int aggregator2Size,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)
Any changes to this method should be coordinated with  
TopNUtils, PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations() and downstream methods. | 
long | 
Generic2AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator1,
                int aggregator1Size,
                BufferAggregator aggregator2,
                int aggregator2Size,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)  | 
long | 
Generic1AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator,
                int aggregatorSize,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)
Any changes to this method should be coordinated with  
TopNUtils, PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations() and downstream methods. | 
long | 
Generic1AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator,
                int aggregatorSize,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)  | 
PooledTopNAlgorithm.PooledTopNParams.Builder | 
PooledTopNAlgorithm.PooledTopNParams.Builder.withCursor(Cursor cursor)  | 
| Constructor and Description | 
|---|
PooledTopNParams(ColumnSelectorPlus selectorPlus,
                Cursor cursor,
                ResourceHolder<ByteBuffer> resultsBufHolder,
                ByteBuffer resultsBuf,
                int[] aggregatorSizes,
                int numBytesPerRecord,
                int numValuesPerPass,
                TopNMetricSpecBuilder<int[]> arrayProvider)  | 
TopNParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
          Cursor cursor,
          int numValuesPerPass)  | 
| Modifier and Type | Method and Description | 
|---|---|
long | 
StringTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
                             DimensionSelector selector,
                             Cursor cursor,
                             Aggregator[][] rowSelector,
                             Map<String,Aggregator[]> aggregatesStore)  | 
long | 
TopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
                             ValueSelectorType selector,
                             Cursor cursor,
                             Aggregator[][] rowSelector,
                             DimExtractionAggregateStoreType aggregatesStore)
Used by DimExtractionTopNAlgorithm. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence<Cursor> | 
QueryableIndexStorageAdapter.makeCursors(Filter filter,
           org.joda.time.Interval interval,
           VirtualColumns virtualColumns,
           Granularity gran,
           boolean descending,
           QueryMetrics<?> queryMetrics)  | 
Sequence<Cursor> | 
CursorFactory.makeCursors(Filter filter,
           org.joda.time.Interval interval,
           VirtualColumns virtualColumns,
           Granularity gran,
           boolean descending,
           QueryMetrics<?> queryMetrics)  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
HistoricalCursor  | 
| Modifier and Type | Method and Description | 
|---|---|
Sequence<Cursor> | 
IncrementalIndexStorageAdapter.makeCursors(Filter filter,
           org.joda.time.Interval interval,
           VirtualColumns virtualColumns,
           Granularity gran,
           boolean descending,
           QueryMetrics<?> queryMetrics)  | 
Copyright © 2011–2018. All rights reserved.