| Modifier and Type | Method and Description | 
|---|---|
static Aggregator[] | 
QueryRunnerHelper.makeAggregators(Cursor cursor,
               List<AggregatorFactory> aggregatorSpecs)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CountAggregator  | 
class  | 
DoubleSumAggregator  | 
class  | 
FilteredAggregator  | 
class  | 
HistogramAggregator  | 
class  | 
JavaScriptAggregator  | 
class  | 
LongSumAggregator  | 
class  | 
MaxAggregator  | 
class  | 
MinAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
MinAggregator.clone()  | 
Aggregator | 
MaxAggregator.clone()  | 
Aggregator | 
LongSumAggregator.clone()  | 
Aggregator | 
DoubleSumAggregator.clone()  | 
Aggregator | 
CountAggregator.clone()  | 
Aggregator | 
MinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
MaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
LongSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)  | 
Aggregator | 
HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory)  | 
Aggregator | 
DoubleSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
AggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
static Aggregator | 
Aggregators.noopAggregator()  | 
| Constructor and Description | 
|---|
FilteredAggregator(ValueMatcher matcher,
                  Aggregator delegate)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CardinalityAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
CardinalityAggregator.clone()  | 
Aggregator | 
CardinalityAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ApproximateHistogramAggregator  | 
class  | 
ApproximateHistogramFoldingAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
ApproximateHistogramFoldingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
Aggregator | 
ApproximateHistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
HyperUniquesAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator | 
HyperUniquesAggregator.clone()  | 
Aggregator | 
HyperUniquesAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
TimeseriesResultBuilder | 
TimeseriesResultBuilder.addMetric(Aggregator aggregator)  | 
| Modifier and Type | Field and Description | 
|---|---|
static Aggregator[] | 
TopNAlgorithm.EMPTY_ARRAY  | 
| Modifier and Type | Method and Description | 
|---|---|
Aggregator[][] | 
BaseTopNAlgorithm.AggregatorArrayProvider.build()  | 
protected static Aggregator[] | 
BaseTopNAlgorithm.makeAggregators(Cursor cursor,
               List<AggregatorFactory> aggregatorSpecs)  | 
protected Aggregator[][] | 
DimExtractionTopNAlgorithm.makeDimValSelector(TopNParams params,
                  int numProcessed,
                  int numToProcess)  | 
protected Aggregator[][] | 
DimExtractionTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators,
                    int numProcessed,
                    int numToProcess)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
DimExtractionTopNAlgorithm.scanAndAggregate(TopNParams params,
                Aggregator[][] rowSelector,
                Map<String,Aggregator[]> aggregatesStore,
                int numProcessed)  | 
protected Aggregator[][] | 
DimExtractionTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators,
                    int numProcessed,
                    int numToProcess)  | 
protected void | 
DimExtractionTopNAlgorithm.updateResults(TopNParams params,
             Aggregator[][] rowSelector,
             Map<String,Aggregator[]> aggregatesStore,
             TopNResultBuilder resultBuilder)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Aggregator[] | 
OnheapIncrementalIndex.concurrentGet(int offset)  | 
protected Aggregator[] | 
OnheapIncrementalIndex.getAggsForRow(int rowOffset)  | 
protected Aggregator[] | 
OnheapIncrementalIndex.initAggs(AggregatorFactory[] metrics,
        ThreadLocal<io.druid.data.input.InputRow> in,
        boolean deserializeComplexMetrics)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
OnheapIncrementalIndex.concurrentSet(int offset,
             Aggregator[] value)  | 
protected Object | 
OnheapIncrementalIndex.getAggVal(Aggregator agg,
         int rowOffset,
         int aggPosition)  | 
Copyright © 2015. All rights reserved.