Why userDS is Dataset[Any], instead of Dataset[Teamuser]? Appreciate
your help. Thanks
val spark = SparkSession
.builder
.config("spark.cassandra.connection.host", cassandrahost)
.appName(getClass.getSimpleName)
.getOrCreate()
import spark.implicits._
val sqlContext = spark.sqlContext
import sqlContext.implicits._
case class Teamuser(teamid:String, userid:String, role:String)
spark
.read
.format("org.apache.spark.sql.cassandra")
.options(Map("keyspace" -> "test", "table" -> "teamuser"))
.load
.createOrReplaceTempView("teamuser")
val userDF = spark.sql("SELECT teamid, userid, role FROM teamuser")
userDF.show()
val userDS:Dataset[Teamuser] = userDF.as[Teamuser]
