java - 在 Java 中将 Aerospike 与 Spark 结合使用时设置 TTL

Question

我是 Aerospike 的新手。我们正在为我们的系统使用 Aerospike 和 Spark (Java)。

我想在每次将数据写入 Aerospike 时为数据帧设置 TTL。但是，我什至无法从文档或 Internet 中找到执行此操作的方法。

我目前的写语法:

networkDs.write()
        .mode(SaveMode.Overwrite)
        .format("com.aerospike.spark.sql")
        .option("aerospike.set", Const.AEROSPIKE_SET)
        .option("aerospike.updateByKey", "id")
        .save();

谁能告诉我怎么做？

非常感谢。

Answer 1

我不确定我是否理解你的问题，但要在使用 aerospike 保存时使用 TTL，你应该将它存储在 DataSet/DataFrame 在保存之前。

注意:生存时间 (TTL) 可以在每条记录上单独设置。

要启用对 TTL 的更新，并指定其他选项:

option("aerospike.ttlColumn", "expiry")

这意味着 TTL 是您的列 expiry。

希望对您有所帮助。

有关更多信息，我建议您查看aerospike tutorial documentation .