spark基于column for dataframe api使用ttl写入cassandra

zpf6vheq  于 2021-06-10  发布在  Cassandra
关注(0)|答案(0)|浏览(355)

我们是否有基于时间戳列使用ttl值写入cassandra的选项。我看到在rdd中,我们可以选择根据列使用不同的ttl进行编写。这对于DataFrameAPI也是一样的。
我有一个Dataframe如下:

stime          Name
2019-12-24     abc  
2019-12-30     xyz

通常,cassandra根据加载时间清除/删除行(如果ttl为60,则加载60秒后数据将被删除)我希望根据stime列删除记录。如果ttl为7天,则即使我同时加载了两行,也应该只删除行。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题