如何仅检索从 Cassandra 更改的信息?
我正在为我的以下用例设计 Cassandra 列族架构.我不确定为我的以下用例设计 cassandra 列族的最佳方法是什么?我将为此使用 CQL Datastax Java 驱动程序.. 以下是我的用例和我现在设计的示例架构 - SCHEMA_ID RECORD_NAME SCHEMA_VALUE TIMESTAMP1 ABC 某个值 t12 ABC some_other_value t
..
datastax-java-driver相关内容
使用 Datastax API(使用新的二进制协议)向上插入/读入/从 Cassandra 数据库
我已经开始使用 Cassandra 数据库.我打算使用 Datastax API 来 upsert/read 进入/从Cassandra 数据库.我对这个 Datastax API(使用新的二进制协议)完全陌生，我也找不到很多包含一些适当示例的文档. 创建列族配置文件使用 key_validation_class = 'UTF8Type'和比较器 = 'UTF8Type'和 default_va
..
使用 datastax java 驱动程序连接到本地 cassandra 节点?
我使用 datastax java 驱动程序 3.1.0 连接到 cassandra 集群，我的 cassandra 集群版本是 2.0.10. 下面是我用来连接到 cassandra 集群的单例类. 公共类 CassUtil {私有静态最终记录器 LOGGER = Logger.getInstance(CassUtil.class);私人会话会话；私有集群集群；私有静态类持有人{私有静态
..
Datastax Cassandra 驱动程序重试策略延迟?
我正在使用 Datastax Cassandra 驱动程序并设置了 RetryPolicy 以在主机不可用时重试.但是，我注意到它会尽可能快地重试.我想改变它以增加重试之间的延迟，而不是在集群陷入困境时敲打它.这对于 OVERLOADED 请求错误尤其重要，因为我确实想在这些情况下重试，但会延迟很大. 延迟的正确位置在哪里?正确的机制是什么?我应该在我的 RetryPolicy 中抛出一个
..
Cassandra:插入 timeuuid 错误
我有下表 创建表测试(用户 ID 变量字符，notifId timeuuid,通知varchar，时间 bigint，读取布尔值，主键(userId，notifId))与聚类顺序(notifId desc)； 我正在运行以下查询: PreparedStatement pstmt = session.prepare("INSERT INTO notification(userId, notif
..
通过java中的主键列表进行cassandra查找
我正在实现一项功能，该功能需要通过主键列表查找 Cassandra. 下面是一个示例数据，其中 id 是主键 mytableid 列 11 4232 5423 6784 455345 4356346 24357 6788 45649 546 我的大多数查询都是按 id 查找，但对于某些特殊情况，我想获取 id 列表的数据.我目前的做法如下: 公共对象 fetchFromCassandr
..
Cassandra 如何处理 datastax java 驱动程序中的阻塞执行语句
阻止从 com.datastax.driver.core.Session 执行方法 public ResultSet execute(Statement statement); 对此方法的评论: 此方法阻塞，直到至少收到一些结果数据库.但是，对于 SELECT 查询，它并不能保证结果已全部收到.但它确实保证了一些已收到来自数据库的响应，特别是保证如果请求无效，就会抛出异常用这种方法.
..
将 Cassandra BoundStatement 的 ResultSet 映射/转换/转换为使用对象映射 API 构建的 Java 类的最有效方法是什么?
DataStax Java 中是否有用于 Apache Cassandra 的内置方法将来自 BoundStatement 的 ResultSet 映射到使用对象映射 API 构建的域对象 Java 类? 我是一个从 Mapper + Accessor 方法转向 BoundStatement 方法的新手，并希望继续使用使用对象映射 API 构建的域对象的 Java 类，因此我在移动时对我的
..
Cassandra 读取超时
我正在从 cassandra 2.0 中提取大量数据，但不幸的是出现超时异常.我的桌子: CREATE KEYSPACE StatisticsKeyspaceWITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 3 };CREATE TABLE StatisticsKeyspace.HourlyStatis
..
如何防止 Cassandra 提交日志填满磁盘空间
我正在 AWS 上运行一个两节点 Datastax AMI 集群.昨天，Cassandra 开始拒绝与所有事物建立联系.系统日志什么也没显示.经过很多的修补，我发现提交日志已经填满了分配安装上的所有磁盘空间，这似乎导致了连接拒绝(删除了一些提交日志，重新启动并可以连接). 我使用的是 DataStax AMI 2.5.1 和 Cassandra 2.1.7 如果我决定从头开始擦除并重新
..
如何在 Datastax Java 驱动程序中使用异步/批量写入功能
我打算使用 Datastax Java 驱动程序写入 Cassandra.. 我主要对 Datastax Java 驱动程序的 Batch Writes 和 Asycnhronous 功能感兴趣，但我不能够获取任何可以解释我如何将这些功能合并到我下面使用 Datastax Java 驱动程序的代码中的教程.. /*** 为指定的 id 执行指定属性的 upsert.*/public void u
..
“尝试查询的所有主机均失败"错误
我的Java代码如下: import com.datastax.driver.core.Cluster;导入 com.datastax.driver.core.Metadata;导入 com.datastax.driver.core.Session;公共类客户控制器{公共无效执行(){集群集群 = Cluster.builder().addContactPoints("172.16.11.126
..
从 com.example.cassandra 使用 Java Driver for Apache Cassandra 1.0 连接到 Cassandra 时出错
在通过 DataStax 使用 Cannsandra 的 Java 驱动程序连接到 Cassandra 客户端时，它抛出以下错误.. 线程“main"com.datastax.driver.core.exceptions.NoHostAvailableException 中的异常:所有主机尝试查询失败(尝试:[/127.0.0.1]) 请推荐... 谢谢！ 我的java代码
..
为 Cassandra Writes 获得背压的最佳方法是什么?
我有一个服务，它以我控制的速度从队列中消耗消息.我做了一些处理，然后尝试通过 Datastax Java 客户端写入 Cassandra 集群.我已经使用 maxRequestsPerConnection 和 maxConnectionsPerHost 设置了我的 Cassandra 集群.但是，在测试中，我发现当我达到 maxConnectionsPerHost 和 maxRequestsPer
..
使用命令行时如何使用 CQL 获取当前时间戳?
我正在尝试从命令行插入到我的 CQL 表中.我能够插入所有内容.但我想知道我是否有时间戳列，那么如何从命令行插入时间戳列?基本上，每当我插入 CQL 表时，我都想插入当前时间戳 - 目前，每当我插入下面的 CQL 表时，我都会对时间戳进行硬编码 - CREATE TABLE TEST (ID TEXT, NAME TEXT, VALUE TEXT, LAST_MODIFIED_DATE T
..
使用 DataStax 客户端将参数传递给 Cassandra CQL 查询
我使用 datastax 作为连接到 cassandra 的客户端.我已经通过 Java 成功连接到 cassandra 集群/键空间/列族.我正在尝试，通过 java 对 cassandra 列族发出一些查询.对我来说，它适用于像 这样的简单查询 ResultSet results = session.execute("select * from demodb.customer where
..
在 Datastax Cassandra CQL 驱动程序的 IN 子句中收集准备好的语句
我正在尝试运行以下查询 SELECT edge_id, b_id FROM booking_by_edge WHERE edge_id IN ? 我将 Long 的 Java 列表绑定为参数，但出现异常 SyntaxError: line 0:-1 不匹配的输入 ''期待 ')' (ResultSetFuture.java:242) 如果我尝试使用 (?) 它期望绑定单个 Long 项目，
..
Cassandra:如何使用 CQL 插入具有良好性能的新宽行
我正在评估 cassandra.我正在使用 datastax 驱动程序和 CQL. 我想用以下内部结构存储一些数据，其中每次更新的名称都不同. +-------+-------+-------+-------+-------+-------+||姓名1 |姓名2 |姓名3 |... |姓名N ||时间 +-------+-------+-------+-------+-------+||v
..
使用 Datastax Cassandra 驱动程序时重新使用 PreparedStatement?
我目前正在使用 Cassandra 2 的 Datastax Cassandra 驱动程序来执行 cql3.这工作正常.我开始使用 PreparedStatement's: Session session = sessionProvider.getSession();尝试 {PreparedStatement ps = session.prepare(cql);结果集 rs = session.
..
Cassandra集群插入性能和插入稳定性差
我必须每秒为每个客户端存储大约 250 个数值，即每小时大约 90 万个数字.它可能不会是一整天的记录(可能每天 5-10 小时)，但我会根据客户端 ID 和读取的日期对我的数据进行分区.最大行长度约为 22-23M，这仍然是可管理的.尽管如此，我的方案是这样的: CREATE TABLE 测量(客户 ID 文本，日期文本，event_time 时间戳，值整数，PRIMARY KEY ((cli
..