Apache Cassandra的Java客户端驱动程序。此驱动程序仅使用Cassandra查询语言版本3(CQL3)和Cassandra的二进制协议。
CQL 插入返回“CodecNotFoundException:未找到请求的操作的编解码器:[list<varchar> <-> java.util.HashMap]”
我认为我的代码和查询中遗漏了一些内容。下面的代码给了我以下错误(在代码下)。 我认为这是因为我的数据和表格不匹配,但一切看起来都很好......
使用setNode()方法指定的节点将读取请求转发给其他节点
我正在尝试使用 Datastax 驱动程序版本 4.13 读取特定 cassandra (4) 节点中存在的数据。我已阅读这篇文章,据说它适用于驱动程序版本 3.x 我修改了我的代码...
如何在多应用场景下获得Cassandra Writes的背压?
我有多个应用程序写入 Cassandra。 每个单元应用程序都配置了反压机制,例如吞吐量MBPerSec = 10 当多个应用程序同时运行时就会出现问题
将 Kubernetes 外部的 Datastax 连接到 Kubernetes 中的 Cassandra 集群
我有一个 Cassandra 集群在 AWS 上的 Kubernetes 中运行(使用孵化器 Helm 图表)。当我使用负载均衡器公开节点时,Datastax 无法直接连接到 wa 中的节点...
Spring 应用程序由于 NoNodeAvailableException 而返回 CassandraConnectionFailureException:没有可用的节点来执行查询
我们在现有集群中又添加了 1 个 dc。应用程序分别部署在每个区域。添加 DC 和区域明智的应用程序部署后,我们开始看到以下异常......
将 LocalDateTime 转换为 Cassandra TIMESTAMP 时出现编解码器问题
我有 POJO 属性如下, @Column(名称 = "时间戳") 私人 LocalDateTime 时间戳; 该属性来自服务,需要保留格式。我正在流式输入...
Datastax java 驱动程序 3.0.0 未找到枚举注释
希望我能很好地阅读文档: http://docs.datastax.com/en/developer/java-driver/3.0/java-driver/reference/crudOperations.html。 枚举注释 如果您的类包含枚举类型字段...
cassandra-unit 是否与 JDK 17 一起运行?
我尝试在我的单元测试中运行 EmbeddedCassandra.startEmbeddedCassandra()(使用 casandra-unit:4.3.1.0),并且在调用 startEmbeddedCassandra() 之后没有抛出任何错误但仍在加载,...
Java 应用程序无法使用提供的联系点连接到 Cassandra 集群
报错如下: 错误 1912 --- [nio-8080-exec-2] o.a.c.c.C.[.[.[/].[dispatcherServlet]:Servlet.service() for servlet [dispatcherServlet] in context with path [] throw exception [
无法从 Spring Boot 应用程序连接到集群,获取 ConnectionInitException:“无法到达任何联系点”
无法连接到 Cassandra 集群:无法到达任何联系点,\ 确保您提供了有效地址(显示前 1 个节点,使用 getAllErrors() 更多):\ 节点(端点= ...
在 V3 Datastax 驱动程序中,Session.execute 方法明确声明抛出哪些异常,我的代码将捕获并适当处理: 但是在 V4 中,CqlSession.execute 方法确实...
Cassandra datastax @Entity-annotated class must have at least an property defined
我在下面的实体类中使用了 Datastax java 驱动程序 4.1.x 包 com.xyz; 导入 com.datastax.oss.driver.api.mapper.annotations.CqlName; 导入 com.datastax.oss.driver.api.mapper.annotations.Enti...
InvalidQueryException:单个赋值中不能超过 100 个。请使用多个赋值来设置这个值
当列表中元素的大小超过 100 时,当我尝试使用列表类型的列之一在我的新表中插入数据时出现此错误。 但我什至可以插入 400 个 reco...
Cassandra datastax-java-driver 日志记录请求上下文
datastax-java-driver 提供了一种记录所有查询的方法。但我需要拦截并记录 REST API 的一些上下文。 我的设置是使用 Spring 数据的 Spring webflux,它在内部使用 datastax-...
v4的java驱动是否可以用下面的方法来实现GenericDao?如何实现? List> retrieve(Class> clazz, BoundStatement boundStatement) throws ...。
如何使用Cassandra Java驱动访问嵌套地图的列表?
我在使用 Cassandra Java 驱动程序获取包含地图的列表时遇到了麻烦。对于以下版本。列表> myList = state.getList(5, TypeTokens.mapOf(Integer......)。
我有以下表 create table test( userId varchar, notifId timeuuid, notification varchar, time bigint,read boolean, primary key(userId, notifId))......。
了解Cassandra池化选项(setCoreConnectionsPerHost和setMaxConnectionsPerHost)?
我最近开始使用Cassandra,我在这里阅读了更多关于连接池的内容。我对池的大小感到困惑,无法理解这里的意思:poolingOptions......。
Datastax RetryPolicies解释,什么时候用什么策略?
我最近开始使用Cassandra,我阅读了更多关于重试策略和一致性级别的内容,我想我已经了解了它的基本知识。我只是困惑于什么重试策略使更...
将数据帧从Spark群集写入cassandra群集:分区和性能调整
我有两个群集-1. Cloudera Hadoop- Spark作业在这里运行2.云-Cassandra群集,多个DC在将数据从我的Spark作业写入cassandra群集时,我正在进行重新分区(...