如何在Scala中定义映射器，以flink中的Cassandra水槽？
从 CassandraSink.addSink(result) .setHost("127.0.0.1") .setMapperOptions(() -> new Mapper.Option[]{Mapper.Option.saveNullFields(true)}) .bui…
与Java驱动程序连接到Cassandra，必须明确设置“本地DC”。
我尝试使用给定参数创建连接。 CqlSessionBuilder builder = CqlSession.builder(); int port = 9042; for ( String host : hosts ){ int idx = host.…
如何在Cassandra Java驱动程序V4中编程启用跨代码故障转移？
在dataStax驱动程序3.x中，我们获得了DCAWAREROUNDROBIN策略，如果本地数据中心中的节点失败。 DataStax文档，提到： Cross-datacenter failover is e…
如何使用DataStax Java驱动程序4.x实现令牌感知负载平衡策略？
我们的应用程序当前使用 Cassandra-Driver-Core-3.1.0 ，并实现令牌感知负载平衡策略。我们将驱动程序升级到 Java-Driver-core-4.13.0 ，驱动程序无法…
Cassandra Java Driver 4.X可用哪些负载平衡政策？
我们正在将DataStax Cassandra Java驱动程序从3.2升级到4.x，以支持DSE 6.8。 负载平衡政策我们的应用程序当前支持是Roundrobinpolicy和Dcawareroundr…
我们如何在Java Driver V4中使用loggingRetrypolicy和fallthroughRetrypolicy与驱动程序configloader？
我们的应用程序实施重试策略，例如使用驱动程序Cassandra-Driver-Core-3.1.0.jar.jar.jar.jar.jar..jar..jar..jar..dse6.8，我们正在将DataStax驱动程…
在Cassandra 4.X中，我可以用什么用作替代结果？
我必须将Cassandra升级到4.x。 这是先前用Cassandra 3.5编写的代码 protected Stream getAll(Stream statements, Mapper mapper) { List futures = st…
如何使用Java驱动程序获得Cassandra列的TTL？
如何使用DataStax驱动程序在Java中从Java中获得列的TTL或一排Cassandra行？ 请帮忙。 还有一种方法可以通过Java代码使用现有TTL更新一行的列？…
为什么使用Cassandra-Driver连接到DataStax Enterprise 6.8时，Keyspace Metadata仅是无效的？
我们需要支持 dataStax Enterprise 6.8 。通过引用 https://docs.datastax.com/en/in/install/6.8/install/dsebasicinstall.html 。 我们的代码确实支…
Cassandra Java驾驶员是否知道港口7000？
通常，端口9042配备了Cassandra簇种子主机，以连接到Cassandra群集进行CRUD操作。 Cassandra Java客户端驱动程序在客户与Cassandra群集建立连接之后，…
JPA问题映射Cassandra Java实体与Snake Case的表名
我正在使用以下驱动程序。 implementation 'com.datastax.astra:astra-spring-boot-starter:0.3.0' implementation 'com.datastax.oss:java-driver-co…
Java微服务的百分比负载平衡到Cassandra
我使用的是带有4个节点的Cassandra簇。在CPU内核和RAM方面，2个节点的资源比其他两个节点多得多。 现在，我正在使用DCAWAREROUNDROBIN负载平衡策略。…
Cassandra DataStax @Entity-Naterated类必须至少有一个属性定义
我在执行MVN清洁软件包/MVN清洁安装时使用了下面的实体类Java驱动程序4.1.x package com.xyz; import com.datastax.oss.driver.api.mapper.annotation…
我们如何从同一Spring Boot应用程序中创建两个单独的Cassandra簇？
我很难从Spring Boot应用程序连接到两个不同的群集。任务是从Cassandra上获得EC2的数据，并批量插入AWS Keyspace。我能够从Cassandra获得EC2的数据。 …
Scylladb是否支持最新版本的指标？
当我第一次启动 scylladb 时： Cluster cluster = Cluster.builder().addContactPoints("xx.xxx.xx.xxx").build(); Session session = cluster.connec…
- 共 1 页
- 1
