dfFromMongo.scala

import com.mongodb.spark._
 
val database = "sample_mflix"
val collection = "comments"
 
val movieCommetsDF = (
    spark.read
    .format("com.mongodb.spark.sql.DefaultSource")
    .option("database", database)
    .option("collection", collection)
    .load()
)