| 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 |
LongMaxBufferAggregator |
class |
LongMinBufferAggregator |
class |
LongSumBufferAggregator |
class |
NoopBufferAggregator |
class |
NullableBufferAggregator
The result of a NullableBufferAggregator will be null if all the values to be aggregated are null values or no values
are aggregated at all.
|
class |
SimpleDoubleBufferAggregator |
class |
SimpleFloatBufferAggregator |
class |
SimpleLongBufferAggregator |
static class |
SuppressedAggregatorFactory.SuppressedBufferAggregator |
| Constructor and Description |
|---|
FilteredBufferAggregator(ValueMatcher matcher,
BufferAggregator delegate) |
NullableBufferAggregator(BufferAggregator delegate,
BaseNullableColumnValueSelector nullSelector) |
SuppressedBufferAggregator(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 |
DoubleFirstBufferAggregator |
class |
FloatFirstBufferAggregator |
class |
LongFirstBufferAggregator |
class |
StringFirstBufferAggregator |
| Modifier and Type | Method and Description |
|---|---|
BufferAggregator |
StringFirstFoldingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
BaseObjectColumnValueSelector selector) |
BufferAggregator |
StringFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
BaseObjectColumnValueSelector selector) |
protected BufferAggregator |
LongFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected BufferAggregator |
FloatFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected BufferAggregator |
DoubleFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
| 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 |
class |
StringLastBufferAggregator |
| Modifier and Type | Method and Description |
|---|---|
BufferAggregator |
StringLastFoldingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
BaseObjectColumnValueSelector selector) |
BufferAggregator |
StringLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
BaseObjectColumnValueSelector selector) |
protected BufferAggregator |
LongLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected BufferAggregator |
FloatLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
protected BufferAggregator |
DoubleLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory,
ColumnValueSelector selector) |
| 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–2019 The Apache Software Foundation. All rights reserved.