12得票1回答
如何在Cassandra表中添加多个列?

我需要在Cassandra中向我的现有列族/表中添加一些新列。我可以像这样添加单个列:ALTER TABLE keyspace_name.table_name ADD column_name cql_type; 我是否可以使用单个查询添加所有新列? 如果是,如何使用cql和datastax c...

14得票4回答
在使用Datastax Cassandra Driver时,如何重复使用PreparedStatement?

我目前正在使用Datastax Cassandra驱动程序执行Cassandra 2的cql3。这部分工作正常。我开始使用PreparedStatement:Session session = sessionProvider.getSession(); try { PreparedSt...

7得票2回答
DataStax Cassandra核心驱动程序依赖于易受攻击的Guava-19。

DataStax Cassandra core Java driver有一个传递依赖于guava-19(包括最新的DataStax),该版本存在安全漏洞(CVE-2018-10237)。 为了解决这个问题,我尝试在DataStax驱动程序中排除guava-19.0依赖项,并替换为guava-...

65得票3回答
如何在使用命令行时使用CQL获取当前时间戳?

我正试图通过命令行向我的CQL表插入数据。我能够插入所有内容。但是如果我有一个时间戳列,那么我如何从命令行插入时间戳列呢?基本上,每当我插入我的CQL表时,我想插入当前时间戳 - 目前,每当我插入下面的CQL表时,我都会硬编码时间戳 -CREATE TABLE TEST (ID TEXT, ...

18得票2回答
CQL3:当只有一个主键时如何检索TTL?

我有一个像这样定义的CQL表:CREATE table primary_key_only( row_key varchar, clustered_key varchar, primary key(row_key, clustered_key) ) 假设我像这样插入值:INSERT ...

18得票2回答
如何在使用“executeAsync”时限制写入请求到Cassandra?

我正在使用Datastax Java驱动程序3.1.0连接到Cassandra集群,我的Cassandra集群版本是2.0.10。我正在使用QUORUM一致性异步写入数据。 private final ExecutorService executorService = Executors...

7得票1回答
Cassandra读取超时

我正在从Cassandra 2.0中提取大量数据,但很不幸出现了超时异常。 我的表: CREATE KEYSPACE StatisticsKeyspace WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_fact...

7得票2回答
如何将Cassandra BoundStatement的ResultSet映射/转换/强制转换为使用对象映射API构建的Java类的最有效方法?

有没有一种内置的方式可以在DataStax Java for Apache Cassandra中,将来自BoundStatement的ResultSet映射到使用Object-mapping API构建的域对象Java类?我是一个新手,从Mapper + Accessor方法转移到BoundS...

7得票1回答
Cassandra集群插入性能差且插入稳定性不佳

我需要每个客户端每秒存储大约250个数字值,每小时大约为900k。这可能不会是全天记录(可能在5-10小时之间),但我将根据客户ID和读数日期对数据进行分区。最大行长度约为22-23M,仍然可管理。尽管如此,我的方案如下: CREATE TABLE measurement ( clien...

8得票2回答
使用DSE的Java API映射Cassandra Materialized View

我有一个带有相关物化视图的Cassandra表。 主键是一个类型为uuid的单个id,我没有排序键。我们称之为my_table_id。这个表包含一个related_id,我想要用它来搜索。 然后我定义了一个针对该表的物化视图。 PRIMARY KEY (related_id, my_ta...