public void register(String source) {
    if (systemName.equals(source)) {
      // source is the same as the system name. creating counters for source name will double count metrics
      LOG.warn("Source:{} is the same as the system name.", source);
      return;
    }
    sourceMetricsMap.putIfAbsent(source, new AzureBlobBasicMetrics(source, metricsRegistry));
  }
Adds a AzureBlobBasicMetrics object for the source being registered with the SystemProducer.
@param source to be registered.
samza-azure/src/main/java/org/apache/samza/system/azureblob/producer/AzureBlobSystemProducerMetrics.java