From 93bb78e280289528cbf28381574a496c83867143 Mon Sep 17 00:00:00 2001 From: Vivek-M-08 Date: Mon, 26 Jun 2023 16:20:57 +0530 Subject: [PATCH 1/2] updated comments --- .../ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala b/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala index 7143ab88..7816fd27 100644 --- a/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala +++ b/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala @@ -28,6 +28,9 @@ case class OnDemandDruidResponse(file: List[String], status: String, statusMsg: case class Metrics(totalRequests: Option[Int], failedRequests: Option[Int], successRequests: Option[Int]) object OnDemandDruidExhaustJob extends BaseReportsJob with Serializable with IJob with OnDemandBaseExhaustJob with BaseDruidQueryProcessor { + /** + * Define implicit variables and constants required for Job that is Job ID and name + */ implicit override val className: String = "org.sunbird.analytics.exhaust.OnDemandDruidExhaustJob" val jobId: String = "druid-dataset" @@ -46,6 +49,10 @@ object OnDemandDruidExhaustJob extends BaseReportsJob with Serializable with IJo implicit val frameworkContext: FrameworkContext = getReportingFrameworkContext() implicit val conf = spark.sparkContext.hadoopConfiguration + /** + * This code block performs job execution, metrics generation, error handling, and cleanup tasks, ensuring accurate measurement of job performance and logging of relevant information. + * Additionally, it dispatches metric events to a Kafka topic based on configuration settings, enabling further analysis and monitoring of the job's execution. + */ try { val res = CommonUtil.time(execute()); // generate metric event and push it to kafka topic From 232242718bf7168e5fe4889bb2a65f58a00befae Mon Sep 17 00:00:00 2001 From: Vivek-M-08 Date: Thu, 6 Jul 2023 13:09:18 +0530 Subject: [PATCH 2/2] updated comment line --- .../org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala b/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala index 7816fd27..3d9b8079 100644 --- a/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala +++ b/batch-models/src/main/scala/org/ekstep/analytics/exhaust/OnDemandDruidExhaustJob.scala @@ -29,7 +29,7 @@ case class Metrics(totalRequests: Option[Int], failedRequests: Option[Int], succ object OnDemandDruidExhaustJob extends BaseReportsJob with Serializable with IJob with OnDemandBaseExhaustJob with BaseDruidQueryProcessor { /** - * Define implicit variables and constants required for Job that is Job ID and name + * Define implicit variables and constants required for Job */ implicit override val className: String = "org.sunbird.analytics.exhaust.OnDemandDruidExhaustJob"