public void resetTimestamp(long timestampMillis) {
        this.timestampMillis = timestampMillis;
    }
sending metrics each time a record is collected.
@param <T>
inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/MetricsCollector.java