datastax-java-driver相关内容

将Cassandra BoundStatement的ResultSet映射/转换/转换为使用Object-mapping API构建的Java classe的最有效方法是什么?

DataStax Java中是否存在用于Apache Cassandra的内置方法,将来自BoundStatement的ResultSet映射到使用Object-mapping API构建的域对象Java类? 使用时Mapper + Accessor方法,Result.all()做得非常好。找不到类似于BoundStatement方法的任何内容。 谢谢 IPVP 解决方案 ..
发布时间:2019-01-02 22:36:04 Java开发

Cassandra:截断表两次抛出一致性异常

我有一个scalatest套件失败,我已经将原因缩小到在测试之前运行和截断数据表的代码。如果我运行下面的代码我可以重现问题 session.execute(s“TRUNCATE $ {dao.tableName} ) session.execute(s“TRUNCATE $ {dao.tableName};”) 抛出: 截断期间出错:无法实现一致性级别ALL ..
发布时间:2016-11-13 16:29:25 其他开发

当试图通过单元在Cassandra中创建列族时,InvalidQueryException

我有一个3节点的cassandra集群,并通过我的单元测试在Java,我首先创建一个键空间,然后在该键空间中创建一个列系列。有时单元测试通过,但随机我不断得到以下错误。我使用最新的datastax 2.1.4 java驱动程序和在2.1.0中的cassandra版本。 com.symc.edp。 database.nosql.NoSQLPersistenceException:com.da ..

如何提高cassandra的写性能?

我有一个名为电子邮件列的家庭,我将电子邮件保存到此CF,它需要100 +秒来写入5000个邮件。 我使用i3处理器,8gb ram。 我的数据中心有6个节点,复制因子= 2。 我们存储到Cassandra的数据大小会影响性能吗? 所有影响写入性能的因素如何提高性能? 提前感谢.. 解决方案 解决方案客户端和群集之间以及群集中的计算机之间的延迟(如 @omnibear ..
发布时间:2016-11-13 16:15:28 其他开发

Cassandra - 写入不会失败,但不会插入值

我有一个3个Cassandra 2.0节点的集群。我的应用程序我写了一个测试,尝试写入和从Cassandra读取一些数据。一般来说这很好。 好奇的是,我重新启动我的电脑后,这个测试会失败,因为写入后,我读到我之前写的相同的值,我得到null而不是值,但写入时没有异常。 如果我手动截断使用的列族,测试将通过。之后,我可以执行这个测试多久我想要,它一遍又一遍。此外,如果Cassandra中有值 ..

范围查询在Cassandra

我使用Cassandra 2.1.2与对应的DataStax Java驱动程序和DataStax提供的对象映射。 下面的表定义: CREATE TABLE如果不存在ses.tim(id text PRIMARY KEY,start bigint,cid int); 映射: @Table(keyspace =“ses”,name =“tim”) class ..
发布时间:2016-11-13 15:50:22 Java开发

Datastax Cassandra - 使用对象映射器时的继承

我尝试使用Cassandra来维持相当简单的POJO,但使用类层次结构(许多子类,一个超类)。我使用Java和Datastax驱动程序(和对象映射器)。 我的问题是对象映射器似乎不识别超类中注释的字段。 p> 我实现的结构是: @Table(keyspace =“。 ..“,name =”...“) public class Subclass extends Supercla ..
发布时间:2016-11-13 15:40:08 Java开发

如何Cassandra处理datastax java驱动程序中的阻塞execute语句

阻止来自com.datastax.driver.core.Session的执行方法 public ResultSet execute(Statement statement); 评论此方法: 此方法阻塞,直到从 数据库接收到至少一些结果。但是,对于SELECT查询,它不保证结果已被完全接收 。但它确保已经从数据库接收到一些 响应,并且特别地, 保证如果请 ..
发布时间:2016-11-13 15:34:57 其他开发