小编Bha*_*thi的帖子

我有一张桌子如下

CREATE TABLE test (
 day int,
 id varchar,  
 start int,
 action varchar,  
 PRIMARY KEY((day),start,id)
);

我想运行此查询

Select * from test where day=1 and start > 1475485412 and start < 1485785654 
and action='accept' ALLOW FILTERING

这是否允许过滤有效？

我期待cassandra将按此顺序过滤

1. By Partitioning column(day)
2. By the range column(start) on the 1's result
3. By action column on 2's result. 

所以allow筛选对于这个查询来说不是一个糟糕的选择.

如果where子句上的多个过滤参数和非索引列是最后一个,过滤器将如何工作？请解释.

我有一个流式数据流正在运行以读取 PUB/SUB 订阅。

经过一段时间或可能在处理一定数量的数据后，我希望管道自行停止。我不希望我的计算引擎实例无限期地运行。

当我通过数据流控制台取消作业时，它显示为失败的作业。

有没有办法实现这一目标？我错过了什么吗？或者 API 中缺少该功能。