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.