我想從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" ))
uj5u.com熱心網友回復：
foreachPartitionuj5u.com熱心網友回復：
不知樓主具體應用場景。直接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）
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/44182.html
標籤：Spark