public static MySqlRecords forRecords(
            final String splitId, final Iterator<SourceRecord> recordsForSplit) {
        return new MySqlRecords(splitId, recordsForSplit, Collections.emptySet());
    }
An implementation of {@link RecordsWithSplitIds} which contains the records of one table split.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/split/MySqlRecords.java