gong commented on code in PR #7085:
URL: https://github.com/apache/inlong/pull/7085#discussion_r1058183023
##########
inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/metric/sub/SinkTableMetricData.java:
##########
@@ -204,6 +204,40 @@ public void outputMetricsWithEstimate(Object data) {
invoke(1, size);
}
+ /**
+ * output dirty metrics
+ *
+ * @param database the database name of record
+ * @param schema the schema name of record
+ * @param table the table name of record
+ * @param isSnapshotRecord is it snapshot record
+ * @param rowCount the row count of records
+ * @param rowSize the row size of records
+ */
+ public void outputDirtyMetrics(String database, String schema, String
table, boolean isSnapshotRecord,
+ long rowCount, long rowSize) {
Review Comment:
isSnapshotRecord is useless. It is only used for sourcemetric
--
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...@inlong.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
