public void setAgeOfLastShippedOpByTable(long timestamp, String tableName) {
    long age = EnvironmentEdgeManager.currentTime() - timestamp;
    this.getSingleSourceSourceByTable()
      .computeIfAbsent(tableName, t -> CompatibilitySingletonFactory
        .getInstance(MetricsReplicationSourceFactory.class).getTableSource(t))
      .setLastShippedAge(age);
  }
Set the age of the last edit that was shipped group by table
@param timestamp write time of the edit
@param tableName String as group and tableName
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/MetricsSource.java