Method findSpans

src/core/TsdbQuery.java:860–898

Finds all the Spans that match this query. This is what actually scans the HBase table and loads the data into Spans. @return A map from HBase row key to the Span for that row key. Since a Span actually contains multiple HBase rows, the row key stored in the map has i

()

   * @throws IllegalArgumentException if bad data was retrieved from HBase.
   */
  private Deferred<SortedMap<byte[], Span>> findSpans() throws HBaseException {
    final short metric_width = tsdb.metrics.width();
    final TreeMap<byte[], Span> spans = // The key is a row key from HBase.
      new TreeMap<byte[], Span>(new SpanCmp(
          (short)(Const.SALT_WIDTH() + metric_width)));
    
    // Copy only the filters that should trigger a tag resolution. If this list
    // is empty due to literals or a wildcard star, then we'll save a TON of
    // UID lookups
    final List<TagVFilter> scanner_filters;
    if (filters != null) {   
      scanner_filters = new ArrayList<TagVFilter>(filters.size());
      for (final TagVFilter filter : filters) {
        if (filter.postScan()) {
          scanner_filters.add(filter);
        }
      }
    } else {
      scanner_filters = null;
    }
    
    if (Const.SALT_WIDTH() > 0) {
      final List<Scanner> scanners = new ArrayList<Scanner>(Const.SALT_BUCKETS());
      for (int i = 0; i < Const.SALT_BUCKETS(); i++) {
        scanners.add(getScanner(i));
      }
      scan_start_time = DateTime.nanoTime();
      return new SaltScanner(tsdb, metric, scanners, spans, scanner_filters,
          delete, rollup_query, query_stats, query_index, null, 
          max_bytes, max_data_points).scan();
    } else {
      final List<Scanner> scanners = new ArrayList<Scanner>(1);
      scanners.add(getScanner(0));
      scan_start_time = DateTime.nanoTime();
      return new SaltScanner(tsdb, metric, scanners, spans, scanner_filters,
          delete, rollup_query, query_stats, query_index, null, max_bytes, 
          max_data_points).scan();
    }
  }
  
  private Deferred<SortedMap<byte[], Span>> findSpansWithMultiGetter() throws HBaseException {
    final short metric_width = tsdb.metrics.width();