From c848546479b8e993042e7734cdde39a312e0910f Mon Sep 17 00:00:00 2001 From: PeterZh6 Date: Mon, 14 Oct 2024 16:00:17 +0800 Subject: [PATCH] chore: add comment for a builder of metricOption --- .../apache/inlong/sort/mongodb/source/MongoDBSourceBuilder.java | 1 + 1 file changed, 1 insertion(+) diff --git a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/source/MongoDBSourceBuilder.java b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/source/MongoDBSourceBuilder.java index e25a03034a0..07b0d9f1cf5 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/source/MongoDBSourceBuilder.java +++ b/inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/source/MongoDBSourceBuilder.java @@ -191,6 +191,7 @@ public MongoDBSourceBuilder deserializer(DebeziumDeserializationSchema des return this; } + /** The metric option used to collect metrics when inlong.metric.labels is present in flink sql. */ public MongoDBSourceBuilder metricOption(MetricOption metricOption) { this.metricOption = metricOption; return this;