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.