Modifier and Type | Field and Description |
---|---|
static Aggregation |
AggregationAverageMaker.COUNT_OUTER |
Constructor and Description |
---|
RawAggregationMetricMaker(MetricDictionary metrics,
BiFunction<String,String,Aggregation> aggregationFactory)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
Set<Aggregation> |
TemplateDruidQuery.getAggregations() |
Modifier and Type | Method and Description |
---|---|
TemplateDruidQuery |
TemplateDruidQuery.withAggregations(Collection<Aggregation> newAggregations)
Makes a copy of the template query and any sub query(s), changing aggregations.
|
Constructor and Description |
---|
TemplateDruidQuery(Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations)
Template Query constructor for a non nested template query.
|
TemplateDruidQuery(Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
TemplateDruidQuery nestedQuery)
Template Query constructor for a nested template query.
|
TemplateDruidQuery(Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
TemplateDruidQuery nestedQuery,
ZonelessTimeGrain timeGrain)
Template Query constructor for a nested template query with a bound time grain.
|
TemplateDruidQuery(Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
ZonelessTimeGrain timeGrain)
Template Query constructor for a non nested template query with a bound time grain.
|
Modifier and Type | Class and Description |
---|---|
class |
CardinalityAggregation
Creates a Druid cardinality aggregation.
|
class |
CountAggregation
Aggregation for counts.
|
class |
DoubleMaxAggregation
Aggregation for the maximum of doubles.
|
class |
DoubleMinAggregation
Aggregation for the minimum of doubles.
|
class |
DoubleSumAggregation
Aggregation for the sum of doubles.
|
class |
FilteredAggregation
FilteredAggregation wraps aggregation with the associated filter.
|
class |
LongMaxAggregation
Aggregation for the maximum of longs.
|
class |
LongMinAggregation
Aggregation for the minimum of longs.
|
class |
LongSumAggregation
Aggregation for the sum of longs.
|
class |
MaxAggregation
Deprecated.
in favor of LongMaxAggregation or DoubleMaxAggregation, since Druid is deprecating MaxAggregation
|
class |
MinAggregation
Deprecated.
in favor of LongMinAggregation, since Druid is deprecating MinAggregation
|
class |
SketchAggregation
Base type for sketch aggregations.
|
class |
SketchCountAggregation
Deprecated.
To consider the latest version of sketch Library.
This class is replaced by ThetaSketchAggregation
|
class |
SketchMergeAggregation
Deprecated.
To consider the latest version of sketch Library.
This class is replaced by ThetaSketchAggregation
|
class |
ThetaSketchAggregation
Aggregation for custom sketches aggregations.
|
Modifier and Type | Method and Description |
---|---|
Aggregation |
FilteredAggregation.getAggregation() |
Aggregation |
FilteredAggregation.withAggregation(Aggregation aggregation)
Creates a new Filtered Aggregation with the provided aggregation.
|
Aggregation |
FilteredAggregation.withFieldName(String fieldName) |
Aggregation |
CountAggregation.withFieldName(String fieldName) |
Aggregation |
LongMaxAggregation.withFieldName(String fieldName) |
Aggregation |
LongMinAggregation.withFieldName(String fieldName) |
Aggregation |
LongSumAggregation.withFieldName(String fieldName) |
Aggregation |
DoubleSumAggregation.withFieldName(String fieldName) |
Aggregation |
MaxAggregation.withFieldName(String fieldName)
Deprecated.
|
Aggregation |
DoubleMinAggregation.withFieldName(String fieldName) |
abstract Aggregation |
Aggregation.withFieldName(String fieldName)
Creates a new Aggregation with the provided field name.
|
Aggregation |
MinAggregation.withFieldName(String fieldName)
Deprecated.
|
Aggregation |
DoubleMaxAggregation.withFieldName(String fieldName) |
Aggregation |
FilteredAggregation.withFilter(Filter filter)
Creates a new Filtered Aggregation with the provided filter.
|
Aggregation |
FilteredAggregation.withName(String name) |
abstract Aggregation |
Aggregation.withName(String name)
Creates a new Aggregation with the provided name.
|
Modifier and Type | Method and Description |
---|---|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
FilteredAggregation.nest()
Splits an Aggregation for 2-pass aggregation into an inner filtered aggregation & outer aggregation.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
FilteredAggregation.nest()
Splits an Aggregation for 2-pass aggregation into an inner filtered aggregation & outer aggregation.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
CountAggregation.nest()
Nesting a 'count' aggregation changes the outer aggregation
to a 'longSum' whereas the inner aggregation remains unchanged.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
CountAggregation.nest()
Nesting a 'count' aggregation changes the outer aggregation
to a 'longSum' whereas the inner aggregation remains unchanged.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
SketchCountAggregation.nest()
Deprecated.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
SketchCountAggregation.nest()
Deprecated.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
CardinalityAggregation.nest()
Cardinality aggregators cannot be safely nested due to correctness constraints which Bard does not currently
support.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
CardinalityAggregation.nest()
Cardinality aggregators cannot be safely nested due to correctness constraints which Bard does not currently
support.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
Aggregation.nest()
Splits an Aggregation for 2-pass aggregation into an inner & outer Aggregation.
|
org.apache.commons.lang3.tuple.Pair<Aggregation,Aggregation> |
Aggregation.nest()
Splits an Aggregation for 2-pass aggregation into an inner & outer Aggregation.
|
Modifier and Type | Method and Description |
---|---|
Aggregation |
FilteredAggregation.withAggregation(Aggregation aggregation)
Creates a new Filtered Aggregation with the provided aggregation.
|
Constructor and Description |
---|
FilteredAggregation(String name,
Aggregation aggregation,
Filter filter)
Constructor.
|
FilteredAggregation(String name,
String fieldName,
Aggregation aggregation,
Filter filter)
Deprecated.
Filtered Aggregations do not have their own field name, they use the one from their aggregator
|
Constructor and Description |
---|
OrderByColumn(Aggregation aggregation,
SortDirection direction)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected Collection<Aggregation> |
AbstractDruidAggregationQuery.aggregations |
Modifier and Type | Method and Description |
---|---|
Set<Aggregation> |
DruidAggregationQuery.getAggregations()
Returns the aggregations of the query.
|
Set<Aggregation> |
LookbackQuery.getAggregations() |
Set<Aggregation> |
AbstractDruidAggregationQuery.getAggregations() |
Modifier and Type | Method and Description |
---|---|
Q |
DruidAggregationQuery.withAggregations(Collection<Aggregation> aggregations)
Returns a copy of this query with the specified aggregations.
|
TopNQuery |
TopNQuery.withAggregations(Collection<Aggregation> aggregations) |
LookbackQuery |
LookbackQuery.withAggregations(Collection<Aggregation> aggregations) |
TimeSeriesQuery |
TimeSeriesQuery.withAggregations(Collection<Aggregation> aggregations) |
GroupByQuery |
GroupByQuery.withAggregations(Collection<Aggregation> aggregations) |
Constructor and Description |
---|
AbstractDruidAggregationQuery(QueryType queryType,
DataSource dataSource,
Granularity granularity,
Collection<Dimension> dimensions,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
QueryContext context,
boolean doFork)
Constructor.
|
GroupByQuery(DataSource dataSource,
Granularity granularity,
Collection<Dimension> dimensions,
Filter filter,
Having having,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
LimitSpec limitSpec)
Constructor.
|
GroupByQuery(DataSource dataSource,
Granularity granularity,
Collection<Dimension> dimensions,
Filter filter,
Having having,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
LimitSpec limitSpec,
QueryContext context,
boolean doFork)
Constructor.
|
TimeSeriesQuery(DataSource dataSource,
Granularity granularity,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals)
Constructor.
|
TimeSeriesQuery(DataSource dataSource,
Granularity granularity,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
QueryContext context,
boolean doFork)
Constructor.
|
TopNQuery(DataSource dataSource,
Granularity granularity,
Dimension dimension,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
long threshold,
TopNMetric metric)
Constructor.
|
TopNQuery(DataSource dataSource,
Granularity granularity,
Dimension dimension,
Filter filter,
Collection<Aggregation> aggregations,
Collection<PostAggregation> postAggregations,
Collection<org.joda.time.Interval> intervals,
long threshold,
TopNMetric metric,
QueryContext context,
boolean doFork)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
protected BiFunction<Aggregation,ApiToFieldMapper,Optional<SqlAggregation>> |
DruidQueryToSqlConverter.buildDruidSqlTypeConverter()
Builds a converter between druid and sql aggregations.
|
Modifier and Type | Method and Description |
---|---|
SqlAggregationQuery |
SqlAggregationQuery.withAggregations(Collection<Aggregation> aggregations) |
Modifier and Type | Method and Description |
---|---|
Optional<SqlAggregation> |
DruidSqlAggregationConverter.apply(Aggregation aggregation,
ApiToFieldMapper apiToFieldMapper)
Finds the corresponding
SqlAggregation from a druid aggregation. |
SqlAggregation |
DefaultSqlAggregationType.getSqlAggregation(Aggregation aggregation,
ApiToFieldMapper apiToFieldMapper) |
SqlAggregation |
SqlAggregationType.getSqlAggregation(Aggregation aggregation,
ApiToFieldMapper apiToFieldMapper)
Builds a
SqlAggregation which contains all the necessary information to build an aggregation in sql. |
Modifier and Type | Method and Description |
---|---|
Set<Aggregation> |
FilteredSketchMetricsHelper.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Deprecated.
Update the outer query aggs if their respective inner post agg names are updated.
|
Set<Aggregation> |
MetricsFilterSetBuilder.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Update the outer query aggs if their respective inner post agg names are updated.
|
Set<Aggregation> |
FilteredThetaSketchMetricsHelper.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping) |
Modifier and Type | Method and Description |
---|---|
Set<FilteredAggregation> |
FilteredSketchMetricsHelper.getFilteredAggregation(com.fasterxml.jackson.databind.JsonNode filter,
Aggregation aggregation,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Deprecated.
|
Set<FilteredAggregation> |
MetricsFilterSetBuilder.getFilteredAggregation(com.fasterxml.jackson.databind.JsonNode filter,
Aggregation aggregation,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
For a given aggregator, this method applies the filter and returns a set of filtered aggregations.
|
Set<FilteredAggregation> |
FilteredThetaSketchMetricsHelper.getFilteredAggregation(com.fasterxml.jackson.databind.JsonNode filter,
Aggregation aggregation,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest) |
Modifier and Type | Method and Description |
---|---|
PostAggregation |
FilteredSketchMetricsHelper.replacePostAggWithPostAggFromMap(PostAggregation postAggregation,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Deprecated.
|
PostAggregation |
MetricsFilterSetBuilder.replacePostAggWithPostAggFromMap(PostAggregation postAggregation,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Takes a post aggregation and updates its FieldAccessor if its fieldName is present in the map changed.
|
PostAggregation |
FilteredThetaSketchMetricsHelper.replacePostAggWithPostAggFromMap(PostAggregation postAggregation,
Map<String,Aggregation> oldNameToNewAggregationMapping) |
Set<Aggregation> |
FilteredSketchMetricsHelper.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Deprecated.
Update the outer query aggs if their respective inner post agg names are updated.
|
Set<Aggregation> |
FilteredSketchMetricsHelper.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Deprecated.
Update the outer query aggs if their respective inner post agg names are updated.
|
Set<Aggregation> |
MetricsFilterSetBuilder.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Update the outer query aggs if their respective inner post agg names are updated.
|
Set<Aggregation> |
MetricsFilterSetBuilder.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping)
Update the outer query aggs if their respective inner post agg names are updated.
|
Set<Aggregation> |
FilteredThetaSketchMetricsHelper.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping) |
Set<Aggregation> |
FilteredThetaSketchMetricsHelper.updateQueryAggs(Set<Aggregation> outerAggregations,
Map<String,String> oldFieldNameToNewFieldNameMap,
Map<String,Aggregation> oldNameToNewAggregationMapping) |
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.