我正在使用 Spark-Cassandra 连接器 1.1.0 和 Cassandra 2.0.12。
我通过 saveToCassandra() Java API 方法将 RDD 写入 Cassandra。
有没有办法使用连接器设置持久记录的 TTL 属性？
谢谢
谢
最佳答案
不幸的是，似乎没有办法使用 1.1.0 版本的连接器来执行此操作(据我所知)。不过 1.2.0-alpha3 中有一种方法。
saveToCassandra()是 WriterBuilder 的包装器，其中有 withTTL方法。您可以使用 writerBuilder(keyspace,table,rowWriter).withTTL(seconds).saveToCassandra()，而不是使用 saveToCassandra()。
关于cassandra - Spark 使用 TTL 保存到 Cassandra，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/28944720/