Modifier and Type | Method and Description |
---|---|
static List<PostAggregator> |
Queries.decoratePostAggregators(List<PostAggregator> postAggs,
Map<String,AggregatorFactory> aggFactories) |
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 | Method and Description |
---|---|
Druids.TimeseriesQueryBuilder |
Druids.TimeseriesQueryBuilder.postAggregators(PostAggregator... postAggregators) |
Modifier and Type | Method and Description |
---|---|
static List<PostAggregator> |
Queries.decoratePostAggregators(List<PostAggregator> postAggs,
Map<String,AggregatorFactory> aggFactories) |
Druids.TimeseriesQueryBuilder |
Druids.TimeseriesQueryBuilder.postAggregators(List<PostAggregator> p) |
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 | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static Pair<List<AggregatorFactory>,List<PostAggregator>> |
AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList,
List<PostAggregator> postAggList,
String metric) |
static List<PostAggregator> |
AggregatorUtil.pruneDependentPostAgg(List<PostAggregator> postAggregatorList,
String postAggName)
returns the list of dependent postAggregators that should be calculated in order to calculate given postAgg
|
Modifier and Type | Method and Description |
---|---|
static Pair<List<AggregatorFactory>,List<PostAggregator>> |
AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList,
List<PostAggregator> postAggList,
String metric) |
static List<PostAggregator> |
AggregatorUtil.pruneDependentPostAgg(List<PostAggregator> postAggregatorList,
String postAggName)
returns the list of dependent postAggregators that should be calculated in order to calculate given postAgg
|
Modifier and Type | Class and Description |
---|---|
class |
DoublesSketchToHistogramPostAggregator |
class |
DoublesSketchToQuantilePostAggregator |
class |
DoublesSketchToQuantilesPostAggregator |
class |
DoublesSketchToStringPostAggregator |
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) |
PostAggregator |
DoublesSketchToStringPostAggregator.getField() |
PostAggregator |
DoublesSketchToQuantilesPostAggregator.getField() |
PostAggregator |
DoublesSketchToQuantilePostAggregator.getField() |
PostAggregator |
DoublesSketchToHistogramPostAggregator.getField() |
Constructor and Description |
---|
DoublesSketchToHistogramPostAggregator(String name,
PostAggregator field,
double[] splitPoints) |
DoublesSketchToQuantilePostAggregator(String name,
PostAggregator field,
double fraction) |
DoublesSketchToQuantilesPostAggregator(String name,
PostAggregator field,
double[] fractions) |
DoublesSketchToStringPostAggregator(String name,
PostAggregator field) |
Modifier and Type | Class and Description |
---|---|
class |
SketchEstimatePostAggregator |
class |
SketchSetPostAggregator |
Modifier and Type | Method and Description |
---|---|
PostAggregator |
SketchSetPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
SketchEstimatePostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
SketchEstimatePostAggregator.getField() |
Modifier and Type | Method and Description |
---|---|
List<PostAggregator> |
SketchSetPostAggregator.getFields() |
Constructor and Description |
---|
SketchEstimatePostAggregator(String name,
PostAggregator field,
Integer errorBoundsStdDev) |
Constructor and Description |
---|
SketchSetPostAggregator(String name,
String func,
Integer maxSize,
List<PostAggregator> fields) |
Modifier and Type | Class and Description |
---|---|
class |
OldSketchEstimatePostAggregator |
class |
OldSketchSetPostAggregator |
Constructor and Description |
---|
OldSketchEstimatePostAggregator(String name,
PostAggregator field) |
Constructor and Description |
---|
OldSketchSetPostAggregator(String name,
String func,
Integer maxSize,
List<PostAggregator> fields) |
Modifier and Type | Class and Description |
---|---|
class |
ApproximateHistogramPostAggregator |
class |
BucketsPostAggregator |
class |
CustomBucketsPostAggregator |
class |
EqualBucketsPostAggregator |
class |
MaxPostAggregator |
class |
MinPostAggregator |
class |
QuantilePostAggregator |
class |
QuantilesPostAggregator |
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 |
HyperUniqueFinalizingPostAggregator |
Modifier and Type | Class and Description |
---|---|
class |
ArithmeticPostAggregator |
class |
ConstantPostAggregator |
class |
DoubleGreatestPostAggregator |
class |
DoubleLeastPostAggregator |
class |
ExpressionPostAggregator |
class |
FieldAccessPostAggregator |
class |
FinalizingFieldAccessPostAggregator |
class |
JavaScriptPostAggregator |
class |
LongGreatestPostAggregator |
class |
LongLeastPostAggregator |
Modifier and Type | Method and Description |
---|---|
List<PostAggregator> |
LongLeastPostAggregator.getFields() |
List<PostAggregator> |
LongGreatestPostAggregator.getFields() |
List<PostAggregator> |
DoubleLeastPostAggregator.getFields() |
List<PostAggregator> |
DoubleGreatestPostAggregator.getFields() |
List<PostAggregator> |
ArithmeticPostAggregator.getFields() |
Constructor and Description |
---|
ArithmeticPostAggregator(String name,
String fnName,
List<PostAggregator> fields) |
ArithmeticPostAggregator(String name,
String fnName,
List<PostAggregator> fields,
String ordering) |
DoubleGreatestPostAggregator(String name,
List<PostAggregator> fields) |
DoubleLeastPostAggregator(String name,
List<PostAggregator> fields) |
LongGreatestPostAggregator(String name,
List<PostAggregator> fields) |
LongLeastPostAggregator(String name,
List<PostAggregator> fields) |
Modifier and Type | Class and Description |
---|---|
class |
PvaluefromZscorePostAggregator |
class |
ZtestPostAggregator
1.
|
Modifier and Type | Method and Description |
---|---|
PostAggregator |
PvaluefromZscorePostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
PostAggregator |
ZtestPostAggregator.getSample1Size() |
PostAggregator |
ZtestPostAggregator.getSample2Size() |
PostAggregator |
ZtestPostAggregator.getSuccessCount1() |
PostAggregator |
ZtestPostAggregator.getSuccessCount2() |
PostAggregator |
PvaluefromZscorePostAggregator.getZscore() |
Constructor and Description |
---|
PvaluefromZscorePostAggregator(String name,
PostAggregator zScore) |
ZtestPostAggregator(String name,
PostAggregator successCount1,
PostAggregator sample1Size,
PostAggregator successCount2,
PostAggregator sample2Size) |
Modifier and Type | Class and Description |
---|---|
class |
StandardDeviationPostAggregator |
Modifier and Type | Method and Description |
---|---|
PostAggregator |
StandardDeviationPostAggregator.decorate(Map<String,AggregatorFactory> aggregators) |
Modifier and Type | Method and Description |
---|---|
List<PostAggregator> |
GroupByQuery.getPostAggregatorSpecs() |
Modifier and Type | Method and Description |
---|---|
GroupByQuery.Builder |
GroupByQuery.Builder.setPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs) |
GroupByQuery |
GroupByQuery.withPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs) |
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 |
---|---|
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.getPostAggIndexForOrderBy(OrderByColumnSpec orderSpec,
List<PostAggregator> postAggs) |
Modifier and Type | Method and Description |
---|---|
List<PostAggregator> |
TimeseriesQuery.getPostAggregatorSpecs() |
Modifier and Type | Method and Description |
---|---|
TimeseriesQuery |
TimeseriesQuery.withPostAggregatorSpecs(List<PostAggregator> postAggregatorSpecs) |
Constructor and Description |
---|
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<PostAggregator> |
TopNQuery.getPostAggregatorSpecs() |
Modifier and Type | Method and Description |
---|---|
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) |
TopNQueryBuilder |
TopNQueryBuilder.postAggregators(List<PostAggregator> p) |
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) |
Constructor and Description |
---|
TopNBinaryFn(Granularity granularity,
DimensionSpec dimSpec,
TopNMetricSpec topNMetricSpec,
int threshold,
List<AggregatorFactory> aggregatorSpecs,
List<PostAggregator> postAggregatorSpecs) |
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 |
---|---|
Iterable<Row> |
IncrementalIndex.iterableWithPostAggregations(List<PostAggregator> postAggs,
boolean descending) |
Modifier and Type | Method and Description |
---|---|
abstract PostAggregator |
PostAggregatorFactory.factorize(String outputName) |
PostAggregator |
Aggregation.getPostAggregator() |
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) |
static Aggregation |
Aggregation.create(PostAggregator postAggregator) |
Modifier and Type | Method and Description |
---|---|
List<PostAggregator> |
Grouping.getPostAggregators() |
Copyright © 2011–2018. All rights reserved.