ChengJie1053 commented on code in PR #3456:
URL: https://github.com/apache/flink-cdc/pull/3456#discussion_r1678659166
##########
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/metrics/MySqlSourceReaderMetrics.java:
##########
@@ -18,17 +18,42 @@
package org.apache.flink.cdc.connectors.mysql.source.metrics;
import org.apache.flink.cdc.connectors.mysql.source.reader.MySqlSourceReader;
+import org.apache.flink.metrics.Counter;
import org.apache.flink.metrics.Gauge;
import org.apache.flink.metrics.MetricGroup;
import org.apache.flink.runtime.metrics.MetricNames;
+import io.debezium.relational.TableId;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
/** A collection class for handling metrics in {@link MySqlSourceReader}. */
public class MySqlSourceReaderMetrics {
public static final long UNDEFINED = -1;
private final MetricGroup metricGroup;
+ public static final String IO_NUM_RECORDS_OUT_SNAPSHOT =
".numRecordsOutBySnapshot";
+
+ public static final String IO_NUM_RECORDS_OUT_DATA_CHANGE_EVENT_INSERT =
+ ".numRecordsOutByDataChangeEventInsert";
+
+ public static final String IO_NUM_RECORDS_OUT_DATA_CHANGE_EVENT_DELETE =
+ ".numRecordsOutByDataChangeEventDelete";
+
+ public static final String IO_NUM_RECORDS_OUT_DATA_CHANGE_EVENT_UPDATE =
+ ".numRecordsOutByDataChangeEventUpdate";
Review Comment:
Ok, thank you for helping me review the code, I will remove (.)
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
