datastax-java-driver相关内容
我有以下模型的两个表: CREATE TABLE IF NOT NOT EXISTS INV( CODE TEXT, PRODUCT_CODE TEXT, LOCATION_NUMBER TEXT, QUANTITY DECIMAL, CHECK_INDICATOR BOOLEAN, VERSION BIGINT, PRIMARY KEY((LOCATION_NUMBER,P
..
DataStax Java中是否存在用于Apache Cassandra的内置方法,将来自BoundStatement的ResultSet映射到使用Object-mapping API构建的域对象Java类? 使用时Mapper + Accessor方法,Result.all()做得非常好。找不到类似于BoundStatement方法的任何内容。 谢谢 IPVP 解决方案
..
cassandra表中其中一列的数据类型为 timeuuid 。 按
..
我的笔记本电脑上运行了Cassandra 1.2.11。我可以使用 nodetool 和 cqlsh 连接到它,但是当我尝试使用DataStax 1.0.4 Java API进行连接时使用CQL 3.0我收到以下错误: com.datastax.driver.core.exceptions.NoHostAvailableException:所有主机尝试查询失败(尝试:localhost /
..
我正在使用datastax java驱动程序3.1.0连接到cassandra集群,而我的cassandra集群版本是2.0.10。 以下是我正在使用的单例类连接到cassandra集群。 public class CassUtil { private static final Logger LOGGER = Logger.getInstance(CassUtil。类); 私
..
我有一个scalatest套件失败,我已经将原因缩小到在测试之前运行和截断数据表的代码。如果我运行下面的代码我可以重现问题 session.execute(s“TRUNCATE $ {dao.tableName} ) session.execute(s“TRUNCATE $ {dao.tableName};”) 抛出: 截断期间出错:无法实现一致性级别ALL
..
我有一个3节点的cassandra集群,并通过我的单元测试在Java,我首先创建一个键空间,然后在该键空间中创建一个列系列。有时单元测试通过,但随机我不断得到以下错误。我使用最新的datastax 2.1.4 java驱动程序和在2.1.0中的cassandra版本。 com.symc.edp。 database.nosql.NoSQLPersistenceException:com.da
..
(neophyte问题)我刚刚安装了cassandra 3.5(在linux上,使用通用包)。 我可以使用cqlsh连接,但不能使用javax java驱动程序(版本2.0.2)。例如。如果我运行 BasicConfigurator.configure(); 集群集群= Cluster.builder()addContactPoint “127.0.0.1”)。build();
..
我有一个名为电子邮件列的家庭,我将电子邮件保存到此CF,它需要100 +秒来写入5000个邮件。 我使用i3处理器,8gb ram。 我的数据中心有6个节点,复制因子= 2。 我们存储到Cassandra的数据大小会影响性能吗? 所有影响写入性能的因素如何提高性能? 提前感谢.. 解决方案 解决方案客户端和群集之间以及群集中的计算机之间的延迟(如 @omnibear
..
我有一个3个Cassandra 2.0节点的集群。我的应用程序我写了一个测试,尝试写入和从Cassandra读取一些数据。一般来说这很好。 好奇的是,我重新启动我的电脑后,这个测试会失败,因为写入后,我读到我之前写的相同的值,我得到null而不是值,但写入时没有异常。 如果我手动截断使用的列族,测试将通过。之后,我可以执行这个测试多久我想要,它一遍又一遍。此外,如果Cassandra中有值
..
在使用Data-stax Java驱动程序版本1.0.2连接到Cassandra 1.2.1时,出现错误: 线程“main”中的异常java.lang.IllegalArgumentException:populate_io_cache_on_flush不是此元数据中定义的列 at com.datastax.driver.core.ColumnDefinitions.getIdx(Colu
..
我有以下情况。 有一个CQL表(Cassandra 2.0.12) CREATE TABLE article( version timeuuid, id timeuuid, active boolean, contentbody text, contentformat text, createdat text, entitytype text, externalsou
..
我使用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
..
我尝试使用Cassandra来维持相当简单的POJO,但使用类层次结构(许多子类,一个超类)。我使用Java和Datastax驱动程序(和对象映射器)。 我的问题是对象映射器似乎不识别超类中注释的字段。 p> 我实现的结构是: @Table(keyspace =“。 ..“,name =”...“) public class Subclass extends Supercla
..
阻止来自com.datastax.driver.core.Session的执行方法 public ResultSet execute(Statement statement); 评论此方法: 此方法阻塞,直到从 数据库接收到至少一些结果。但是,对于SELECT查询,它不保证结果已被完全接收 。但它确保已经从数据库接收到一些 响应,并且特别地, 保证如果请
..
似乎没有任何直接的方式来知道cassandra中的受影响的行更新和删除语句。 例如,如果我有一个像这样的查询: DELETE FROM xyztable WHERE PKEY IN(1,2,3,4,5,6); 现在,由于我已经传递了6个键,受影响。 > 我看过cassandra没有提供有关写入操作的反馈 。 除了我通过g
..
我目前正在使用Cassandra 2的Datastax Cassandra驱动程序来执行cql3。这工作正常。我开始使用 PreparedStatement的: Session session = sessionProvider.getSession ; try { PreparedStatement ps = session.prepare(cql); ResultSet rs
..
这是我当前的错误: com.datastax.driver.core.exceptions.NoHostAvailableException:试图查询失败(尝试:/127.0.0.1(com.datastax.driver.core.TransportException:[/127.0.0.1]意外异常触发(java.lang.NoClassDefFoundError:无法初始化类com.
..
如果有人在使用UDT(用户定义类型)方面有一些经验,我想了解如何向后兼容性工作。 说我有以下UDT CREATE TYPE addr b $ b street1 text, zip text, state text ); 如果我修改“addr”UDT有几个属性(例如zip_code2 int,和名称文字): CREATE TYPE addr( stree
..
我目前无法使用datastax驱动程序连接到我的cassandra数据库。我收到以下错误: com.datastax.driver.core.TransportException:[/127.0.0.1] (java.lang.NoSuchMethodError:com.google.common.collect.ImmutableSet.copyOf(Ljava / util / Col
..