併發刪除，並使用星火

Question

使用火花卡桑德拉連接器使用下面的代碼，我救了我的預測結果爲卡桑德拉DB插入卡桑德拉：

CassandraJavaUtil.javaFunctions(sensorDataRDD).writerBuilder(modelParamter.keyspace, "sensor_data_2", 
       CassandraJavaUtil.mapToRow(SensorData2Double.class)).saveToCassandra(); 

的數據是基於秒標度的時間戳記。因此，預測的文字可以按小時縮放。我需要先刪除所有以前的記錄。刪除應該發生在Cassandra表中的一個特殊列上，並提供其唯一鍵。

我不知道如何刪除所有以前的記錄，以確保當我使用上面的java代碼插入新記錄時，他們不會被我的cassandra刪除查詢後刪除。

當我刪除或插入行（主鍵）時，Cassandra列上是否有任何原子性？

Answer 1

爲什麼需要刪除以前的數據？

如果您正在爲相同的密鑰寫入新數據，它將被簡單覆蓋。

如果不想刪除「新」數據，您可以檢查該值的寫入時間（寫入時間函數），如果它足夠新鮮 - 不要刪除它。