代码之家  ›  专栏  ›  技术社区  ›  Ismail H

为密集IO操作优化cassandra java/scala驱动程序的配置?

  •  0
  • Ismail H  · 技术社区  · 6 年前

    我在cassandra上找不到池选项的任何配置(使用Scala,但我可以使用Java示例进行管理)。以前有人做过吗?

    编辑 :我用的是j ava driver with scala extra . 我的目标是优化密集型IO应用程序(DB读取查询)。

    2 回复  |  直到 4 年前
        1
  •  1
  •   Alex Ott    6 年前

    您需要按照中所述进行调整 driver's documentation for protocol V2 it has 至少2个连接,最多2个连接。您可以使用以下代码将其最小值增加到4,最大值增加到10:

    PoolingOptions poolingOptions = new PoolingOptions();
    poolingOptions
        .setConnectionsPerHost(HostDistance.LOCAL,  4, 10)
        .setConnectionsPerHost(HostDistance.REMOTE, 2, 4);
    

    创建群集/会话对象时,应添加以下选项:

    Cluster cluster = Cluster.builder()
        .withContactPoints("127.0.0.1")
        .withPoolingOptions(poolingOptions)
        .build();
    
        2
  •  -1
  •   New Alexandria    6 年前