我需要一个查询组连同如果条件的基础上计数，我在mysql下面的工作查询。 select notification,subject,max(time) as recent,value,IF(COUNT(event.value) > 1, 'Abnormal', 'Normal') AS NewResult from event where time between date_add(now(), interval -10 minute) and now() group by device,value order by time; Cassandra对此有什么相关的疑问吗。
1条答案
按热度按时间qf9go6mv1#
不需要。这需要在所有令牌范围内进行过滤和至少一次分散收集（如果使用索引），并且可能需要一次完整的表扫描。这两种语言都不能很好地扩展，因此它们几乎不受支持，因此在cql语法中根本不允许使用更复杂的表达式。
在cassandra中，您是围绕查询设计表，而不是围绕数据设计查询。您可能真的想考虑使用spark或hadoop来执行更复杂的批量处理，但实际上您并没有按照数据库的设计用途来使用它。如果它只是一个单独运行的临时查询，你可以编写一个客户端应用程序，将所有数据拉下来，进行聚合和过滤。
如果有机会，请考虑更改数据模型（如果需要读取）。