In [29]:
import org.apache.spark.sql.cassandra._
In [30]:
val df = spark.read.format("org.apache.spark.sql.cassandra").options(Map( "table" -> "words", "keyspace" -> "test")).load() // This Dataset will use a spark.cassandra.input.size of 128
In [31]:
df.show()