cassandra-2.0相关内容

Cassandra中如何保证不同表上的数据一致性?

我是 Cassandra 的新手，我读过 Cassandra 鼓励非规范化和数据重复.这让我有点困惑.让我们想象一下以下场景: 我有一个包含四个表的键空间:A、B、C 和 D. 创建表 A (表 ID 整数，列 1 整数，column2 varchar，第3列varchar，第4列varchar，第5列varchar，PRIMARY KEY (column1, tableID)); 假设 ..
发布时间：2021-12-31 17:45:59 其他开发

如何重置丢失的 Cassandra 管理员用户密码?

我可以完全访问 Cassandra 安装文件和在 cassandra.yaml 中配置的 PasswordAuthenticator.我该怎么做才能重置丢失的管理员用户密码，同时保持现有数据库完好无损? 解决方案 通过以下步骤解决: 将 cassandra.yaml 中的身份验证器更改为 AllowAllAuthenticator 并重新启动 Cassandra cqlsh up ..
发布时间：2021-12-31 17:41:54 其他开发

cassandra中二级索引的范围查询

我使用的是 cassandra 2.1.10.所以首先我要清楚我知道二级索引是 cassandra 中的反模式.但是为了测试目的，我尝试了以下操作: 创建表 test_topology1.tt (文本主键，b 时间戳) 与bloom_filter_fp_chance = 0.01AND 缓存 = '{"keys":"ALL", "rows_per_partition":"NONE"}'AND 评 ..
发布时间：2021-12-31 17:38:32 其他开发

Cassandra 如何选择发送请求的节点?

想象一个 Cassandra 集群需要由客户端应用程序访问.在 Java api 中，我们创建一个集群实例并通过 Session 发送读或写请求.如果我们使用读/写一致性ONE，api如何选择实际节点(协调器节点)以转发请求.是随机选择吗?请帮忙解决这个问题. 解决方案 Cassandra 驱动程序使用“gossip"协议(以及称为节点发现的过程)来获取有关集群的信息.如果节点变得不可用， ..
发布时间：2021-12-31 17:37:56 Java开发

将大量数据从 Cassandra 导出到 CSV

我使用 Cassandra 2.0.9 在一个列族中存储大量数据，比如 100Gb.我想以快速的方式将此数据导出到 CSV.我试过了: sstable2json - 它产生相当大的 json 文件，难以解析 - 因为工具将数据放在一行中并使用复杂的模式(例如 300Mb 数据文件 = ~2Gb json)，它需要一个很多时间转储，Cassandra 喜欢根据其内部机制更改源文件名 COPY ..
发布时间：2021-12-31 17:35:42 其他开发

cassandra 如何找到包含数据的节点?

我已经阅读了很多关于 Cassandra 的文章和很多问题/答案，但我仍然无法弄清楚 Cassandra 在读取数据时如何决定去哪个节点. 首先，关于假想集群的一些假设: 复制策略 = 简单 使用随机分区器 10 个节点的集群 复制因子为 5 以下是我根据我阅读过的各种 Datastax 文章和其他博客文章对写入工作方式的理解: 客户端将数据发送到随机节点 “随机" ..
发布时间：2021-12-31 17:32:42 其他开发

Cassandra Java 驱动程序:多少个接触点是合理的?

在 Java 中，我连接到 Cussandra 集群如下: Cluster cluster = Cluster.builder().addContactPoints("host-001","host-002").build(); 我需要在那里指定集群的所有主机吗?如果我有一个 1000 个节点的集群怎么办?我随机选择几个?有多少，我真的是随机做的吗? 解决方案 我想说，将您的客户端配置 ..
发布时间：2021-12-31 17:23:27 Java开发

我怎么知道 nodetool 修复是否完成

我有一个 2 节点的 apache cassandra (2.0.3) 集群，代表因子为 1.我在 cqlsh 中使用以下命令将代表因子更改为 2 ALTER KEYSPACE "mykeyspace" WITH REPLICATION = { 'class' : 'SimpleStrategy', 'replication_factor' : 2 }; 然后我尝试在执行此类更改后运行推荐的“ ..
发布时间：2021-12-31 17:23:00 其他开发

在 cassandra 中使用 Order by 子句

在 cassandra 中创建表时，我们可以按如下顺序给出聚类键. 创建表 user(partitionkey int, id int, name varchar, age int, address text,insrt_ts 时间戳，主键(partitionkey, name, insrt_ts, id)聚类顺序为 (name asc, insrt_ts desc, id asc); 当我们 ..
发布时间：2021-12-31 17:21:36 其他开发

Cassandra 中的原子批处理是如何工作的?

原子批处理如何保证单个批处理中的所有语句都将执行或不执行? 解决方案 为了了解批处理的工作原理，查看批处理执行的各个阶段很有帮助. 客户 使用 CQL3 或现代 Cassandra 客户端 API 支持批处理.在每种情况下，您都可以指定要作为批处理的一部分执行的语句列表、用于所有语句的一致性级别和可选的时间戳.您将能够批量执行 INSERT、DELETE 和 UPDATE 语句 ..
发布时间：2021-12-31 17:18:54 其他开发

通过部分分区键查询 Cassandra

在 Cassandra 中，我可以创建一个复合分区键，与我的集群键分开: CREATE TABLE footable (第 1 列文字，第2列文本，第3列文本，第4列文本，主键 ((column1, column2))) 据我所知，按分区键查询是一种极其有效(最有效?)的数据检索方法.然而，我不知道的是，仅通过复合分区键的一部分进行查询是否也有效. 在 MSSQL 中，只要包含从第一个开 ..
发布时间：2021-12-31 17:18:45 其他开发

二级索引如何在 Cassandra 中工作?

假设我有一个列族: CREATE TABLE update_audit (scopeid bigint，强大的bigint，时间时间戳，record_link_id bigint，ip地址文本，user_zuid bigint，值文本，PRIMARY KEY ((scopeid, formid), time)) 与聚类顺序 BY (时间 DESC) 有两个二级索引，其中 record_link ..
发布时间：2021-12-31 17:14:02 其他开发

Spark Sql 查询失败

使用 Sparks 2/java/Cas​​sanda2.2尝试运行一个简单的 sparks sql 查询，它出错:尝试如下，+ 变体，如“'LAX'"，和 '=' 而不是 '=='. 线程“main"org.apache.spark.sql.AnalysisException 中的异常:无法解析'`LAX`'给定的输入列:[transdate, origin];第 1 行 pos 42；'项目 ..
发布时间：2021-11-14 23:03:30 Java开发

将Cassandra用作队列

将Cassandra用作队列: 真的那么糟糕吗? 设置:5个节点群集，所有操作均按法定人数执行 使用DateTieredCompaction可以大大降低TombStones的成本，并允许立即删除整个SSTable. 我们将所有消息添加到具有相同TTL的队列中 我们根据时间(例如1分钟间隔)对邮件进行分区，并跟踪读取位置. 消耗的消息将被明确删除.(只有1个线程提取消息) ..
发布时间：2021-04-21 19:39:57 其他开发

在Cassandra中删除读取和删除突变

我有多个DC的大型Cassandra群集.有时，我在带有213个内部节点和514个交叉节点的debug.log中收到有关Drop读取和删除突变的INFO消息.但是，应用程序不受影响.根据我的理解，实际的请求没有失败，但是某些副本没有响应协调器，如果实现了一致性，则请求成功.请澄清我是否有误会. 解决方案 如果满足请求的一致性级别，则应用程序不会从协调器收到错误.您提到该应用程序没有受到影响 ..
发布时间：2021-04-21 19:39:05 其他开发