public void reportEnd(Status status) throws SemanticException {
    if (isEnabled) {
      LOG.info("End {}", status );
      Progress progress = replicationMetric.getProgress();
      progress.setStatus(status);
      replicationMetric.setProgress(progress);
      metricCollector.addMetric(replicationMetric);
    }
  }
Abstract class for Replication Metric Collection.
ql/src/java/org/apache/hadoop/hive/ql/parse/repl/metric/ReplicationMetricCollector.java