Method call

src/core/TsdbQuery.java:1372–1422

Creates the SpanGroups to form the final results of this query. @param spans The Spans found for this query (#findSpans). Can be null, in which case the array returned will be empty. @return A possibly empty array of SpanGroups built according to any 'GROUP BY

(final DataPoints[] datapoints)

     * any 'GROUP BY' formulated in this query.
     */
     public Deferred<DataPoints[]> call(final DataPoints[] datapoints) throws Exception {
      //TODO review this logic during spatial aggregation implementation
       
      if (datapoints == NO_RESULT && RollupQuery.isValidQuery(rollup_query)) {
        //There are no datapoints for this query and it is a rollup query
        //but not the default interval (default interval means raw).
        //This will prevent redundant scan on raw data on the presense of
        //default rollup interval
        
        //If the rollup usage is to fallback directly to raw data
        //then nullyfy the rollup query, so that the recursive scan will use
        //raw data and this will not called again because of isValida check
        //If the rollup usage is to fallback to next best match then pupup
        //next best match and attach that to the rollup query
        if (rollup_usage == ROLLUP_USAGE.ROLLUP_FALLBACK_RAW) {
          transformRollupQueryToDownSampler();
          return runAsync();
        }
        else if (best_match_rollups != null && best_match_rollups.size() > 0) {
          RollupInterval interval = best_match_rollups.remove(0);
          
          if (interval.isDefaultInterval()) {
            transformRollupQueryToDownSampler();
          }
          else {
            rollup_query = new RollupQuery(interval, 
                  rollup_query.getRollupAgg(),
                  rollup_query.getSampleIntervalInMS(),
                  aggregator);
            //Here the requested sampling rate will be higher than
            //resulted result. So downsample it
            if (!rollup_query.isLowerSamplingRate()) {
//               sample_interval_ms = rollup_query.getSampleIntervalInMS();
//               downsampler = rollup_query.getRollupAgg();
              // TODO - default fill
              downsampler = new DownsamplingSpecification(
                  rollup_query.getSampleIntervalInMS(), 
                  rollup_query.getRollupAgg(),
                  (downsampler != null ? downsampler.getFillPolicy() : 
                    FillPolicy.ZERO));
            }
          }
          
          return runAsync();
        }
        return Deferred.fromResult(NO_RESULT);
      }
      else {
        return Deferred.fromResult(datapoints);
      }
    }
  }
  
  /**