@Override
  public void startedJob(DataVertical dataType, String exportService, String importService) {
    TagContext tctx = tagger.emptyBuilder()
        .put(KEY_DATA_TYPE, TagValue.create(dataType.getDataType()), TAG_METADATA)
        .put(KEY_EXPORT_SERVICE, TagValue.create(exportService), TAG_METADATA)
        .put(KEY_IMPORT_SERVICE, TagValue.create(importService), TAG_METADATA)
        .build();
    try (Scope ss = tagger.withTagContext(tctx)) {
      STATS_RECORDER.newMeasureMap().put(JOB_STARTED, 1).record();
    }
  }
A {@link DtpInternalMetricRecorder} that writes metrics to Stackdriver.
*
extensions/cloud/portability-cloud-google/src/main/java/org/datatransferproject/cloud/google/GoogleDtpInternalMetricRecorder.java