Package | Description |
---|---|
io.druid.query.topn | |
io.druid.query.topn.types |
Modifier and Type | Class and Description |
---|---|
class |
BaseTopNAlgorithm<DimValSelector,DimValAggregateStore,Parameters extends TopNParams> |
interface |
TopNAlgorithm<DimValSelector,Parameters extends TopNParams> |
Modifier and Type | Class and Description |
---|---|
static class |
PooledTopNAlgorithm.PooledTopNParams |
Modifier and Type | Method and Description |
---|---|
TopNParams |
TopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
Cursor cursor) |
TopNParams |
DimExtractionTopNAlgorithm.makeInitParams(ColumnSelectorPlus<TopNColumnSelectorStrategy> selectorPlus,
Cursor cursor) |
TopNParams |
TimeExtractionTopNAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
Cursor cursor) |
TopNParams |
AggregateTopNMetricFirstAlgorithm.makeInitParams(ColumnSelectorPlus selectorPlus,
Cursor cursor) |
Modifier and Type | Method and Description |
---|---|
void |
TimeExtractionTopNAlgorithm.cleanup(TopNParams params) |
void |
DimExtractionTopNAlgorithm.cleanup(TopNParams params) |
void |
AggregateTopNMetricFirstAlgorithm.cleanup(TopNParams params) |
protected Map<String,Aggregator[]> |
TimeExtractionTopNAlgorithm.makeDimValAggregateStore(TopNParams params) |
protected Map<Comparable,Aggregator[]> |
DimExtractionTopNAlgorithm.makeDimValAggregateStore(TopNParams params) |
protected int[] |
TimeExtractionTopNAlgorithm.makeDimValSelector(TopNParams params,
int numProcessed,
int numToProcess) |
protected Aggregator[][] |
DimExtractionTopNAlgorithm.makeDimValSelector(TopNParams params,
int numProcessed,
int numToProcess) |
static TopNResultBuilder |
BaseTopNAlgorithm.makeResultBuilder(TopNParams params,
TopNQuery query) |
void |
AggregateTopNMetricFirstAlgorithm.run(TopNParams params,
TopNResultBuilder resultBuilder,
int[] ints) |
void |
DimExtractionTopNAlgorithm.scanAndAggregate(TopNParams params,
Aggregator[][] rowSelector,
Map<Comparable,Aggregator[]> aggregatesStore,
int numProcessed) |
protected void |
TimeExtractionTopNAlgorithm.scanAndAggregate(TopNParams params,
int[] dimValSelector,
Map<String,Aggregator[]> aggregatesStore,
int numProcessed) |
protected void |
DimExtractionTopNAlgorithm.updateResults(TopNParams params,
Aggregator[][] rowSelector,
Map<Comparable,Aggregator[]> aggregatesStore,
TopNResultBuilder resultBuilder) |
protected void |
TimeExtractionTopNAlgorithm.updateResults(TopNParams params,
int[] dimValSelector,
Map<String,Aggregator[]> aggregatesStore,
TopNResultBuilder resultBuilder) |
Modifier and Type | Method and Description |
---|---|
Aggregator[][] |
TopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities)
Used by DimExtractionTopNAlgorithm.
|
Aggregator[][] |
StringTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities) |
Aggregator[][] |
LongTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities) |
Aggregator[][] |
FloatTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities) |
Copyright © 2011–2017. All rights reserved.