我有一张像这样的Cassandratable

CREATE TABLE tmp.inventory (
    t_id text,
    is_available boolean,
    modified_at bigint,
    price double,
    available_units bigint,
    PRIMARY KEY(t_id, modified_at)
) WITH CLUSTERING ORDER BY (modified_at);

我有一个流媒体管道更新Cassandra的项目。流式管道每隔一段时间检查一次。因此，当管道失败时，它将重新处理自上次成功检查点以来的源数据。当它在失败后重新处理时，它将尝试覆盖cassandra中已经成功写入的数据（即在最后一个成功的检查点之后但在失败之前）。我在考虑利用 modified_at 实现这一点。像这样的

UPDATE tmp.inventory SET is_available = ? WHERE t_id = ? AND modified_at < ?

只有当cassandra中的修改的\u at小于管道中的修改的\u at时，我才尝试进行更新。但是，这会引发 InvalidQueryException: Slice restrictions are not supported on the clustering columns in UPDATE statements 我想如果这种情况有帮助的话。

UPDATE tmp.inventory SET is_available = ? WHERE t_id = ? IF modified_at < ?

但这件事 InvalidQueryException: PRIMARY KEY column 'modified_at' cannot have IF conditions 那么，处理这个问题的理想方法是什么呢？
编辑如果我只在这个表中有这些字段，那么重新处理事件可能没有那么大的问题，因为当管道赶上实时流时，它最终会变得一致，但是说有另一个流作业用当前价格、可用单位等更新同一个表。在这种情况下，如果其中一个作业失败并重新启动，则表可能处于一致状态。