JNSimba commented on code in PR #199:
URL:
https://github.com/apache/doris-flink-connector/pull/199#discussion_r1336763203
##########
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/ParsingProcessFunction.java:
##########
@@ -62,4 +63,23 @@ public static OutputTag<String> createRecordOutputTag(String
tableName) {
return new OutputTag<String>("record-" + tableName) {
};
}
+
+ public String recordConvert(String record) throws Exception {
+ JsonNode recordRoot = objectMapper.readValue(record, JsonNode.class);
Review Comment:
When the switch is turned off, there is no need to process the record,
because traversing the data here may cause a loss of performance.
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
