我使用Spark-Cassandra连接器1.1.0和Cassandra 2.0.12 .
我通过saveToCassandra（）Java API方法将RDD写入Cassandra .
有没有办法用连接器设置持久记录的TTL属性？
谢谢，
夏嘉曦
是的，我们可以做到 . 只需设置spark配置密钥“ spark.cassandra.output.ttl ” . 同时创建sparkConf对象 .
Note: Value should be in second
不幸的是，似乎没有办法用连接器的1.1.0版本（我知道） . 然而，在1.2.0-alpha3中有一种方法 .
saveToCassandra()是WriterBuilder的包装器，它有一个withTTL方法 . 而不是使用 saveToCassandra ，你可以使用 writerBuilder(keyspace,table,rowWriter).withTTL(seconds).saveToCassandra() .
saveToCassandra
writerBuilder(keyspace,table,rowWriter).withTTL(seconds).saveToCassandra()
2 回答
是的，我们可以做到 . 只需设置spark配置密钥“ spark.cassandra.output.ttl ” . 同时创建sparkConf对象 .
Note: Value should be in second
不幸的是，似乎没有办法用连接器的1.1.0版本（我知道） . 然而，在1.2.0-alpha3中有一种方法 .
saveToCassandra()是WriterBuilder的包装器，它有一个withTTL方法 . 而不是使用
saveToCassandra，你可以使用writerBuilder(keyspace,table,rowWriter).withTTL(seconds).saveToCassandra().