Method mergeAndReturnResults

src/core/MultiGetQuery.java:796–836

()

  }

  private void mergeAndReturnResults() throws Exception {
    final long hbase_time = DateTime.currentTimeMillis();
    TsdbQuery.scanlatency.add((int) (hbase_time - fetch_start_time));
    if (LOG.isDebugEnabled()) {
      LOG.debug("Finished fetching data for metric: " + Bytes.pretty(metric)
      + " using " + (hbase_time - fetch_start_time) + "ms");
    }
    LOG.info("Finished fetching data for metric: " + Bytes.pretty(metric)
    + " using " + (hbase_time - fetch_start_time) + "ms");
    if (exception != null) {
      LOG.error("After all of the multi-gets finished, at "
          + "least one threw an exception", exception);
      throw exception;
    }

    final long merge_start = DateTime.nanoTime();

    // Merge sorted spans together
    if (!isHistogramScan()) {
      mergeDataPoints();
    } else {
      // Merge histogram data points
      mergeHistogramDataPoints();
    }

    if (LOG.isDebugEnabled()) {
      LOG.debug("It took " + (DateTime.currentTimeMillis() - hbase_time) + " ms, "
          + " to merge and sort the rows into a tree map");
    }

    if (query_stats != null) {
      query_stats.addStat(query_index, QueryStat.SCANNER_MERGE_TIME, 
          (DateTime.nanoTime() - merge_start));
    }

    if (!isHistogramScan()) {
      results.callback(spans);
    } else {
      histogramResults.callback(histogramSpans);
    }
  }

  private boolean isHistogramScan() {
    return histogramSpans != null;