Modifier and Type | Method and Description |
---|---|
AggregatorFactory[] |
BenchmarkSchemaInfo.getAggsArray() |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
BenchmarkSchemaInfo.getAggs() |
Constructor and Description |
---|
BenchmarkSchemaInfo(List<BenchmarkColumnSchema> columnSchemas,
List<AggregatorFactory> aggs,
org.joda.time.Interval dataInterval,
boolean withRollup) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
ClientMergeQuery.getAggregators() |
Constructor and Description |
---|
ClientMergeQuery(String dataSource,
List<DataSegment> segments,
List<AggregatorFactory> aggregators) |
Modifier and Type | Method and Description |
---|---|
static InputRow |
InputRowSerde.fromBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap,
byte[] data,
AggregatorFactory[] aggs) |
protected File |
IndexGeneratorJob.IndexGeneratorReducer.mergeQueryableIndex(List<QueryableIndex> indexes,
AggregatorFactory[] aggs,
File file,
ProgressIndicator progressIndicator) |
static byte[] |
InputRowSerde.toBytes(Map<String,InputRowSerde.IndexSerdeTypeHelper> typeHelperMap,
InputRow row,
AggregatorFactory[] aggs,
boolean reportParseExceptions) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
SameIntervalMergeTask.getAggregators() |
List<AggregatorFactory> |
MergeTask.getAggregators() |
List<AggregatorFactory> |
AppendTask.getAggregators() |
Constructor and Description |
---|
AppendTask(String id,
String dataSource,
List<DataSegment> segments,
List<AggregatorFactory> aggregators,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
MergeTask(String id,
String dataSource,
List<DataSegment> segments,
List<AggregatorFactory> aggregators,
Boolean rollup,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
SameIntervalMergeTask(String id,
String dataSource,
org.joda.time.Interval interval,
List<AggregatorFactory> aggregators,
Boolean rollup,
IndexSpec indexSpec,
Boolean buildV9Directly,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
Druids.TimeseriesQueryBuilder |
Druids.TimeseriesQueryBuilder.aggregators(AggregatorFactory... aggregators) |
Modifier and Type | Method and Description |
---|---|
Druids.TimeseriesQueryBuilder |
Druids.TimeseriesQueryBuilder.aggregators(List<AggregatorFactory> a) |
static List<PostAggregator> |
Queries.decoratePostAggregators(List<PostAggregator> postAggs,
Map<String,AggregatorFactory> aggFactories) |
static int |
DruidMetrics.findNumComplexAggs(List<AggregatorFactory> aggs) |
static List<PostAggregator> |
Queries.prepareAggregations(List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs)
Deprecated.
|
static List<PostAggregator> |
Queries.prepareAggregations(List<String> otherOutputNames,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs)
Returns decorated post-aggregators, based on original un-decorated post-aggregators.
|
Modifier and Type | Class and Description |
---|---|
class |
CountAggregatorFactory |
class |
DoubleMaxAggregatorFactory |
class |
DoubleMinAggregatorFactory |
class |
DoubleSumAggregatorFactory |
class |
FilteredAggregatorFactory |
class |
FloatMaxAggregatorFactory |
class |
FloatMinAggregatorFactory |
class |
FloatSumAggregatorFactory |
class |
HistogramAggregatorFactory |
class |
JavaScriptAggregatorFactory |
class |
LongMaxAggregatorFactory |
class |
LongMinAggregatorFactory |
class |
LongSumAggregatorFactory |
class |
SimpleDoubleAggregatorFactory |
class |
SimpleFloatAggregatorFactory |
class |
TimestampAggregatorFactory |
class |
TimestampMaxAggregatorFactory |
class |
TimestampMinAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
FilteredAggregatorFactory.getAggregator() |
AggregatorFactory |
TimestampAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
LongSumAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
LongMinAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
LongMaxAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
JavaScriptAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
HistogramAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
FloatSumAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
FloatMinAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
FloatMaxAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
FilteredAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
DoubleSumAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
DoubleMinAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
DoubleMaxAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
CountAggregatorFactory.getCombiningFactory() |
abstract AggregatorFactory |
AggregatorFactory.getCombiningFactory()
Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory.
|
AggregatorFactory |
TimestampAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
SimpleFloatAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
SimpleDoubleAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
LongSumAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
LongMinAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
LongMaxAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
JavaScriptAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
AggregatorFactory.getMergingFactory(AggregatorFactory other)
Returns an AggregatorFactory that can be used to merge the output of aggregators from this factory and
other factory.
|
static AggregatorFactory[] |
AggregatorFactory.mergeAggregators(List<AggregatorFactory[]> aggregatorsList)
Merges the list of AggregatorFactory[] (presumable from metadata of some segments being merged) and
returns merged AggregatorFactory[] (for the metadata for merged segment).
|
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
TimestampAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
SimpleFloatAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
SimpleDoubleAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
LongSumAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
LongMinAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
LongMaxAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
JavaScriptAggregatorFactory.getMergingFactory(AggregatorFactory other) |
AggregatorFactory |
AggregatorFactory.getMergingFactory(AggregatorFactory other)
Returns an AggregatorFactory that can be used to merge the output of aggregators from this factory and
other factory.
|
Object |
MetricManipulationFn.manipulate(AggregatorFactory factory,
Object object) |
Modifier and Type | Method and Description |
---|---|
static Pair<List<AggregatorFactory>,List<PostAggregator>> |
AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList,
List<PostAggregator> postAggList,
String metric) |
PostAggregator |
PostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
Returns a richer post aggregator which are built from the given aggregators with their names and some accessible
environmental variables such as ones in the object scope.
|
Constructor and Description |
---|
AggregatorFactoryNotMergeableException(AggregatorFactory af1,
AggregatorFactory af2) |
FilteredAggregatorFactory(AggregatorFactory delegate,
DimFilter filter) |
Modifier and Type | Class and Description |
---|---|
class |
CardinalityAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
CardinalityAggregatorFactory.getCombiningFactory() |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
CardinalityAggregatorFactory.getRequiredColumns() |
Modifier and Type | Class and Description |
---|---|
class |
DoublesSketchAggregatorFactory |
class |
DoublesSketchMergeAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
DoublesSketchAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
DoublesSketchAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
DoublesSketchAggregatorFactory.getRequiredColumns() |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
DoublesSketchAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
PostAggregator |
DoublesSketchToStringPostAggregator.decorate(Map<String,AggregatorFactory> map) |
PostAggregator |
DoublesSketchToQuantilesPostAggregator.decorate(Map<String,AggregatorFactory> map) |
PostAggregator |
DoublesSketchToQuantilePostAggregator.decorate(Map<String,AggregatorFactory> map) |
PostAggregator |
DoublesSketchToHistogramPostAggregator.decorate(Map<String,AggregatorFactory> map) |
Modifier and Type | Class and Description |
---|---|
class |
SketchAggregatorFactory |
class |
SketchMergeAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
SketchMergeAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
SketchMergeAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
SketchMergeAggregatorFactory.getRequiredColumns() |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
SketchMergeAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
PostAggregator |
SketchSetPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
SketchEstimatePostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
Modifier and Type | Class and Description |
---|---|
class |
OldSketchBuildAggregatorFactory |
class |
OldSketchMergeAggregatorFactory |
Modifier and Type | Class and Description |
---|---|
class |
DistinctCountAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
DistinctCountAggregatorFactory.getCombiningFactory() |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
DistinctCountAggregatorFactory.getRequiredColumns() |
Modifier and Type | Class and Description |
---|---|
class |
DoubleFirstAggregatorFactory |
class |
FloatFirstAggregatorFactory |
class |
LongFirstAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
LongFirstAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
FloatFirstAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
DoubleFirstAggregatorFactory.getCombiningFactory() |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
LongFirstAggregatorFactory.getRequiredColumns() |
List<AggregatorFactory> |
FloatFirstAggregatorFactory.getRequiredColumns() |
List<AggregatorFactory> |
DoubleFirstAggregatorFactory.getRequiredColumns() |
Modifier and Type | Class and Description |
---|---|
class |
ApproximateHistogramAggregatorFactory |
class |
ApproximateHistogramFoldingAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
ApproximateHistogramFoldingAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
ApproximateHistogramAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
ApproximateHistogramAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
ApproximateHistogramAggregatorFactory.getRequiredColumns() |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
ApproximateHistogramAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
PostAggregator |
QuantilesPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
QuantilePostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
MinPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
MaxPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
EqualBucketsPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
CustomBucketsPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
BucketsPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
Modifier and Type | Class and Description |
---|---|
class |
HyperUniquesAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
HyperUniquesAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
HyperUniquesAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
HyperUniquesAggregatorFactory.getRequiredColumns() |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
HyperUniquesAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
HyperUniqueFinalizingPostAggregator |
HyperUniqueFinalizingPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
Modifier and Type | Class and Description |
---|---|
class |
DoubleLastAggregatorFactory |
class |
FloatLastAggregatorFactory |
class |
LongLastAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
LongLastAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
FloatLastAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
DoubleLastAggregatorFactory.getCombiningFactory() |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
LongLastAggregatorFactory.getRequiredColumns() |
List<AggregatorFactory> |
FloatLastAggregatorFactory.getRequiredColumns() |
List<AggregatorFactory> |
DoubleLastAggregatorFactory.getRequiredColumns() |
Modifier and Type | Method and Description |
---|---|
ZtestPostAggregator |
ZtestPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
PvaluefromZscorePostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
Modifier and Type | Class and Description |
---|---|
class |
VarianceAggregatorFactory |
class |
VarianceFoldingAggregatorFactory |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
VarianceAggregatorFactory.getCombiningFactory() |
AggregatorFactory |
VarianceAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
VarianceAggregatorFactory.getRequiredColumns() |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory |
VarianceAggregatorFactory.getMergingFactory(AggregatorFactory other) |
Modifier and Type | Method and Description |
---|---|
PostAggregator |
StandardDeviationPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
GroupByQuery.getAggregatorSpecs() |
Modifier and Type | Method and Description |
---|---|
GroupByQuery.Builder |
GroupByQuery.Builder.addAggregator(AggregatorFactory aggregator) |
Modifier and Type | Method and Description |
---|---|
GroupByQuery.Builder |
GroupByQuery.Builder.setAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs) |
Constructor and Description |
---|
GroupByQuery(DataSource dataSource,
QuerySegmentSpec querySegmentSpec,
VirtualColumns virtualColumns,
DimFilter dimFilter,
Granularity granularity,
List<DimensionSpec> dimensions,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs,
HavingSpec havingSpec,
LimitSpec limitSpec,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
Grouper.BufferComparator |
Grouper.KeySerde.bufferComparatorWithAggregators(AggregatorFactory[] aggregatorFactories,
int[] aggregatorOffsets)
When pushing down limits, it may also be necessary to compare aggregated values along with the key
using the bufferComparator.
|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
int mergeBufferSize)
Create a single-threaded grouper and accumulator.
|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories,
com.google.common.util.concurrent.ListeningExecutorService grouperSorter,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt,
int mergeBufferSize)
If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not
been applied to the input rows yet, for example, in a nested query, if an extraction function is being
applied in the outer query to a field of the inner query.
|
static <KeyType> int |
StreamingMergeSortedGrouper.requiredBufferCapacity(Grouper.KeySerde<KeyType> keySerde,
AggregatorFactory[] aggregatorFactories)
Returns the minimum buffer capacity required for this grouper.
|
Constructor and Description |
---|
AbstractBufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerde<KeyType> keySerde,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize) |
BufferArrayGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
int cardinality) |
BufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerde<KeyType> keySerde,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize,
float maxLoadFactor,
int initialBuckets,
boolean useDefaultSorting) |
ConcurrentGrouper(GroupByQueryConfig groupByQueryConfig,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
Grouper.KeySerdeFactory<KeyType> keySerdeFactory,
Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
int concurrencyHint,
DefaultLimitSpec limitSpec,
boolean sortHasNonGroupingFields,
com.google.common.util.concurrent.ListeningExecutorService executor,
int priority,
boolean hasQueryTimeout,
long queryTimeoutAt) |
LimitedBufferHashGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerde<KeyType> keySerde,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize,
float maxLoadFactor,
int initialBuckets,
int limit,
boolean sortHasNonGroupingFields) |
ParallelCombiner(com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
AggregatorFactory[] combiningFactories,
Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory,
com.google.common.util.concurrent.ListeningExecutorService executor,
boolean sortHasNonGroupingFields,
int concurrencyHint,
int priority,
long queryTimeoutAt,
int intermediateCombineDegree) |
SpillingGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
Grouper.KeySerdeFactory<KeyType> keySerdeFactory,
ColumnSelectorFactory columnSelectorFactory,
AggregatorFactory[] aggregatorFactories,
int bufferGrouperMaxSize,
float bufferGrouperMaxLoadFactor,
int bufferGrouperInitialBuckets,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
boolean spillingAllowed,
DefaultLimitSpec limitSpec,
boolean sortHasNonGroupingFields,
int mergeBufferSize) |
Modifier and Type | Method and Description |
---|---|
void |
OrHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
NotHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
LessThanHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
HavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
GreaterThanHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
EqualToHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
DimFilterHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
BaseHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
void |
AndHavingSpec.setAggregators(Map<String,AggregatorFactory> aggregators) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
NoopLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
LimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst)
Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
|
com.google.common.base.Function<Sequence<Row>,Sequence<Row>> |
DefaultLimitSpec.build(List<DimensionSpec> dimensions,
List<AggregatorFactory> aggs,
List<PostAggregator> postAggs,
Granularity granularity,
boolean sortByDimsFirst) |
static int |
OrderByColumnSpec.getAggIndexForOrderBy(OrderByColumnSpec orderSpec,
List<AggregatorFactory> aggregatorFactories) |
Modifier and Type | Method and Description |
---|---|
Map<String,AggregatorFactory> |
SegmentAnalysis.getAggregators() |
Constructor and Description |
---|
SegmentAnalysis(String id,
List<org.joda.time.Interval> interval,
Map<String,ColumnAnalysis> columns,
long size,
long numRows,
Map<String,AggregatorFactory> aggregators,
TimestampSpec timestampSpec,
Granularity queryGranularity,
Boolean rollup) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
TimeseriesQuery.getAggregatorSpecs() |
Constructor and Description |
---|
TimeseriesBinaryFn(Granularity granularity,
List<AggregatorFactory> aggregations) |
TimeseriesQuery(DataSource dataSource,
QuerySegmentSpec querySegmentSpec,
boolean descending,
VirtualColumns virtualColumns,
DimFilter dimFilter,
Granularity granularity,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
TopNQuery.getAggregatorSpecs() |
Modifier and Type | Method and Description |
---|---|
TopNQueryBuilder |
TopNQueryBuilder.aggregators(List<? extends AggregatorFactory> a) |
protected static String[] |
TopNQueryQueryToolChest.extractFactoryName(List<AggregatorFactory> aggregatorFactories) |
Comparator |
TopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
Comparator |
NumericTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
Comparator |
LexicographicTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
Comparator |
InvertedTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
Comparator |
DimensionTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
Comparator |
AlphaNumericTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
TopNResultBuilder |
TopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
NumericTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
LexicographicTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
InvertedTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNResultBuilder |
DimensionTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
static Aggregator[] |
BaseTopNAlgorithm.makeAggregators(Cursor cursor,
List<AggregatorFactory> aggregatorSpecs) |
protected static BufferAggregator[] |
BaseTopNAlgorithm.makeBufferAggregators(Cursor cursor,
List<AggregatorFactory> aggregatorSpecs) |
void |
TopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
void |
NumericTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
void |
LexicographicTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
void |
InvertedTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
void |
DimensionTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
TopNQuery |
TopNQuery.withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs) |
Constructor and Description |
---|
TopNBinaryFn(Granularity granularity,
DimensionSpec dimSpec,
TopNMetricSpec topNMetricSpec,
int threshold,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
TopNLexicographicResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
int threshold,
String previousStop,
Comparator comparator,
List<AggregatorFactory> aggFactories) |
TopNNumericResultBuilder(org.joda.time.DateTime timestamp,
DimensionSpec dimSpec,
String metricName,
int threshold,
Comparator comparator,
List<AggregatorFactory> aggFactories,
List<PostAggregator> postAggs) |
TopNQuery(DataSource dataSource,
VirtualColumns virtualColumns,
DimensionSpec dimensionSpec,
TopNMetricSpec topNMetricSpec,
int threshold,
QuerySegmentSpec querySegmentSpec,
DimFilter dimFilter,
Granularity granularity,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory[] |
Metadata.getAggregators() |
Modifier and Type | Method and Description |
---|---|
File |
IndexMergerV9.append(List<IndexableAdapter> indexes,
AggregatorFactory[] aggregators,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.append(List<IndexableAdapter> indexes,
AggregatorFactory[] aggregators,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.merge(List<IndexableAdapter> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec) |
File |
IndexMerger.merge(List<IndexableAdapter> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec) |
static Metadata |
Metadata.merge(List<Metadata> toBeMerged,
AggregatorFactory[] overrideMergedAggregators) |
File |
IndexMergerV9.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
ProgressIndicator progress,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMergerV9.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
File |
IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes,
boolean rollup,
AggregatorFactory[] metricAggs,
File outDir,
IndexSpec indexSpec,
SegmentWriteOutMediumFactory segmentWriteOutMediumFactory) |
Metadata |
Metadata.setAggregators(AggregatorFactory[] aggregators) |
Constructor and Description |
---|
RowboatMergeFunction(AggregatorFactory[] metricAggs) |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory[] |
IncrementalIndex.getMetricAggs() |
AggregatorFactory[] |
IncrementalIndexSchema.getMetrics() |
Modifier and Type | Method and Description |
---|---|
protected Integer |
OnheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
IncrementalIndex.TimeAndDims key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean skipMaxRowsInMemoryCheck) |
protected Integer |
OffheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
IncrementalIndex.TimeAndDims key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean skipMaxRowsInMemoryCheck) |
protected abstract Integer |
IncrementalIndex.addToFacts(AggregatorFactory[] metrics,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
InputRow row,
AtomicInteger numEntries,
IncrementalIndex.TimeAndDims key,
ThreadLocal<InputRow> rowContainer,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean skipMaxRowsInMemoryCheck) |
protected Aggregator[] |
OnheapIncrementalIndex.initAggs(AggregatorFactory[] metrics,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean deserializeComplexMetrics,
boolean concurrentEventAdd) |
protected BufferAggregator[] |
OffheapIncrementalIndex.initAggs(AggregatorFactory[] metrics,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean deserializeComplexMetrics,
boolean concurrentEventAdd) |
protected abstract AggregatorType[] |
IncrementalIndex.initAggs(AggregatorFactory[] metrics,
com.google.common.base.Supplier<InputRow> rowSupplier,
boolean deserializeComplexMetrics,
boolean concurrentEventAdd) |
protected ColumnSelectorFactory |
IncrementalIndex.makeColumnSelectorFactory(AggregatorFactory agg,
com.google.common.base.Supplier<InputRow> in,
boolean deserializeComplexMetrics) |
static ColumnSelectorFactory |
IncrementalIndex.makeColumnSelectorFactory(VirtualColumns virtualColumns,
AggregatorFactory agg,
com.google.common.base.Supplier<InputRow> in,
boolean deserializeComplexMetrics)
Column selector used at ingestion time for inputs to aggregators.
|
IncrementalIndex.Builder |
IncrementalIndex.Builder.setSimpleTestingIndexSchema(AggregatorFactory... metrics)
A helper method to set a simple index schema with only metrics and default values for the other parameters.
|
IncrementalIndexSchema.Builder |
IncrementalIndexSchema.Builder.withMetrics(AggregatorFactory... metrics) |
Constructor and Description |
---|
IncrementalIndexSchema(long minTimestamp,
TimestampSpec timestampSpec,
Granularity gran,
VirtualColumns virtualColumns,
DimensionsSpec dimensionsSpec,
AggregatorFactory[] metrics,
boolean rollup) |
MetricDesc(int index,
AggregatorFactory factory) |
Modifier and Type | Method and Description |
---|---|
AggregatorFactory[] |
DataSchema.getAggregators() |
Constructor and Description |
---|
DataSchema(String dataSource,
Map<String,Object> parser,
AggregatorFactory[] aggregators,
GranularitySpec granularitySpec,
TransformSpec transformSpec,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
Aggregation.getAggregatorFactories() |
Modifier and Type | Method and Description |
---|---|
static Aggregation |
Aggregation.create(AggregatorFactory aggregatorFactory) |
static Aggregation |
Aggregation.create(List<VirtualColumn> virtualColumns,
AggregatorFactory aggregatorFactory) |
Modifier and Type | Method and Description |
---|---|
static Aggregation |
Aggregation.create(List<AggregatorFactory> aggregatorFactories,
PostAggregator postAggregator) |
static Aggregation |
Aggregation.create(List<VirtualColumn> virtualColumns,
List<AggregatorFactory> aggregatorFactories,
PostAggregator postAggregator) |
Modifier and Type | Method and Description |
---|---|
List<AggregatorFactory> |
Grouping.getAggregatorFactories() |
Copyright © 2011–2018. All rights reserved.