storing nps feeds to a backup table for analysis

sunbird-cb · May 17, 2024 · c024bdb · c024bdb
1 parent fc052c3
commit c024bdb
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
@@ -63,6 +63,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()
   }
 
 }