| Modifier and Type | Class and Description |
|---|---|
class |
CountBufferAggregator |
class |
DoubleMaxBufferAggregator |
class |
DoubleMinBufferAggregator |
class |
DoubleSumBufferAggregator |
class |
FilteredBufferAggregator |
class |
HistogramBufferAggregator |
class |
JavaScriptBufferAggregator |
class |
LongMaxBufferAggregator |
class |
LongMinBufferAggregator |
class |
LongSumBufferAggregator |
| 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,
com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier,
boolean deserializeComplexMetrics) |
| Modifier and Type | Method and Description |
|---|---|
protected Object |
OffheapIncrementalIndex.getAggVal(BufferAggregator agg,
int rowOffset,
int aggPosition) |
Copyright © 2011–2015. All rights reserved.