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 index f7913aac..9bb6d9d3 100644 --- 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() } }