My code :
val name = sc.textFile("/FileStore/tables/employeenames.csv")
case class x(ID:String,Employee_name:String)
val namePairRDD = name.map(_.split(",")).map(x => (x(0), x(1).trim.toString)).toDF("ID", "Employee_name")
namePairRDD.createOrRe...
I understand we can solve this in multiple ways. I am trying to solve this Question. Hence i am following the flow.
Write the missing Spark SQL queries to join all the three tables, sort the table, and display the output in the given format: ID, Na...