Merge pull request #100 from varshamahuli97/cbrelease-4.8.13.1

storing nps feeds to a backup table for analysis
sunbird-cb · May 17, 2024 · 06e0679 · 06e0679
2 parents 515bb07 + 9fa57ba
commit 06e0679
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/batch-models/src/main/scala/org/ekstep/analytics/dashboard/survey/nps/NpsModel.scala b/batch-models/src/main/scala/org/ekstep/analytics/dashboard/survey/nps/NpsModel.scala
@@ -65,6 +65,13 @@ object NpsModel extends AbsDashboardModel {
       .options(Map("keyspace" -> conf.cassandraUserFeedKeyspace , "table" -> conf.cassandraUserFeedTable))
       .mode("append")
       .save()
+
+    // write the dataframe to cassandra user_feed_backup table
+    additionalDF.write
+      .format("org.apache.spark.sql.cassandra")
+      .options(Map("keyspace" -> "sunbird_notifications" , "table" -> "notification_feed_backup"))
+      .mode("append")
+      .save()
   }
 
 }