如何列出keyspace中的列族？
如何使用CQL 3获取Cassandra中所有列族的列表？ 解决方案 cqlsh>从system.schema_columnfamilies中选择columnfamily_name，其中keyspace_name ='test'; columnfamily_name ------------------- commits foo has_all_types i
..
cassandra-2.0相关内容
R和cassandra连接错误
图书馆（RJDBC） cassdrv list.files（”/ home / beyhan / Downloads / jars /“，pattern =”jar $“，full.names = T）） casscon ; - dbConnect（cassdrv，“jdbc：cassandra：// localhost：9042”） p>
..
Cassandra：java.lang.OutOfMemoryError：Java堆空间
我使用cassandra 2.0.8并收到此异常 INFO 16：44：50,132初始化system.batchlog INFO 16：44：50,138初始化system.sstable_activity INFO 16：44：50,142打开/ var / lib / cassandra / data / system / sstable_activity / system-
..
原子批次在Cassandra
批处理语句是什么意思是cassandra中的原子？文档在本质上是有点混乱的是精确的。是否意味着查询在群集中的节点上是原子的？ 例如，我有一个包含100个查询的批处理。如果批处理中的第40个查询失败，批处理中执行的39个查询会发生什么？ 我知道有一个批处理创建了，的部分批次的一致性。它是否删除39个条目中的其余部分，并提供批处理查询的所需原子性质。 在MYSQL中，我们将autoc
..
尝试登录到cassandra的控制台（cqlsh），它拒绝我
我已经更新了 cassandra.yaml 与： 验证者：PasswordAuthenticator 然后使用replication_factor为3创建了system_auth键空间： CREATE KEYSPACE system_auth WITH REPLICATION = {'class'：'SimpleStrategy'，'replication_fac
..
如何使用DataStax Java驱动程序设置Cassandra客户端到节点加密？
我在Cassandra群集上设置了节点到节点加密。现在我想设置客户端到节点。根据此文档，它应该像获取SSL证书一样简单我的客户端并将其导入到每个节点的信任库。我没有这样的证书，但这不是我的问题。 由于我的客户端使用DataStax Java驱动程序，似乎为了启用SSL客户端，当我建立群集时，我应该使用 withSSL（） 方法启用SSL。好吧，但我还需要做什么？我不熟悉JSSE，所以我不知道
..
通过部分分区键查询Cassandra
在Cassandra中，我可以创建一个与我的聚类键分开的复合分区键： CREATE TABLE footable $ b column1 text， column2 text， column3 text， column4 text， PRIMARY KEY（（column1，column2）） ） 根据我的理解，分区键查询是一个非常高效（最有效？）的方法检索数据。但
..
将大量数据从Cassandra导出到CSV
我使用Cassandra 2.0.9存储大量数据，比方说100Gb，在一个列系列中。我想以快速的方式将此数据导出为CSV。我试过： sstable2json - 它产生相当大的json文件，很难解析 - 在一行中并使用复杂的模式（例如300Mb数据文件=〜2Gb json），转储需要很多时间，Cassandra喜欢根据其内部机制更改源文件名。 COPY - 对于大量记录，在相当快速的EC2
..
如何知道nodetool修复是否完成
我有一个2节点apache cassandra（2.0.3）集群，其rep因子为1.我使用以下命令在cqlsh中更改rep因子为2 ALTER KEYSPACE“mykeyspace”WITH REPLICATION = {'class'：'SimpleStrategy'，'replication_factor'：2}; 然后我尝试在做这种类型的alter之后运行推荐的“
..
用于访问R中的Cassandra数据库的软件包
我试过 RCassandra 和 RJDBC 但不幸的是，这些绑定似乎只适用于旧的Cassandra 1 。X。 解决方案 这不是真的，当前版本的 RJDBC 与Cassandra 2配合使用。 X。 下载具有C * 2.x兼容性的最新版本：cassandra-jdbc-2.1.1.jar $但是有一个警告，你还必须下载java依赖项，并将它们放入您的JAVA类路径（MacOS：/
..
将一张表复制到Cassandra中的另一张表
我想将数据从standardevents复制到standardeventstemp。 下面的步骤我正在做 COPY事件。标准事件（uuid，数据，名称，时间，跟踪器，类型，用户ID）TO'temp.csv'; truncate standardevents; COPY event.standardeventstemp（uuid，data，name，time，tracker
..
Cassandra - 重叠数据范围
我在Cassandra中有以下'任务'表。 Task_ID UUID - 分区键 Starts_On TIMESTAMP-群集列 Ends_On TIMESTAMP - 群集列 我想运行CQL查询以获取指定日期范围内的重叠任务。例如，如果我将两个时间戳（T1和T2）作为参数传递给查询，我想获得适用于该范围内的所有任务（即重叠记录）。 在Cassandra中最好的方法是什么？我
..
Cassandra与硬盘不平衡，如何配置？
我们正在构建一个用于存储大量时间序列数据的Cassandra（2.1.5）集群，我们计划利用现有硬件，问题是可用的硬件真的不同。 2台机器：4核心，8 GB，SSD 2台机器：8核心，16 GB，SSD 2机器：32核心，64 GB，硬盘 显然，32核机器可以处理比4核机器更大的负载，我们应该如何配置Cassandra来处理这个。我们正在使用RF 3和最新的datastax
..
Cassandra如何选择节点发送请求？
想象一下，Cassandra集群需要由客户端应用程序访问。在Java API中，我们创建一个集群实例，并通过一个Session发送读或写请求。如果我们使用读/写一致性ONE，api如何选择实际节点（协调器节点）以便转发请求。是随机选择吗？请帮助解决这个问题。 解决方案 Cassandra驱动程序使用“gossip”协议有关集群的信息。如果节点不可用，则客户端驱动程序自动尝试其他节点并使用死
..
Cassandra示例触发器获取删除的行和列值
当列族中有更新时，将调用ITrigger扩充方法。我们如何知道更新操作是插入还是删除？ 此外，是否可以在触发器实现的同一个键空间中的其他表中执行任何DML语句？假设有两个表test1和test2。为test1创建触发器。如果在test1中有任何删除操作，我们如何在触发器实现中为test2执行DML语句？ 解决方案 检查更新操作的代码是否为删除或插入 @Override p
..
Cassandra CQL选择查询不返回具有时间戳为clusterkey的记录
Cassandra CQL：使用复合键和集群键创建的表。当我尝试从分区键执行select *时，我能够检索所有数据，它也适用于关系运算符（）。 但是当我查询特定的集群键使用等于（=）运算符与适当的值，它返回0行。 表格： CREATE TABLE entity_data（ received_date timestamp， entity text， received_ti
..
Cassandra Java驱动程序：有多少联系人是合理的？
在Java中，我连接到Cussandra集群，如下所示： 集群集群= Cluster.builder（）addContactPoints -001“，”host-002“）。build（）; 我需要指定集群中的所有主机吗？如果我有一个1000个节点的集群？我随机选择几个？ 解决方案 我的方法是添加尽可能多的节点 - 原因很简单：种子仅仅用于集群启动，但是一旦集群启
..
Cassandra中的原子批是如何工作的？
原子批次如何保证单个批次中的所有语句都将执行或不执行？ 解决方案 为了理解批次如何工作，它有助于查看批处理执行的各个阶段。 / p> 客户 支持使用
..
二级索引在Cassandra中如何工作？
假设我有一个栏族： CREATE TABLE update_audit（ scopeid bigint， formid bigint， 时间时间戳， record_link_id bigint， ipaddress文本， user_zuid bigint， 值文本， PRIMARY KEY（（scopeid，formid）时间） ）WITH CLUSTERING ORDER B
..
卡珊德拉 - 有没有办法来限制异步的查询号码是多少？
我想知道是否有办法来限制由卡桑德拉Java驱动程序同时执行的查询号码是多少？ 目前，我执行了许多疑问如下： ... 。preparedStatement语句=会话prepare（“SELECT * FROM用户WHERE ID =？”）; BoundStatement boundStatement =新BoundStatement（语句）; 清单＆LT; ResultSetFuture＆GT
..