#000: Review comment fix - Generation of metrics

Sanketika-Obsrv · Jan 3, 2025 · e322419 · e322419
1 parent 180cbb7
commit e322419
Showing 1 changed file with 3 additions and 2 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
@@ -26,8 +26,8 @@ class RowDataConverterFunction(config: HudiConnectorConfig, datasetId: String) e
   // Logger for logging
   private val logger = LoggerFactory.getLogger(classOf[RowDataConverterFunction])
 
-  protected val metricsList: MetricsList = getMetricsList()
-  protected val metrics: Metrics = registerMetrics(metricsList.datasets, metricsList.metrics)
+  private val metricsList: MetricsList = getMetricsList()
+  private val metrics: Metrics = registerMetrics(metricsList.datasets, metricsList.metrics)
 
 
 
@@ -51,6 +51,7 @@ class RowDataConverterFunction(config: HudiConnectorConfig, datasetId: String) e
 
   override def map(event: MMap[String, AnyRef]): RowData = {
     startTime = System.currentTimeMillis()
+    metrics.incCounter(datasetId, config.inputEventCountMetric)
     try {
       metrics.incCounter(datasetId, config.inputEventCountMetric, event.size)
       val rowData = convertToRowData(event)