protected boolean shouldIgnore(String group, String metricName) {
    boolean isBlacklisted = this.blacklist.isPresent();
    String fullMetricName = group + "." + metricName;

    if (isBlacklisted && !this.blacklistedMetrics.contains(fullMetricName)) {
      if (this.blacklist.get().matcher(fullMetricName).matches()) {
        this.blacklistedMetrics.add(fullMetricName);
        LOG.debug("Samza diagnostics: blacklisted metric {} because it matched blacklist regex: {}", fullMetricName,
            this.blacklist.get());
      } else {
        isBlacklisted = false;
      }
    }
    return isBlacklisted;
  }
MetricsSnapshotReporter is a generic metrics reporter that sends metrics to a stream.

jobName // my-samza-job
jobId // an id that differentiates multiple executions of the same job
taskName // container_567890
host // eat1-app128.gird
version // 0.0.1
blacklist // Regex of metrics to ignore when flushing
samza-core/src/main/java/org/apache/samza/metrics/reporter/MetricsSnapshotReporter.java