| Modifier and Type | Class and Description | 
|---|---|
class  | 
CountBufferAggregator  | 
class  | 
DoubleSumBufferAggregator  | 
class  | 
FilteredBufferAggregator  | 
class  | 
HistogramBufferAggregator  | 
class  | 
JavaScriptBufferAggregator  | 
class  | 
LongSumBufferAggregator  | 
class  | 
MaxBufferAggregator  | 
class  | 
MinBufferAggregator  | 
| Constructor and Description | 
|---|
FilteredBufferAggregator(ValueMatcher matcher,
                        BufferAggregator delegate)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CardinalityBufferAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
CardinalityAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ApproximateHistogramBufferAggregator  | 
class  | 
ApproximateHistogramFoldingBufferAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
ApproximateHistogramFoldingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
ApproximateHistogramAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
HyperUniquesBufferAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
HyperUniquesAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected static BufferAggregator[] | 
BaseTopNAlgorithm.makeBufferAggregators(Cursor cursor,
                     List<AggregatorFactory> aggregatorSpecs)  | 
protected BufferAggregator[] | 
PooledTopNAlgorithm.makeDimValAggregateStore(PooledTopNAlgorithm.PooledTopNParams params)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
PooledTopNAlgorithm.closeAggregators(BufferAggregator[] bufferAggregators)  | 
protected void | 
PooledTopNAlgorithm.scanAndAggregate(PooledTopNAlgorithm.PooledTopNParams params,
                int[] positions,
                BufferAggregator[] theAggregators,
                int numProcessed)
Use aggressive loop unrolling to aggregate the data
 How this works: The aggregates are evaluated AGG_UNROLL_COUNT at a time. 
 | 
protected void | 
PooledTopNAlgorithm.updateResults(PooledTopNAlgorithm.PooledTopNParams params,
             int[] positions,
             BufferAggregator[] theAggregators,
             TopNResultBuilder resultBuilder)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected BufferAggregator[] | 
OffheapIncrementalIndex.getAggsForRow(int rowOffset)  | 
protected BufferAggregator[] | 
OffheapIncrementalIndex.initAggs(AggregatorFactory[] metrics,
        ThreadLocal<io.druid.data.input.InputRow> in,
        boolean deserializeComplexMetrics)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Object | 
OffheapIncrementalIndex.getAggVal(BufferAggregator agg,
         int rowOffset,
         int aggPosition)  | 
Copyright © 2015. All rights reserved.