#000: Review comment fix - Generation of metrics

Sanketika-Obsrv · Jan 3, 2025 · e7c281d · e7c281d
1 parent 6ae728a
commit e7c281d
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/...e/hudi-connector/src/main/scala/org/sunbird/obsrv/function/RowDataConverterFunction.scala b/...e/hudi-connector/src/main/scala/org/sunbird/obsrv/function/RowDataConverterFunction.scala
@@ -56,6 +56,16 @@ class RowDataConverterFunction(config: HudiConnectorConfig, datasetId: String) e
 
       // Convert the event data into RowData for further processing
       val rowData = convertToRowData(event)
+
+      logger.info("Metric inputEventCount: " + inputEventCount)
+      logger.info("Metric failedEventCount: " + failedEventCount)
+
+      logger.info("Before increment: inputEventCount=" + inputEventCount.getCount)
+      inputEventCount.inc()
+      logger.info("After increment: inputEventCount=" + inputEventCount.getCount)
+
+
+
       rowData
     } catch {
       case ex: Exception =>