spectator-reg-atlas/src/main/java/com/netflix/spectator/atlas/impl/DataExpr.java [612:631]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      return new Aggregator() {
        private final Map<Map<String, String>, Aggregator> aggrs = new HashMap<>();

        @Override public void update(TagsValuePair p) {
          if (!shouldCheckQuery || af.query().matches(p.tags())) {
            Map<String, String> k = resultTags(p.tags());
            aggrs.computeIfAbsent(k, ks -> af.aggregator(ks, false)).update(p);
          }
        }

        @Override public Iterable<TagsValuePair> result() {
          return aggrs.values().stream()
              .flatMap(a -> StreamSupport.stream(a.result().spliterator(), false))
              .collect(Collectors.toList());
        }
      };
    }

    @Override public String toString() {
      final String keyList = String.join(",", keys);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



spectator-reg-atlas/src/main/java/com/netflix/spectator/atlas/impl/DataExpr.java [686:705]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
      return new Aggregator() {
        private final Map<Map<String, String>, Aggregator> aggrs = new HashMap<>();

        @Override public void update(TagsValuePair p) {
          if (!shouldCheckQuery || af.query().matches(p.tags())) {
            Map<String, String> k = resultTags(p.tags());
            aggrs.computeIfAbsent(k, ks -> af.aggregator(ks, false)).update(p);
          }
        }

        @Override public Iterable<TagsValuePair> result() {
          return aggrs.values().stream()
              .flatMap(a -> StreamSupport.stream(a.result().spliterator(), false))
              .collect(Collectors.toList());
        }
      };
    }

    @Override public String toString() {
      final String keyList = String.join(",", keys);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -