0

我有一个列族,其定义如下:


create column family Message with key_validation_class ='UTF8Type' and default_validation_class = 'UTF8Type'


其行键是唯一的 id 并且两列存储在一行中

  1. message : 字符串消息
  2. created_dt :在 cassandra 中创建此行的日期时间

现在我的要求是移动和删除一年多以来存在的所有消息。我不想完全删除该数据,而是将其从工作中的 cassandra 集群移至另一个用于存档的数据。

是否有任何工具/脚本可以帮助实现这一目标?

如果我必须使用 hector 编写代码,那么如何有效地完成呢?如何找出具有 created_dt < current_dt - 1 year 的键?

4

0 回答 0