public void init()

in src/main/java/com/aliyun/dts/subscribe/clients/metrics/LogMetricsReporter.java [61:70]

• 10 lines of code
• 4 McCabe index (conditional complexity)

    public void init(List<KafkaMetric> initMetrics) {
        synchronized (lock) {
            for (KafkaMetric metric : initMetrics) {
                if (includeSet.isEmpty() || includeSet.contains(metric.metricName().name())) {
                    LOG.debug("Adding metric {}", metric.metricName());
                    metrics.put(metric.metricName(), metric);
                }
            }
        }
    }