您可以通过使用 leftJoinWithCassandraTable ，然后用提取的数据添加输入数据，并将数据写回cassandra。
类似这样的内容（采用我自己的代码）：

// this case class is matching to Cassandra table & input data...
case class Data(....)
val data = ...data_that_you_received_and_casted_to_Data_case_class...
val joined = data.leftJoinWithCassandraTable[Data]("ks", "table")
// perform update of existing values, and prepare new data
val summed = joined.map({ case (n: Data, c: Option[Data]) =>
 c match {
   // if there is no data in Cassandra, just return input data
   case None => Data(n)
   // there is data in Cassandra, do the sum
   case Some(s) =>
     Data(..., n.neu + s.neu)}
})
// and write updated/new values
summed.saveToCassandra("ks", "table")

p、 我建议使用spark cassandra connector 2.5.0直接支持的spark结构化流媒体，以及所谓的Dataframe直接连接。当使用Dataframe时，您的代码会更简单，并且可能会更优化。