在 Cassandra 中选择两个表

2024-03-08

I use Cassandra一个项目,这是我的第一个项目。 ,我试图对两个表执行一个简单的请求,但这不起作用......

我想做类似的事情:

Select * from table1, table2 where table1.test = test and table2.test2 = 123;

是否可以请求两个表Cassandra?我怎样才能做到这一点?

Thanks


我正在尝试对两个表执行一个简单的请求

您尝试执行的操作称为“分布式连接”,而 Cassandra 是专门为防止您执行此操作而设计的。

解决这些类型问题的方法是使用一个称为非规范化。假设您有两个简单的表carMake and carModel:

 makeid | make
--------+--------
      1 |  Chevy
      2 |  Dodge
      3 |   Ford

 modelid | makeid | model
---------+--------+---------
      15 |      3 |   Focus
      11 |      3 | Mustang
      32 |      2 | Charger
      82 |      3 |  Fusion

现在,在传统的 RDBMS 中,如果我想选择所有品牌为“Ford”的汽车型号,我将执行 JOIN 查询。但对于 Cassandra,我们的想法是在建模阶段解决这个问题,通过构建一个支持同时查询汽车品牌和型号的表:

CREATE TABLE carMakeModel (
    carid int,
    make text,
    model text,
    PRIMARY KEY (make,carid));

aploetz@cqlsh:stackoverflow> SELECT * FROM carMakeModel WHERE make='Ford';

 make | carid | model
------+-------+---------
 Ford |     1 | Mustang
 Ford |     2 |   Focus
 Ford |     3 |  Fusion

(3 rows)

这里需要注意的一些要点:

  • make根据需要进行重复。您会注意到“Ford”在结果集中被指定了 3 次。如果您有 13 款福特汽车的数据,您将存储“福特”的值 13 次。
  • Cassandra 中的主键是独一无二的。我有carid作为主键的一部分添加,以确保每个主键的唯一性model,否则为每个插入一个make会覆盖自身。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

