Modifier and Type | Method and Description |
---|---|
protected GroupByQuery |
DruidQueryBuilder.buildGroupByQuery(TemplateDruidQuery template,
ConstrainedTable table,
Granularity granularity,
org.joda.time.DateTimeZone timeZone,
Set<Dimension> groupByDimensions,
Filter filter,
Having having,
Set<org.joda.time.Interval> intervals,
LimitSpec druidOrderBy)
Builds a druid groupBy query recursively nesting dataSource based on the TemplateDruidQuery.
|
DruidAggregationQuery<?> |
DruidQueryBuilder.buildQuery(DataApiRequest request,
TemplateDruidQuery template)
Build a druid query object from an API request and it's templateDruidQuery.
|
protected TimeSeriesQuery |
DruidQueryBuilder.buildTimeSeriesQuery(TemplateDruidQuery template,
ConstrainedTable table,
Granularity granularity,
org.joda.time.DateTimeZone timeZone,
Filter filter,
Set<org.joda.time.Interval> intervals)
Builds a druid TimeSeries query.
|
protected TopNQuery |
DruidQueryBuilder.buildTopNQuery(TemplateDruidQuery template,
ConstrainedTable table,
Granularity granularity,
org.joda.time.DateTimeZone timeZone,
Set<Dimension> groupByDimension,
Filter filter,
Set<org.joda.time.Interval> intervals,
TopNMetric metricSpec,
int topN)
Builds a druid topN query.
|
protected boolean |
DruidQueryBuilder.canOptimizeTimeSeries(DataApiRequest apiRequest,
TemplateDruidQuery templateDruidQuery)
Determine if the optimization to a Timeseries query can be done.
|
protected boolean |
DruidQueryBuilder.canOptimizeTopN(DataApiRequest apiRequest,
TemplateDruidQuery templateDruidQuery)
Determine if the optimization to a TopN query can be done.
|
Modifier and Type | Method and Description |
---|---|
protected TemplateDruidQuery |
MetricMaker.getDependentQuery(String name)
Deprecated.
Instead get the metric in the calling function and then get the TDQ out only if necessary
|
protected TemplateDruidQuery |
MetricMaker.getMergedQuery(List<String> names)
A helper function returning the resulting aggregation set from merging one or more template druid queries.
|
Modifier and Type | Method and Description |
---|---|
TemplateDruidQuery |
TemplateDruidQuery.getInnermostQuery() |
TemplateDruidQuery |
LogicalMetric.getTemplateDruidQuery() |
TemplateDruidQuery |
TemplateDruidQueryMerger.merge(DataApiRequest request)
Merge all of the TemplateDruidQueries from all of the Metrics in an DataApiRequest together.
|
TemplateDruidQuery |
TemplateDruidQuery.merge(TemplateDruidQuery sibling)
Merges two template queries into one.
|
TemplateDruidQuery |
TemplateDruidQuery.nest()
Transforms a N-pass query into a (N+1)-pass query.
|
TemplateDruidQuery |
TemplateDruidQuery.withAggregations(Collection<Aggregation> newAggregations)
Makes a copy of the template query and any sub query(s), changing aggregations.
|
TemplateDruidQuery |
TemplateDruidQuery.withAllIntervals(Collection<org.joda.time.Interval> intervals) |
TemplateDruidQuery |
TemplateDruidQuery.withContext(QueryContext context) |
TemplateDruidQuery |
TemplateDruidQuery.withDataSource(DataSource dataSource) |
TemplateDruidQuery |
TemplateDruidQuery.withFilter(Filter filter) |
TemplateDruidQuery |
TemplateDruidQuery.withGranularity(Granularity granularity)
With granularity is partially implemented because TemplateDruidQuery supports only ZonelessTimeGrains.
|
TemplateDruidQuery |
TemplateDruidQuery.withGranularity(ZonelessTimeGrain newTimeGrain)
Makes a copy of the template query and any sub query(s), changing time grain on the outermost level only.
|
TemplateDruidQuery |
TemplateDruidQuery.withInnermostDataSource(DataSource dataSource) |
TemplateDruidQuery |
TemplateDruidQuery.withInnerQuery(TemplateDruidQuery newNestedQuery)
Makes a copy of the template query, changing nested query.
|
TemplateDruidQuery |
TemplateDruidQuery.withIntervals(Collection<org.joda.time.Interval> intervals) |
TemplateDruidQuery |
TemplateDruidQuery.withPostAggregations(Collection<PostAggregation> newPostAggregations)
Makes a copy of the template query and any sub query(s), changing post-aggregations.
|
Modifier and Type | Method and Description |
---|---|
Optional<TemplateDruidQuery> |
TemplateDruidQuery.getInnerQuery() |
Modifier and Type | Method and Description |
---|---|
TemplateDruidQuery |
TemplateDruidQuery.merge(TemplateDruidQuery sibling)
Merges two template queries into one.
|
TemplateDruidQuery |
TemplateDruidQuery.withInnerQuery(TemplateDruidQuery newNestedQuery)
Makes a copy of the template query, changing nested query.
|
Constructor and Description |
---|
LogicalMetric(TemplateDruidQuery templateDruidQuery,
ResultSetMapper calculation,
LogicalMetricInfo logicalMetricInfo)
Constructor.
|
LogicalMetric(TemplateDruidQuery templateDruidQuery,
ResultSetMapper calculation,
String name)
Deprecated.
Properties, such as name, of LogicalMetric is stored in a unified object called
LogicalMetricInfo . Use new constructor
LogicalMetric.LogicalMetric(TemplateDruidQuery, ResultSetMapper, LogicalMetricInfo) instead. |
LogicalMetric(TemplateDruidQuery templateDruidQuery,
ResultSetMapper calculation,
String name,
String description)
Deprecated.
Properties, such as name, of LogicalMetric is stored in a unified object called
LogicalMetricInfo . Use new constructor
LogicalMetric.LogicalMetric(TemplateDruidQuery, ResultSetMapper, LogicalMetricInfo) instead. |
LogicalMetric(TemplateDruidQuery templateDruidQuery,
ResultSetMapper calculation,
String name,
String longName,
String category,
String description)
Deprecated.
Properties, such as name, of LogicalMetric is stored in a unified object called
LogicalMetricInfo . Use new constructor
LogicalMetric.LogicalMetric(TemplateDruidQuery, ResultSetMapper, LogicalMetricInfo) instead. |
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.
|
Modifier and Type | Method and Description |
---|---|
Granularity |
RequestQueryGranularityResolver.apply(DataApiRequest request,
TemplateDruidQuery templateDruidQuery) |
Granularity |
RequestQueryGranularityResolver.resolveAcceptingGrain(DataApiRequest apiRequest,
TemplateDruidQuery query)
Get the a granularity which must be satisfied by any answering table granularity for this request.
|
Constructor and Description |
---|
QueryPlanningConstraint(DataApiRequest dataApiRequest,
TemplateDruidQuery templateDruidQuery)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
TemplateDruidQuery |
FilteredSketchMetricsHelper.updateOuterQuery(TemplateDruidQuery outerQuery,
Map<String,String> oldFieldNameToNewFieldNameMap)
Deprecated.
A method to update outer query aggregations & postAggregations.
|
TemplateDruidQuery |
MetricsFilterSetBuilder.updateOuterQuery(TemplateDruidQuery outerQuery,
Map<String,String> oldFieldNameToNewFieldNameMap)
A method to update outer query aggregations and postAggregations.
|
TemplateDruidQuery |
FilteredThetaSketchMetricsHelper.updateOuterQuery(TemplateDruidQuery outerQuery,
Map<String,String> oldFieldNameToNewFieldNameMap) |
TemplateDruidQuery |
FilteredSketchMetricsHelper.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Deprecated.
|
TemplateDruidQuery |
MetricsFilterSetBuilder.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Method to update a given query by changing aggregators to filteredAggregators and updating postAggs to reference
the filteredAggregators.
|
TemplateDruidQuery |
FilteredThetaSketchMetricsHelper.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest) |
Modifier and Type | Method and Description |
---|---|
TemplateDruidQuery |
FilteredSketchMetricsHelper.updateOuterQuery(TemplateDruidQuery outerQuery,
Map<String,String> oldFieldNameToNewFieldNameMap)
Deprecated.
A method to update outer query aggregations & postAggregations.
|
TemplateDruidQuery |
MetricsFilterSetBuilder.updateOuterQuery(TemplateDruidQuery outerQuery,
Map<String,String> oldFieldNameToNewFieldNameMap)
A method to update outer query aggregations and postAggregations.
|
TemplateDruidQuery |
FilteredThetaSketchMetricsHelper.updateOuterQuery(TemplateDruidQuery outerQuery,
Map<String,String> oldFieldNameToNewFieldNameMap) |
TemplateDruidQuery |
FilteredSketchMetricsHelper.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Deprecated.
|
TemplateDruidQuery |
MetricsFilterSetBuilder.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest)
Method to update a given query by changing aggregators to filteredAggregators and updating postAggs to reference
the filteredAggregators.
|
TemplateDruidQuery |
FilteredThetaSketchMetricsHelper.updateTemplateDruidQuery(TemplateDruidQuery query,
com.fasterxml.jackson.databind.JsonNode metricFilterObject,
DimensionDictionary dimensionDictionary,
LogicalTable table,
DataApiRequest apiRequest) |
Copyright © 2016–2018 Yahoo! Inc.. All rights reserved.