public long getCurrentLatency() {
    return currentLatency;
  }
A generator that generates the latency metrics of the writing operators in flink applications.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/metric/MetricsGenerator.java