Method Query

runtime/metricsview/executor/executor.go:335–481

Query executes the provided query against the metrics view.

(ctx context.Context, qry *metricsview.Query, executionTime *time.Time)

// Query executes the provided query against the metrics view.
func (e *Executor) Query(ctx context.Context, qry *metricsview.Query, executionTime *time.Time) (*drivers.Result, error) {
	if !e.security.CanAccess() {
		return nil, runtime.ErrForbidden
	}

	err := qry.Validate()
	if err != nil {
		return nil, err
	}

	// preserve the original limit, required in 2 phase comparison
	ogLimit := qry.Limit

	rowsCap, err := e.rewriteQueryEnforceCaps(qry)
	if err != nil {
		return nil, err
	}

	pivotAST, pivoting, err := e.rewriteQueryForPivot(qry)
	if err != nil {
		return nil, err
	}

	if err := e.RewriteQueryTimeRanges(ctx, qry, executionTime); err != nil {
		return nil, err
	}

	if err := e.enforceQueryLimits(qry); err != nil {
		return nil, err
	}

	if err := e.rewritePercentOfTotals(ctx, qry); err != nil {
		return nil, err
	}

	if err := e.rewriteQueryDruidExactify(ctx, qry); err != nil {
		return nil, err
	}

	// Check if a rollup table can satisfy the query; if so, use a synthetic spec pointing to it
	mvForAST := e.metricsView
	rollupSpec, err := e.rewriteQueryForRollup(ctx, qry)
	if err != nil {
		return nil, err
	}
	if rollupSpec != nil {
		mvForAST = rollupSpec
	}

	ast, err := metricsview.NewAST(mvForAST, e.security, qry, e.olap.Dialect())
	if err != nil {
		return nil, err
	}

	ok, err := e.rewriteTwoPhaseComparisons(ctx, qry, ast, ogLimit)
	if err != nil {
		return nil, err
	} // TODO if !ok then can log a warning that two phase comparison is not possible with a reason