java - 如何设置cassandra的读取请求超时

Question

我尝试为 cassandra 创建具有不同读取请求超时的新端点。对于大数据请求，超时较大的端点会做出响应。我找到了带有 com.datastax.cassandra 驱动程序的 Scala 代码和带有 read_request_timeout 参数的 cassandra-default.yaml 。如何在 Cluster builder 或代码中的其他位置设置 read_request_timeout ？

Cluster
      .builder
      .addContactPoints(cassandraHost.split(","): _*)
      .withPort(cassandraPort)
      .withRetryPolicy(DefaultRetryPolicy.INSTANCE)
      .withLoadBalancingPolicy(
        new TokenAwarePolicy(DCAwareRoundRobinPolicy.builder().build())).build



# How long the coordinator should wait for read operations to complete
read_request_timeout_in_ms: 5000

Answer 1

使用以下方式在查询级别设置:

session.execute(
        new SimpleStatement("CQL HERE").setReadTimeoutMillis(65000));

如果您想在集群构建时进行设置，请使用:

Cluster cluster = Cluster.builder()
        .addContactPoint("127.0.0.1")
        .withSocketOptions(
                new SocketOptions()
                        .setConnectTimeoutMillis(2000))
        .build();

Socket Options