Конфигурация для оптимизации драйвера Cassandra Java / Scala для интенсивных операций ввода-вывода? - PullRequest
Новая
       3

Конфигурация для оптимизации драйвера Cassandra Java / Scala для интенсивных операций ввода-вывода?

0 голосов
/ 29 ноября 2018

Я не могу найти какую-либо конфигурацию для опции объединения на cassandra (используя Scala, но я могу управлять с помощью примеров Java).Кто-нибудь когда-либо делал это раньше?

Редактировать : я использую драйвер ja 1005 * с scala extra .Моя цель - оптимизировать интенсивное приложение ввода-вывода (запросы на чтение из БД).

Ответы [ 2 ]

0 голосов
/ 30 ноября 2018

Необходимо выполнить настройку, как описано в документации для драйвера .Cassandra 2.0 использует протокол V2, который ограничивает количество запросов в полете, поэтому у вас есть только возможность увеличить количество соединений, открытых от водителя к Cassandra.По умолчанию для протокола V2 имеет минимум 2 соединения и максимум 2 соединения.Вы можете увеличить его до 4 минимальных и 10 максимальных с помощью следующего кода: 

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

; при создании объектов Cluster / Session необходимо добавить опции: 

Cluster cluster = Cluster.builder()
    .withContactPoints("127.0.0.1")
    .withPoolingOptions(poolingOptions)
    .build();
0 голосов
/ 29 ноября 2018

Поскольку вы находитесь в среде JVM, вы можете просто загрузить рабочие конфигурации Java через Scala.

...