在 Cassandra 中选择两个表 的相关文章

  • 避免 cassandra 中的僵尸数据

    最近 我在客户设置 3 节点集群时遇到了一个问题 其中一个节点出现故障 并在 12 天后才上线 在我们的场景中 大多数表的默认 gc grace seconds 已设置为 1 天 并且有很多表 当此故障节点出现时 来自该节点的陈旧数据被复制
  • Java获取调用页面的URL

    为了让您了解情况 我们使用基于 Tomcat 6 0 29 的自定义服务器 我们正在使用 Java 和 Spring 进行开发 假设我有一个链接 您可以从http localhost 显示 http localhost display to
  • 带有“Sec-Fetch-User:?1”标头的重复请求扰乱了我的请求限制

    我有一个网站 并且我已经实施了自己的请求限制以提高安全性 问题是 从一台特定的机器上 我收到重复的请求 它们之间几乎相同 生成的两个请求之间存在毫秒级的时间差 当某些 JavaScript 代码以编程方式提交表单时 就会执行原始请求 它们之
  • NodeJS发送POST请求时如何设置Content-Length?

    var https require https var p api username FA AA ZOHO ACTION EXPORT ZOHO OUTPUT FORMAT JSON ZOHO ERROR FORMAT JSON ZOHO
  • 为什么 Cassandra 客户端在生产中没有 epoll 时会失败? [复制]

    这个问题在这里已经有答案了 当我在本地运行服务时 我收到一条警告 指出 epoll 不可用 因此它使用 NIO 很公平 当我将其部署到 Kubernetes 中时 我得到了以下信息 这导致服务无法运行 2017 03 29T19 09 22
  • Cassandra Nodetool Repair 的具体作用是什么?

    From http docs datastax com en cassandra 2 0 cassandra operations ops repair nodes c html http docs datastax com en cass
  • Hector 和 Cassandra 问题 NoSuchFieldError:DEFAULT_MEMTABLE_THROUGHPUT_IN_MB

    我正在通过 Hector 测试与 Cassandra 数据库的连接 但是当我运行 Junit 测试时 我不断收到以下消息 java lang NoSuchFieldError DEFAULT MEMTABLE THROUGHPUT IN M
  • 我可以在 Cassandra 2.1 中对集合进行多重查询吗?

    在 Cassandra 2 1 中 我们可以通过在列上创建二级索引来查询集合 cqlsh play gt select from songs where tags contains t1 id tags title e99f8f30 d21
  • 性能 - TTL 与在 Cassandra 中删除一行

    我们有大量数据写入 cassandra 中的数百万行 我们还有一个调度程序 需要处理这些记录并在处理成功后将其删除 想知道处理后删除行还是用 TTL 标记行 本质上是延迟删除 Deletion 与 TTL 对于 Cassandra 性能有何
  • Spark JSON 文本字段到 RDD

    我有一个 cassandra 表 其中有一个名为 snapshot 的文本类型字段 其中包含 JSON 对象 identifier timestamp snapshot 我了解到 为了能够使用 Spark 对该字段进行转换 我需要将该 RD
  • 表行为的 cassandra TTL

    假设我在 secondary 1 处插入一列 在 secondary 2 处插入另一列 表的默认 TTL 设置为 10 秒 例如 问题1 data1 和 data2 是否会在 10 秒后被删除 或者 data 1 将在 10 秒后被删除 d
  • 我能否找出 ASP 回发时将触发哪些控制事件?

    是否有可能在发生之前获取将要触发的控制事件列表 例如在Page Load处理程序 例如 如果单击了一个按钮 我可以在button click事件处理程序被调用 您选择了一个非常棘手的问题 原因是事件触发的方式有多种 1 EVENTTARGE
  • Web Api 请求在 IIS 上永远排队(状态:ExecuteRequestHandler)

    我目前在生产环境中遇到一些挂起 经过一番调查后 我发现大量请求在应用程序池的工作进程中排队 常见的事情是 每个长时间排队的请求都是一个Web api请求 我同时使用MVC and Web API在应用程序中 请求排队时间约为 3 小时 当应
  • Cassandra 查询失败(墓碑)

    所以这让我发疯 我尝试查询 Cassandra 中的一张表 结果显示查询失败 我尝试深入探究其背后的原因 发现这是因为墓碑 我将 GC GRACE SECONDS 更改为零并使用 nodetool 触发了压缩 当我再次查询时它工作正常 然而
  • 如何制作将 HTML 文件加载到 div 中的 XMLHttpRequest?

    我正在尝试做一个XMLHttpRequest从外部文件加载 HTML 并将文件内容插入到div 当我运行该函数时 它会在所有正文中插入 HTML 这是不够的 My code gt HTML
  • Cassandra .setFetchSize() on 语句不被遵守

    我想在UI上实现分页 所以我这样设置fetchSize boundStatement setFetchSize 20 但 setFetchSize 不被尊重 截至目前 我的表有 400 行 并且所有 400 行均已检索 当我使用检索下一组行
  • Redis AOF fsync(始终)与 LSM 树

    我对日志结构化合并树 LSM 树 的理解是 它利用了附加到磁盘非常快 因为它不需要查找 这一事实 只需将更新附加到预写日志并返回到客户端即可 我的理解是 这仍然提供了立即的持久性 同时仍然非常快 我不认为 Redis 使用 LSM 树 它似
  • Apache Cassandra 中的复合索引

    我正在尝试设置一个 cassandra 列族 其中一些列上有二级索引 在读回数据时我需要进行过滤 在我最初的测试中 当我一起使用多个索引时 速度会变慢 这是我当前的配置方式 通过 cassandra cli update column fa
  • 如何使用 DataStax java 驱动程序增加 cassandra 中的每秒事务数 (TPS)

    设置 2 节点 Cassandra 2 0 7 31 集群 副本 1 DataStax java 驱动程序 2 0 Problem 我正在使用 Datastax java 驱动程序进行负载平衡 我并通过 Jmeter 生成 50000 线程
  • 如何使用 cqlsh 将 Cassandra 连接到本地主机?

    我将 rpc port 设置为公共 IP 地址 现在我可以从外部服务器正常连接到 Cassandra 但是 我无法使用 cqlsh 从 Cassandra 服务器本身进行连接 我收到一个错误 即 Connection error Could

