Hi all.
I have the following schema that I need to filter with spark sql
|-- msg_id: string (nullable = true)
|-- country: string (nullable = true)
|-- sent_ts: timestamp (nullable = true)
|-- marks: array (nullable = true)
||-- element: struct (containsNull = true)
|||-- namespace:
case class RowObj(page: Int, country: String, id: String, step: Int)
sc.cassandraTable[RowObj]("keyspace","table").map(row => row.copy(step =
8)).saveToCassandra("keyspace","table",SomeColumns("page","country","id","step"))
Hi guys. Im pretty new to spark and more on Scala.
Im trying to do a
