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 massive update on a cassandra table. PK is page, country
and id. BUT im having problems with step column and null values.
This works OK when step has a value but not when is null.
Any idea?

Reply via email to