随机推荐

  • 为什么浏览器要为 CSS 属性创建供应商前缀?

    也许这是一个显而易见的答案 但是 Why on earth浏览器是否会决定创建自己的供应商前缀border radius等等 我的意思是 为什么我必须输入 moz border radius 10px webkit border radiu
  • 通过回调方法使用 Quarkus/Mutiny 将 MyRequestService 连接到 Reactive REST GET 端点

    上周我与Mutiny https smallrye io smallrye mutiny 图书馆 因为我需要一个Reactive https en wikipedia org wiki Reactive programming我的 REST
  • 使用paste0时转义斜杠

    我正在尝试将几个字符串连接在一起 包括反斜杠 但是 我似乎无法正确转义反斜杠 paste0 A B 给我Error unexpected symbol in paste0 A B while paste0 A B returns A B 我
  • DOM选择方法的文档顺序

    我知道实时 NodeList 返回getElementsByTagName保留元素的文档顺序 这是真的吗getElementsdByClassName getElementsByName and querySelectorAll方法 这些方
  • JavaScript 中的 window.location 替代方案

    什么是标准化替代品window location href财产 我在 w3schools com 上检查它是否已在所有主要浏览器中实现 因此没有问题 但我很好奇如何正确执行此操作 从这里可以看出该函数没有标准化 https develope
  • 我应该使用什么重定向 uri (OAuth 2.0)?

    我为 google API Console 注册了我的应用程序 我得到了我的客户秘密 客户 ID 以及两个重定向 uri urn xxxxxxx oob http localhostxxxxxx 当然 我使用这些项目并成功向谷歌请求令牌 但
  • MySQL 并发性,它是如何工作的以及我是否需要在我的应用程序中处理它

    我目前正在运行 MySQL 数据库 我的所有表都使用表引擎 InnoDB 每个登录我的应用程序的人都可以查看记录 我担心在某些时候两个用户可能会同时更新或插入记录 MySQL 是否能够优雅地处理这种类型的并发问题 还是我必须将其编程到我的代
  • PCRE 正则表达式反向引用有效,但子例程无效

    我正在尝试匹配文本 1 嘿嘿嘿嘿 2 嘿嘿嘿嘿 与正则表达式 a w 1 w b w w w c w 1 w Regex a火柴1完全 并且2完全 但最后一个 y Regex b完全匹配1 and 2 Regex c不匹配1 or 2 下列
  • WordPress 博客分页不起作用

    我仍然卡在这个问题上 我的 WordPress 博客上的分页无法正常工作 http www example com news http www example com news 当您单击不同的页码时 它会正确更新 URL 和页面标题 但不会
  • Swift Couple - Publishers.CombineLatest 在多个线程上

    当将 Publishers CombineLatest 与运行除 Main 的 sink 以外的线程的 Publishers 一起使用时Publishers CombineLatest并不总是被调用 这个问题并不是每次都会出现 这就是为什么
  • 在 Facebook 见解上找不到我的应用程序?

    我正在使用社交插件运行一个网站 所以我创建了一个 Facebook 应用程序 然后我想使用 facebook inform 来连接我的网站和应用程序 ps 我还在标题中添加了app id或meta 但我在连接列表中找不到我创建的应用程序 有
  • 如何在 Android 中将 getview() 与 SimpleAdapter 一起使用?

    我正在生成一个ListView用一个SimpleAdapter My SimpleAdapter代码如下 ListAdapter k new SimpleAdapter this val1 R layout mytask new Strin
  • QTextEdit 中的水平线

    我试图在一个水平线QTextDocument 我使用 HTML 进行格式化 为了画出我想要的线条 我自然地使用了 hr 标签 但这条线是灰色的 我想把它的颜色改为黑色 这些样式似乎不适用于hr元素 那么有没有一个简单的解决方法可以在我的文档
  • 如何在Python中使用“with open”打开多个文件?

    我想一次更改几个文件 iff我可以写信给他们所有人 我想知道是否可以以某种方式将多个开放调用与with陈述 try with open a w as a and open b w as b do something except IOErr
  • Flask 应用程序“使用 stat 重新启动”

    我已经构建了一些 Flask 应用程序 但在我最新的项目中 我注意到开发模式有些奇怪 终端中常见消息的第二行始终显示 Running on http 127 0 0 1 5000 Restarting with reloader 已被替换为
  • git bisect skip 如何选择下一个提交来尝试?

    使用时git bisect 一个人可以跑git bisect skip将当前提交标记为不可构建 不可测试的提交 尝试让 Git 选择其他提交进行测试 Git 如何决定在某个提交之后尝试哪个提交git bisect skip 实验表明这不仅仅
  • Backbone.js 查看实例变量?

    我正在学习 Backbone js 并试图弄清楚是否可以在 Backbone 视图中包含实例变量 我的目标是在实例化视图时从外部文件加载视图的模板 目前 我将它们存储在 Backbone 应用程序的全局命名空间中的全局变量中 但将模板存储在
  • 动态获取变量

    我正在使用 Go 模板来管理 Helm 的部署 我有这样的values yaml 文件 env dev config dev myname Hi live myname Bye 现在我想根据环境 开发 实时 获取值 喜欢 Values co
  • dlopen 是否创建多个库实例?

    在网上搜索后 我似乎找不到答案 当我第一次使用 dlopen 时 它似乎比此后的任何时间都花费更长的时间 包括如果我从程序的多个实例运行它 dlopen 是否将 so 加载到内存中一次并让操作系统保存它 以便任何后续调用 甚至来自程序的另一
  • 在 Cassandra 中选择两个表

    I use Cassandra一个项目 这是我的第一个项目 我试图对两个表执行一个简单的请求 但这不起作用 我想做类似的事情 Select from table1 table2 where table1 test test and tabl