@Override
  public void exportPageFinished(
      DataVertical dataType,
      String service,
      boolean success,
      Duration duration) {
    TagContext tctx = tagger.emptyBuilder()
        .put(KEY_DATA_TYPE, TagValue.create(dataType.getDataType()), TAG_METADATA)
        .put(KEY_EXPORT_SERVICE, TagValue.create(service), TAG_METADATA)
        .put(KEY_SUCCESS, TagValue.create(Boolean.toString(success)), TAG_METADATA)
        .build();
    try (Scope ss = tagger.withTagContext(tctx)) {
      STATS_RECORDER.newMeasureMap()
          .put(EXPORT_PAGE, 1)
          .put(EXPORT_PAGE_DURATION, duration.toMillis())
          .record();
    }
  }
A {@link DtpInternalMetricRecorder} that writes metrics to Stackdriver.
*
extensions/cloud/portability-cloud-google/src/main/java/org/datatransferproject/cloud/google/GoogleDtpInternalMetricRecorder.java