java - datastax java 驱动程序 - 如何为轻量级事务配置 LOCAL_SERIAL

标签 java cassandra datastax-enterprise datastax-java-driver datastax-startup

我们有 DSE 4.8.7 集群,有 3 个数据中心,每个数据中心 5 个节点。 Ww 有一个 RF 3, 3, 2 的 key 空间。

我们正在使用轻量级事务。

当执行涉及使用 RF2 关闭数据中心节点的操作时,我们会遇到轻量级事务问题,因为无法满足 SERIAL 一致性级别。

有没有办法更改驱动程序以使用 LOCAL_SERIAL 而不是 SERIAL?

最佳答案

有两种方法可以使用 DataStax java 驱动程序配置串行一致性级别:

<强> At a per statement level :

statement.setSerialConsistencyLevel(ConsistencyLevel.LOCAL_SERIAL);
session.execute(statement);

<强> Globally for all queries :

Cluster.builder()
    .withQueryOptions(new QueryOptions()
        .setSerialConsistencyLevel(ConsistencyLevel.LOCAL_SERIAL))
    .build();

关于java - datastax java 驱动程序 - 如何为轻量级事务配置 LOCAL_SERIAL,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38124307/

相关文章:

WEB-INF 之外的 Java .class 文件?

cassandra - 使用 Solr 集成时,DSE 创建的 Cassandra 索引的性质是什么?

datastax-enterprise - 在尝试使用 DSE graphloader 加载数据时,出现错误 - DSE Graph 未配置为处理查询

solr - DSE 6通过http创建solr核心

java - 适合初学者的简单 8 车游戏

java - 错误: “; Expected Not a statement ”

java - Base-64转Mat转换opencv

java - Cassandra 的读取性能在复制过程中几乎保持不变

spring-mvc - 在同一 jvm 中部署的多个 war 中使用 cassandra 驱动程序时出现 jmx 错误

java - 用于时间序列数据的 Cassandra Map Reduce