DataframeByRow.scala

case class Person(name: String, age: Long, ttl: Long)

val caseClassDF = Seq(Person("Andy", 32, 5000000), Person("Mark", 27, 1000000)).toDF()

caseClassDF.show()
// +----+---+-------+
// |name|age|    ttl|
// +----+---+-------+
// |Andy| 32|5000000|
// |Mark| 27|1000000|
// +----+---+-------+

// With Table:
// CREATE TABLE IF NOT EXISTS test.person (
//     name BIGINT, 
//     age BIGINT, 
//     PRIMARY KEY (name, age)
// )

caseClassDF.write
           .format("org.apache.spark.sql.cassandra")
           .options(Map( "table" -> "words_copy", "keyspace" -> "test", "ttl_column" -> "ttl"))
           .save()