e-mhui commented on code in PR #7750:
URL: https://github.com/apache/inlong/pull/7750#discussion_r1173549371
##########
inlong-sort/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/split/MySqlSplitSerializer.java:
##########
@@ -104,6 +104,38 @@ public static Map<TableId, TableChange>
readTableSchemas(int version, DataInputD
return tableSchemas;
}
+ public static void writeTableDdls(
+ Map<TableId, String> tableDdls, DataOutputSerializer out) throws
IOException {
+ final int size = tableDdls.size();
+ out.writeInt(size);
+ for (Map.Entry<TableId, String> entry : tableDdls.entrySet()) {
+ out.writeUTF(entry.getKey().toString());
+ out.writeUTF(entry.getValue());
+ }
+ }
+
+ public static Map<TableId, String> readTableDdls(int version,
DataInputDeserializer in)
+ throws IOException {
+ Map<TableId, String> tableDdls = new HashMap<>();
+ final int size = in.readInt();
+ for (int i = 0; i < size; i++) {
+ TableId tableId = TableId.parse(in.readUTF());
Review Comment:
Thanks, it has been fixed.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
