文件名称：storm-cassandra-cql
文件大小：68KB
文件格式：ZIP
更新时间：2024-06-30 14:32:06
Java
描述/理由 这是一个基于 CQL java 驱动程序的新 CassandraState 实现。 对于 Cassandra，CQL 对轻量级事务、批处理和集合有更好的支持。 此外，CQL 可能会比传统的 Thrift 界面获得更多关注。 出于这些原因，我们决定创建一个基于 CQL 的 C* 状态实现。 Storm-Cassandra-Cql 提供了三种不同的状态实现： CassandraCqlState ：简单地将元组映射到具有批处理功能的语句。 CassandraCqlMapState ：提供 IBackingMap 实现，用于 Storm 中的键/值和聚合。 CassandraCqlIncrementalState ：利用条件更新以增量方式对数据执行维度聚合。 （每批构成一个增量） 设计 应用程序/拓扑提供映射器接口的实现。 例如， 提供了从键和值到可用于更新插入和检索数据的语句
【文件预览】：
storm-cassandra-cql-master
----pom.xml(3KB)
----LICENSE(11KB)
----src()
--------test()
--------main()
----.gitignore(112B)
----CHANGELOG.md(1KB)
----libsnappyjava.jnilib(49KB)
----README.md(10KB)