当前位置: 首页 > 知识库问答 >
问题:

用TTL节省Cassandra的火花

拓拔辰钊
2023-03-14

我正在使用Spark-Cassandra连接器1.1.0和Cassandra 2.0.12。

谢谢,

沙伊

共有1个答案

岑畅
2023-03-14

不幸的是,在连接器的1.1.0版本中,似乎没有一种方法可以做到这一点(据我所知)。但是在1.2.0-alpha3中有一种方法。

SaveTocassandra()是WriterBuilder的包装器,它有一个WithTTL方法。您可以使用writerbuilder(keyspace,table,rowWriter).withttl(seconds).saveTocassandra(),而不是使用saveTocassandra

 类似资料:
  • 我们正在使用数据轴进行索拉/卡桑德拉。目前,我们的搜索响应小于200毫秒,但每五分钟响应一次,大约10秒。调试后,我们将原因确定为TTL。ttl 线程每 5 分钟运行一次,这就是我们看到性能下降的时候。但是我们无法弄清楚TTL线程正在做什么来阻止读取?数据软件企业版:4.8 任何人有任何想法,请分享。谢谢。

  • 每次使用cassandra connector在spark中运行scala程序时都会出现此错误 这是我的程序

  • 编辑1 当选择正确的scala版本时,它似乎会更进一步,但我不确定下面的输出是否仍然有需要解决的错误:

  • TTL

    TTL key 以秒为单位,返回给定 key 的剩余生存时间(TTL, time to live)。 可用版本: >= 1.0.0 时间复杂度: O(1) 返回值: 当 key 不存在或没有设置生存时间时,返回 -1 。 否则,返回 key 的剩余生存时间(以秒为单位)。 # 带 TTL 的key redis> SET name "redis" OK redis> EXPIRE name 30

  • 使用从docx4j,我在两个docx文件中的相同位置有以下内容(解压.docx后从相应的中提取)。以下是这些文件之间的唯一区别: 和 在第一个文档中,