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

Question

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

我想在每次将数据写入 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。

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

Set TTL when using Aerospike with Spark in Java

java

ttl

apache-spark

aerospike