cassandra 相关问题

Cassandra是一个高度可扩展,最终一致,分布式,结构化的行/列存储。

getIndexDDLStatements 仅适用于值列?

公共列表 getIndexDDLStatements(字符串表){ List idxDDLs = new LinkedList<>(); 设置 keyCols = new HashSet<>(

回答 1 投票 0

无法连接到spark

运行Python代码不会连接到Spark,也不会在Cassandra中创建数据库。我已经确认服务已在 docker 上启动并且可以从 PC 访问。我将 .jar 放入...

回答 1 投票 0

CQL 插入返回“CodecNotFoundException:未找到请求的操作的编解码器:[list<varchar> <-> java.util.HashMap]”

我认为我的代码和查询中遗漏了一些内容。下面的代码给了我以下错误(在代码下)。 我认为这是因为我的数据和表格不匹配,但一切看起来都很好......

回答 2 投票 0

Windows 上的 Cassandra 安装失败,出现错误“无法创建 Java 虚拟机”

我正在尝试在 Windows 上安装 cassandra 版本 3.11.14,但出现此错误: 错误:无法创建 Java 虚拟机。 错误:发生致命异常。程序将会退出。 我有...

回答 2 投票 0

如何在 Datastax Cassandra 中获取每个查询的 CPU 时间、内存时间和 CPU 使用率?

我在研究生工作中使用 datastax cassandra,我想获得这个指标,但我找不到任何有关它的文档。我正在使用 python 连接器。是否可以获得有关...的信息

回答 1 投票 0

更好地理解 SSTables 格式 big 与 bti

在哪里可以找到有关哪个版本的 Cassandra 支持哪个版本的 SSTables 的更多信息。 最近我注意到 DSE Cassandra 正在生成 SSTables bti,而 Apache Cassandra 3.11.4 继续...

回答 2 投票 0

为什么环境变量在application.yml中不起作用?

我有以下代码 @SpringBootApplication 公共类应用程序{ 公共静态无效主(字符串[] args){ System.out.println("环境变量为 "+ ((System.getenv("

回答 1 投票 0

Cassandra 中的 Spring 数据切片

实际上我正在使用 Slice 在 Cassandra 中的查询中进行分页。我的存储库声明如下: @存储库 公共接口 MovementsRepository 扩展了 CassandraRepository 实际上我正在使用 Slice 在 Cassandra 中的查询中进行分页。我的存储库声明如下: @Repository public interface MovementsRepository<T> extends CassandraRepository<Movements, MovementsPK> { @Query("SELECT movementNumber FROM KEYSPACE.MOVEMENTS) Slice<Movements> downOrder(@Param("agency") String agency, @Param("account") String account, @Param("initialDate") LocalDate initialDate, @Param("finalDate") LocalDate finalDate, Pageable pageable); } 我是这样在第一页进行搜索的: Slice<Movements> slice = this.movementsRepository.downOrder(agency, account, initialDate, finalDate, CassandraPageRequest.first(1000)); 要进入下一页,我可以像这样获取属性 slice.nextPageable() : slice = this.movementsRepository.downOrder(agency, account, initialDate, finalDate, slice.nextPageable()); 但是我需要对每个请求进行分页,所以我需要在 JSON 中检索 pagingState 或者当第二个、第三个...请求到来时我是否可以使用它来设置 nextPageable 我知道下一个搜索在下一页中,可以以我正在做的方式或其他方式做这件事? 非常感谢 切片只能导航到下一个切片。 Slice 还提供是否有更多数据要获取的详细信息。所以你可以在 while 循环中运行它,如下所示: while(slice.hasNext()){ slice = this.movementsRepository.downOrder(agency, account, initialDate, finalDate, slice.nextPageable()); }

回答 1 投票 0

CQL 查询抛出错误:日期 (23) 的长度预计为 8 或 0 字节

需要帮助解决以下问题。 错误:响应错误:日期长度应为 8 或 0 字节 (23) 在 FrameReader.readError (D:\EACApp\eac-app-management\node_modules\cassandra-driver\lib\re...

回答 1 投票 0

在 DevCenter 中使用绑定变量,出现错误“绑定变量数量无效”

如何在 select 语句中使用绑定变量。 当我直接使用它时,它会检索如下值。 选择事件时间 来自 stage_insight.insight_hourly_ts 其中 tag_id='UP247490.

回答 1 投票 0

CQL Datastax Java 映射集/列表查询操作

嗨,我目前正在尝试设置我的 CQL Dao 以实现一些查询功能, 但是我找不到一种方法将任何对象的集合作为参数,因为我不断收到此错误

回答 2 投票 0

如何使用 Datastax Java Cassandra 驱动程序将环境变量传递到 application.conf

我有当前的application.conf... datastax-java-驱动程序 { basic.contact-points = ["192.168.23.1:9042"] 基本的 { 负载均衡策略{ 本地数据中心 = datacenter1 ...

回答 2 投票 0

单存储到 Cassandra 迁移

我们正在将 Singlestore DB 迁移到 Cassandra 数据库。作为初始设置,需要完成数据建模。我们计划使用 data-xtractor 进行此建模/迁移操作...

回答 1 投票 0

Cassandra nodetool cfstats 显示“索引表”的“修复百分比=0”?

我在几个表上创建二级索引。然后我在集群中的每个节点上成功运行了nodetool -pr。但是当我使用nodetool cfstats检查表状态时,发现输出信息

回答 1 投票 0

如何使用 cqlsh 将 Cassandra 连接到本地主机?

我将 rpc_port 设置为公共 IP 地址,现在我可以从外部服务器很好地连接到 Cassandra。 但是,我无法使用 cqlsh 从 Cassandra 服务器本身进行连接 我收到了

回答 15 投票 0

Scylla JMX - MBean org.apache.cassandra.metrics:keyspace=uzzstore,name=EstimatedRowCount,scope=chunks,type=ColumnFamily 如何映射到 API 中?

Scylla 通过其内部 API 公开 JMX mbean(或者可能相反,但这并不重要)。例如,我可以访问 MBean org.apache.cassandra.metrics:name=LiveDiskSpaceUsed,type=

回答 1 投票 0

需要一个计数器查询,使用 hector API 给出主键的所有计数器

我正在使用 cassandra 的 hector API。 我创建一个计数器表如下 私有无效addColumnFamilyCounter(ThriftCluster集群,字符串cfName,int rowCacheKeysToSave){ 字符串

回答 1 投票 0

从 Cassandra 中的表获取行数的最佳方法是什么?

有没有最好的方法可以从 Cassandra 表中获取总行数? 问候, 玛尼

回答 5 投票 0

是否有任何文档解释 Cassandra CDC 内部细节的行为?

我正在研究 POC,我需要解析 Cassandra CDC 日志并将其用于某些目的。在最新的 Cassandra 版本 4.1 中,Cassandra CDC 包含 _cdc.idx 文件,该文件指向 Com 中的持久写入...

回答 2 投票 0

CQL 按时间范围检索时间序列数据

我在不同位置有传感器,每个传感器测量多个参数。每个传感器每天大约会进行 200 万次测量。我需要按位置/时间范围查询,但是范围

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.