com.yahoo.bard.webservice.druid.model.query

Class WeightEvaluationQuery

java.lang.Object

com.yahoo.bard.webservice.druid.model.query.AbstractDruidQuery<Q>

com.yahoo.bard.webservice.druid.model.query.AbstractDruidFactQuery<Q>

com.yahoo.bard.webservice.druid.model.query.AbstractDruidAggregationQuery<GroupByQuery>

com.yahoo.bard.webservice.druid.model.query.GroupByQuery

com.yahoo.bard.webservice.druid.model.query.WeightEvaluationQuery

All Implemented Interfaces:

DruidAggregationQuery<GroupByQuery>, DruidFactQuery<GroupByQuery>, DruidQuery<GroupByQuery>

public class WeightEvaluationQuery
extends GroupByQuery

Query to generate weight to evaluate the query.

Calculates # of sketches times the number rows which will be in result set

  {
    "queryType": "groupBy",
    "dataSource": {
      "query": {
        "queryType": "groupBy",
        "dataSource": {
          "name": "basefact_network",
          "type": "table"
        },
        "dimensions": [
          "user_device_type",
          "pty_country",
          "device_type_id"
        ],
        "aggregations": [
          {
            "name": "ignored",
            "type": "count"
          }
        ],
        "postAggregations": [
          {
            "type": "constant",
            "name": "count",
            "value": 2
          }
        ],
        "intervals": [
          "2014-09-01T00:00:00.000Z/2014-09-30T00:00:00.000Z"
        ],
        "granularity": {
          "type": "period",
          "period": "P1D"
        }
      },
      "type": "query"
    },
    "dimensions": [],
    "aggregations": [
      {
        "name": "count",
        "fieldName": "count",
        "type": "longSum"
      }
    ],
    "postAggregations": [],
    "intervals": [
      "2014-09-01T00:00:00.000Z/2014-09-30T00:00:00.000Z"
    ],
    "granularity": "all"
  }
 

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_DRUID_TOP_N_THRESHOLD

Fields inherited from class com.yahoo.bard.webservice.druid.model.query.AbstractDruidAggregationQuery

aggregations, dimensions, postAggregations

Fields inherited from class com.yahoo.bard.webservice.druid.model.query.AbstractDruidFactQuery

filter, granularity, intervals

Fields inherited from class com.yahoo.bard.webservice.druid.model.query.AbstractDruidQuery

context, dataSource, queryType

Constructor Summary

Constructors

Constructor and Description
WeightEvaluationQuery(DruidAggregationQuery<?> query, int weight) Generate a query that calculates the even weight of the response cardinality of the given query.

Method Summary

Modifier and Type	Method and Description
Granularity	getGranularity() Returns the time grain (granularity) of the query.
static long	getWorstCaseWeightEstimate(DruidAggregationQuery<?> query) Evaluate Druid query for worst possible case expensive aggregation that could bring down Druid.
static WeightEvaluationQuery	makeWeightEvaluationQuery(DruidAggregationQuery<?> query) Evaluate Druid query for expensive aggregation that could bring down Druid.

Methods inherited from class com.yahoo.bard.webservice.druid.model.query.GroupByQuery

getHaving, getLimitSpec, withAggregations, withAllIntervals, withContext, withDataSource, withDimensions, withFilter, withGranularity, withHaving, withInnermostDataSource, withIntervals, withLimitSpec, withOrderBy, withPostAggregations

Methods inherited from class com.yahoo.bard.webservice.druid.model.query.AbstractDruidAggregationQuery

getAggregations, getDimensions, getPostAggregations

Methods inherited from class com.yahoo.bard.webservice.druid.model.query.AbstractDruidFactQuery

getFilter, getIntervals

Methods inherited from class com.yahoo.bard.webservice.druid.model.query.AbstractDruidQuery

getContext, getDataSource, getQueryType

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.yahoo.bard.webservice.druid.model.query.DruidAggregationQuery

buildSchemaColumns, getDependentFieldNames, getInnermostQuery, getInnerQuery, getMetricDimensions

Methods inherited from interface com.yahoo.bard.webservice.druid.model.query.DruidFactQuery

getFilter, getIntervals

Methods inherited from interface com.yahoo.bard.webservice.druid.model.query.DruidQuery

getContext, getDataSource, getQueryType

Field Detail

DEFAULT_DRUID_TOP_N_THRESHOLD

public static final long DEFAULT_DRUID_TOP_N_THRESHOLD

See Also:

Constant Field Values

Constructor Detail

WeightEvaluationQuery

public WeightEvaluationQuery(DruidAggregationQuery<?> query,
                             int weight)

Generate a query that calculates the even weight of the response cardinality of the given query.

Parameters:

query - Query to calculate the weighted response cardinality of

weight - Weight to apply to each response row

Method Detail

getGranularity

public Granularity getGranularity()

Description copied from interface: DruidFactQuery

Returns the time grain (granularity) of the query.

Specified by:

getGranularity in interface DruidFactQuery<GroupByQuery>

Overrides:

getGranularity in class AbstractDruidFactQuery<GroupByQuery>

Returns:

the query time grain

makeWeightEvaluationQuery

public static WeightEvaluationQuery makeWeightEvaluationQuery(DruidAggregationQuery<?> query)

Evaluate Druid query for expensive aggregation that could bring down Druid.

Parameters:

query - Druid Query

Returns:

query or null if not required

getWorstCaseWeightEstimate

public static long getWorstCaseWeightEstimate(DruidAggregationQuery<?> query)

Evaluate Druid query for worst possible case expensive aggregation that could bring down Druid.

Number of Sketches * # of periods in iteration * cardinality of each dimension values

Parameters:

query - The base query being estimated

Returns:

worst case rows

Throws:

ArithmeticException - if the estimate is larger than Long.MAX_VALUE