从spark中如何 update cassandra数据表？

Question

我想从spark中的计算结果存入cassandra，但是得使用update语句，哪位大神指导如何使用update语句更新表？例子如下：在saveToCassandra 地方能否有update的方法？lines.map( x=>((x._1,x._7),(x._5,x._6)) )
                .reduceByKey((x,y) => (x._1+y._1,x._2+y._2))
                .map(x=>(x._1._1, x._1._2, x._2._1,x._2._2))
                .saveToCassandra("casdemo",  "logt_stats", SomeColumns("accesstime","name", "count","bytes" ))
               

Answer 1

foreachPartition

Answer 2

不知楼主具体应用场景。
直接saveToCassandra的时候，数据包含原表的主键一致插入就相当于更新了。
如原表为
id， name ， age
1      Li           18
2      Wang     20
PrimaryKey（id）1  Zhang  22
直接插入somecolumn（id，name，age） 
就更新为：
id， name ， age
1     Zhang     22
2      Wang     20
PrimaryKey（id）