Я использую разъем Spark-Cassandra 1.1.0 с Cassandra 2.0.12.Спайк спасает Кассандру с TTL
Я пишу RDDs в Cassandra с помощью метода Java API saveToCassandra().
Есть ли способ установить свойство TTL сохраненных записей с помощью соединителя?
Спасибо,
Шай
К сожалению, это не похоже, есть способ сделать это (что я знаю) с версии 1.1.0 разъема. Однако в 1.2.0-alpha3 есть способ.
saveToCassandra() является оберткой над WriterBuilder, которая имеет метод withTTL. Вместо использования saveToCassandra вы можете использовать writerBuilder(keyspace,table,rowWriter).withTTL(seconds).saveToCassandra().
Да, мы можем сделать. Просто установите искровой конфигурационный ключ «spark.cassandra.output.ttl». Время создания объекта sparkConf.
Примечание: Значение должно быть во втором
Для более новых версий этого является документация: https://github.com/datastax/spark-cassandra-connector/blob/master/doc/5_saving.md# указав-ТТЛ-и-WriteTime – Oosterman