code: protected List<Metric> filter(List<Metric> metrics) {
      final List<Metric> filtered = metrics.stream().filter(this::shouldIncludeMetric)
          .collect(Collectors.toList());
      LOGGER.debug("Filter: input {} metrics, output {} metrics",
          metrics.size(), filtered.size());
      return filtered;
    }
docs: Return metrics to be sent to the main atlas deployment.
  Metrics will be sent if their publishing policy matches atlas and if they
  will *not* be sent to the aggregation cluster.