Cassandra delta/相对查询

Question

我必须编排一个批处理，每天复制一个表的增量。该表仅被写入，从未更新。我将 java 与 jdbc 一起使用，我想知道表上是否有元数据或其他东西可以查询以获取在某个日期之后添加的所有行。

---

为什么是元数据？ 因为我的桌子看起来像：

CREATE TABLE aTable (
  aTable_id timeuuid,
  ...
  PRIMARY KEY ((aTable_id))
) WITH
...

我不能将 timeuuid 键放在 where 子句中，例如：

SELECT * FROM aTable WHERE aTable_id > minTimeuuid(?)

还有令牌功能，即使aTable_id 的顺序正确，也会给我错误的结果：

SELECT * FROM aTable WHERE token(aTable_id) > token(minTimeuuid(?))

简而言之，我的问题是：如何让 aTables 比某个日期更新？

Answer 1

在 cassandra 中，主键也是分区键。 为每个 timeuuid 创建一个分区是没有意义的...... 所以通常你用主键对事物进行分组，然后使用集群键进行排序。

这是一个与我所做的相近的例子：

create table sensors(
    location varchar, 
    timestamp timeuuid, 
    ...
    PRIMARY KEY(location, timestamp)
) WITH CLUSTERING ORDER BY (timestamp DESC) AND ...

位置是分区键，时间戳是集群键。

然后你可以这样选择：

SELECT * from sensors 
    where location='tarifa' 
    and timestamp > maxTimeuuid('2015-04-15 13:00') 
    and timestamp < minTimeuuid('2015-04-15 15:00');

Answer 2

所以我最终找到了一个解决方案，在介绍 cassandra 3.0 的聚会中找到。

请记住，架构是为另一个请求设置的，而密钥不是为增量请求设置的。

我的目标是只查询上一批中的更新行，这里是我做的方式：

• 创建一个索引表，按日期小时分区（分钟、秒和毫秒被截断）。该表由主表中的全局索引提供。
• 在 java 中，按小时查询索引 (loop on a calendar) 并使用 IN 查询选择主表。
• 工作完成！