| Modifier and Type | Class and Description | 
|---|---|
class  | 
CountBufferAggregator  | 
class  | 
DoubleMaxBufferAggregator  | 
class  | 
DoubleMinBufferAggregator  | 
class  | 
DoubleSumBufferAggregator  | 
class  | 
FilteredBufferAggregator  | 
class  | 
FloatMaxBufferAggregator  | 
class  | 
FloatMinBufferAggregator  | 
class  | 
FloatSumBufferAggregator  | 
class  | 
HistogramBufferAggregator  | 
class  | 
JavaScriptBufferAggregator  | 
class  | 
LongBufferAggregator  | 
class  | 
LongMaxBufferAggregator  | 
class  | 
LongMinBufferAggregator  | 
class  | 
LongSumBufferAggregator  | 
class  | 
NoopBufferAggregator  | 
class  | 
SimpleDoubleBufferAggregator  | 
class  | 
SimpleFloatBufferAggregator  | 
class  | 
TimestampBufferAggregator  | 
| 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  | 
DoublesSketchBuildBufferAggregator  | 
class  | 
DoublesSketchMergeBufferAggregator  | 
class  | 
DoublesSketchNoOpBufferAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
DoublesSketchMergeAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
DoublesSketchAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
SketchBufferAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
SketchAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DistinctCountBufferAggregator  | 
class  | 
EmptyDistinctCountBufferAggregator
The difference from  
NoopBufferAggregator is that
 EmptyDistinctCountBufferAggregator returns 0 instead of null from EmptyDistinctCountBufferAggregator.get(ByteBuffer, int). | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
DistinctCountAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
DoubleFirstBufferAggregator  | 
class  | 
FloatFirstBufferAggregator  | 
class  | 
LongFirstBufferAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
LongFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
FloatFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
DoubleFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| 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 | Class and Description | 
|---|---|
class  | 
DoubleLastBufferAggregator  | 
class  | 
FloatLastBufferAggregator  | 
class  | 
LongLastBufferAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
LongLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
FloatLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
BufferAggregator | 
DoubleLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
VarianceBufferAggregator  | 
static class  | 
VarianceBufferAggregator.FloatVarianceAggregator  | 
static class  | 
VarianceBufferAggregator.LongVarianceAggregator  | 
static class  | 
VarianceBufferAggregator.ObjectVarianceAggregator  | 
| Modifier and Type | Method and Description | 
|---|---|
BufferAggregator | 
VarianceAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected BufferAggregator[] | 
AbstractBufferHashGrouper.aggregators  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
Historical1AggPooledTopNScanner<DimensionSelectorType extends HistoricalDimensionSelector,MetricSelectorType,BufferAggregatorType extends BufferAggregator>  | 
| 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)  | 
long | 
Generic2AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator1,
                int aggregator1Size,
                BufferAggregator aggregator2,
                int aggregator2Size,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)
Any changes to this method should be coordinated with  
TopNUtils, PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations() and downstream methods. | 
long | 
Generic2AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator1,
                int aggregator1Size,
                BufferAggregator aggregator2,
                int aggregator2Size,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)  | 
long | 
Generic1AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator,
                int aggregatorSize,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)
Any changes to this method should be coordinated with  
TopNUtils, PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations() and downstream methods. | 
long | 
Generic1AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector,
                BufferAggregator aggregator,
                int aggregatorSize,
                Cursor cursor,
                int[] positions,
                ByteBuffer resultsBuffer)  | 
protected long | 
PooledTopNAlgorithm.scanAndAggregate(PooledTopNAlgorithm.PooledTopNParams params,
                int[] positions,
                BufferAggregator[] theAggregators)  | 
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<InputRow> rowSupplier,
        boolean deserializeComplexMetrics,
        boolean concurrentEventAdd)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected Object | 
OffheapIncrementalIndex.getAggVal(BufferAggregator agg,
         int rowOffset,
         int aggPosition)  | 
Copyright © 2011–2018. All rights reserved.