代码之家  ›  专栏  ›  技术社区  ›  tuancoltech

在Java中使用带Spark的Aerospike时设置TTL

  •  2
  • tuancoltech  · 技术社区  · 7 年前

    我对Aerospike是新手。我们在系统中使用Aerospike with Spark(Java)。

    每次数据写入Aerospike时,我都要为数据帧设置TTL。然而,我甚至无法从文件或互联网上找到这样做的方法。

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

    谁能告诉我怎么做?

    谢谢。

    1 回复  |  直到 7 年前
        1
  •  3
  •   eliasah    7 年前

    我不确定我是否理解你的问题,但在保存时使用TTL aerospike DataSet / DataFrame 在它被保存之前。

    生存的时间

    要启用TTL更新,请指定其他选项:

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

    这意味着TTL是您的列 expiry .

    有关更多信息,我建议您查看 尖锥 tutorial documentation