Method mergeDataPoints

src/core/MultiGetQuery.java:899–963

()

  }

  private void mergeDataPoints() {
    for (List<KeyValue> kvs : kvsmap.values()) {
      if (kvs == null || kvs.isEmpty()) {
        LOG.error("Found a key value list that was null or empty");
        continue;
      }
      for (final KeyValue kv : kvs) {

        if (kv == null) {
          LOG.error("Found a key value item that was null");
          continue;
        }
        if (kv.key() == null) {
          LOG.error("A key for a kv was null");
          continue;
        }

        Span datapoints = null;
        try {
          datapoints = spans.get(kv.key());
        } catch (RuntimeException e) {
          LOG.error("Failed to fetch the span", e);
        }

        // If this tsdb follows append logic, then there will not be any
        // duplicates here. But if it is not, then there can be multiple
        // non-compcated or out of order rows here
        if (datapoints == null) {
          datapoints = RollupQuery.isValidQuery(rollup_query) 
              ? new RollupSpan(tsdb, rollup_query)
                  : new Span(tsdb);
              spans.put(kv.key(), datapoints);
        }

        if (annotMap.containsKey(kv.key())) {
          for (Annotation note : annotMap.get(kv.key())) {
            datapoints.getAnnotations().add(note);
          }
          annotMap.remove(kv.key());
        }
        try {
          datapoints.addRow(kv);
        } catch (RuntimeException e) {
          LOG.error("Exception adding row to span", e);
        }
      }
    }

    kvsmap.clear();

    for (byte[] key : annotMap.keySet()) {
      Span datapoints = (Span) spans.get(key);

      if (datapoints == null) {
        datapoints = new Span(tsdb);
        spans.put(key, datapoints);
      }