选择具有最高时间戳的行
我有一个存储事件的表 CREATE TABLE active_events ( event_id VARCHAR, number VARCHAR, .... start_time TIMESTAMP, PRIMARY KEY (event_id, number…
从 cassandra 2.1 迁移到 scylla 4.5
制作: nodetool flash(在 cassandra 上) nodetool snapshot name_snapshot(在 cassandra 上) cqlsh [IP] "-e DESC SCHEMA" > orig_schema.cql(…
Mongo 与 cassandra:单点故障
在 Cassandra 与 Mongo 的争论中,据说由于 mongo 具有主从架构,因此它存在单点故障(主节点),当主节点发生故障时,从节点需要时间来决定新的主节…
cassandra从一个节点备份到另一个节点
我是 cassandra 和 gremlin 的新手。我正在使用 gremlin 输入和检索来自 cassandra 的数据。我想进行备份并在新节点上恢复它。我使用 nodetool 拍摄了…
Cassandra 中的点对点架构如何工作?
点对点 Cassandra 架构究竟如何运作?我的意思是: 当请求到达集群时,它必须到达基于 IP 的某些机器,对吧? 那么它会首先攻击哪台机器呢? :节点之…
即使不满足一致性级别,也会存储提示吗?
考虑集群有 3 个节点,密钥空间 A 的副本数 = 3,一致性为 quorom, 当 2 个节点出现故障时,这将引发一致性级别不满足的异常。第三个节点是否充当协…
列式/面向列的数据库与宽列/列族数据库
最近我对 Cassandra 感到非常困惑,因为大多数在线材料甚至 AWS 和 Google 都将其描述为柱状数据库。但实际上它是基于行的、分区的、列族数据库。现在…
在同一台机器上发生硬件故障后更换 Cassandra 种子节点?
我有两个虚拟机,每个虚拟机托管一个 Cassandra 种子节点。我擦除一台虚拟机来模拟硬件故障。 cassandra-env.sh 文件末尾添加 replace_address_first_…
我们是否可以添加新的 Cassandra 3.11 DC,将其升级到 4.0,然后最终摆脱旧的 DC?
我们希望使用多 DC 复制从 cassandra 3.11.12 升级到 cassandra 4.0.2。 我们希望这样做是为了轻松快速地回滚(避免备份\快照和恢复的情况)。 Steps …
Kafka 主题 Avro 键未从 Cassandra 源连接器填充
我有一个 Kafka 主题,它具有以下 Avro Key Schema: { "type": "record", "name": "onboardingStatusKey", "namespace": "onboarding", "fields": [ …
cassandra 选择分组最大值
我在 covid19 键空间下创建了一个表“统计数据”: CREATE TABLE statistics(country_name text, dt date, confirmed_cases bigint, deaths bigint, P…
多线程时 Datastax Cassandra NoNodeAvailableException
我正在尝试用 Java 构建一个多线程 Cassandra 导入器。我正在使用这个包: group: 'com.datastax.cassandra', name: 'cassandra-driver-core', versio…
Spring 升级后 Cassandra 分面不工作
我已将 Spring 从1.5.2 升级到2.5.5,因此 Cassandra 也得到了升级。 我正在使用 Cassandra 存储库并编写本机查询。 升级之前,以下查询在 facet_fiel…
将信息保存到 Cassandra 不会保持顺序
我正在使用 Scala 并尝试将我的日历信息从 Spark 保存到 Cassandra。 我开始使用 Cassandra 创建相同的模式: session.execute("CREATE TABLE calenda…