Modifier and Type | Class and Description |
---|---|
class |
CountAggregator |
class |
DoubleMaxAggregator |
class |
DoubleMinAggregator |
class |
DoubleSumAggregator |
class |
FilteredAggregator |
class |
HistogramAggregator |
class |
JavaScriptAggregator |
class |
LongMaxAggregator |
class |
LongMinAggregator |
class |
LongSumAggregator |
class |
TimestampAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
TimestampAggregator.clone() |
Aggregator |
LongSumAggregator.clone() |
Aggregator |
LongMinAggregator.clone() |
Aggregator |
LongMaxAggregator.clone() |
Aggregator |
DoubleSumAggregator.clone() |
Aggregator |
DoubleMinAggregator.clone() |
Aggregator |
DoubleMaxAggregator.clone() |
Aggregator |
CountAggregator.clone() |
Aggregator |
TimestampAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
LongSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
LongMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
LongMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory) |
Aggregator |
HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory) |
Aggregator |
DoubleSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
DoubleMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
DoubleMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
abstract Aggregator |
AggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
static Aggregator |
Aggregators.noopAggregator() |
Constructor and Description |
---|
FilteredAggregator(ValueMatcher matcher,
Aggregator delegate) |
Modifier and Type | Class and Description |
---|---|
class |
CardinalityAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
CardinalityAggregator.clone() |
Aggregator |
CardinalityAggregatorFactory.factorize(ColumnSelectorFactory columnFactory) |
Modifier and Type | Class and Description |
---|---|
class |
EmptySketchAggregator |
class |
SketchAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
SketchAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Modifier and Type | Class and Description |
---|---|
class |
DistinctCountAggregator |
class |
EmptyDistinctCountAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
DistinctCountAggregatorFactory.factorize(ColumnSelectorFactory columnFactory) |
Modifier and Type | Class and Description |
---|---|
class |
DoubleFirstAggregator |
class |
LongFirstAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
LongFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
DoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Modifier and Type | Class and Description |
---|---|
class |
ApproximateHistogramAggregator |
class |
ApproximateHistogramFoldingAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
ApproximateHistogramFoldingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
ApproximateHistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Modifier and Type | Class and Description |
---|---|
class |
HyperUniquesAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
HyperUniquesAggregator.clone() |
Aggregator |
HyperUniquesAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Modifier and Type | Class and Description |
---|---|
class |
DoubleLastAggregator |
class |
LongLastAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
LongLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Aggregator |
DoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Modifier and Type | Class and Description |
---|---|
class |
VarianceAggregator |
static class |
VarianceAggregator.FloatVarianceAggregator |
static class |
VarianceAggregator.LongVarianceAggregator |
static class |
VarianceAggregator.ObjectVarianceAggregator |
Modifier and Type | Method and Description |
---|---|
Aggregator |
VarianceAggregatorFactory.factorize(ColumnSelectorFactory metricFactory) |
Modifier and Type | Method and Description |
---|---|
TimeseriesResultBuilder |
TimeseriesResultBuilder.addMetric(String name,
Aggregator aggregator) |
Modifier and Type | Field and Description |
---|---|
static Aggregator[] |
TopNAlgorithm.EMPTY_ARRAY |
Modifier and Type | Method and Description |
---|---|
Aggregator[][] |
BaseTopNAlgorithm.AggregatorArrayProvider.build() |
static Aggregator[] |
BaseTopNAlgorithm.makeAggregators(Cursor cursor,
List<AggregatorFactory> aggregatorSpecs) |
protected Aggregator[][] |
DimExtractionTopNAlgorithm.makeDimValSelector(TopNParams params,
int numProcessed,
int numToProcess) |
protected Aggregator[][] |
DimExtractionTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators,
int numProcessed,
int numToProcess) |
Modifier and Type | Method and Description |
---|---|
void |
DimExtractionTopNAlgorithm.scanAndAggregate(TopNParams params,
Aggregator[][] rowSelector,
Map<Comparable,Aggregator[]> aggregatesStore,
int numProcessed) |
protected Aggregator[][] |
DimExtractionTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators,
int numProcessed,
int numToProcess) |
protected void |
DimExtractionTopNAlgorithm.updateResults(TopNParams params,
Aggregator[][] rowSelector,
Map<Comparable,Aggregator[]> aggregatesStore,
TopNResultBuilder resultBuilder) |
Modifier and Type | Method and Description |
---|---|
Aggregator[][] |
TopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities)
Used by DimExtractionTopNAlgorithm.
|
Aggregator[][] |
StringTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities) |
Aggregator[][] |
LongTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities) |
Aggregator[][] |
FloatTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query,
TopNParams params,
Capabilities capabilities) |
Modifier and Type | Method and Description |
---|---|
void |
StringTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
DimensionSelector selector,
Cursor cursor,
Aggregator[][] rowSelector,
Map<String,Aggregator[]> aggregatesStore) |
void |
FloatTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
FloatColumnSelector selector,
Cursor cursor,
Aggregator[][] rowSelector,
it.unimi.dsi.fastutil.ints.Int2ObjectMap<Aggregator[]> aggregatesStore) |
void |
LongTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
LongColumnSelector selector,
Cursor cursor,
Aggregator[][] rowSelector,
it.unimi.dsi.fastutil.longs.Long2ObjectMap<Aggregator[]> aggregatesStore) |
void |
TopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query,
ValueSelectorType selector,
Cursor cursor,
Aggregator[][] rowSelector,
DimExtractionAggregateStoreType aggregatesStore)
Used by DimExtractionTopNAlgorithm.
|
Modifier and Type | Method and Description |
---|---|
protected Aggregator[] |
OnheapIncrementalIndex.concurrentGet(int offset) |
protected Aggregator[] |
OnheapIncrementalIndex.getAggsForRow(int rowOffset) |
protected Aggregator[] |
OnheapIncrementalIndex.initAggs(AggregatorFactory[] metrics,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean deserializeComplexMetrics) |
Modifier and Type | Method and Description |
---|---|
protected void |
OnheapIncrementalIndex.concurrentSet(int offset,
Aggregator[] value) |
protected Object |
OnheapIncrementalIndex.getAggVal(Aggregator agg,
int rowOffset,
int aggPosition) |
Copyright © 2011–2017. All rights reserved.