private Collector<RowData> createMetricsCollector(SourceRecord record, Collector<RowData> out) {
        MetricsCollector<RowData> collector = new MetricsCollector<>(out, cdcExactlyMetric);
        collector.resetTimestamp((Long) ((Struct) record.value()).get(FieldName.TIMESTAMP));
        return collector;
    }
Create a metrics collector to collect metrics data and reset timestamp from source record
@param record source record
@param out output collector
@return metrics collector
inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/RowDataDebeziumDeserializeSchema.java