Пример настроек:
SOURCE(CASSANDRA(
host 'localhost'
port 9042
user 'username'
password 'qwerty123'
keyspace 'database_name'
column_family 'table_name'
allow_filtering 1
partition_key_prefix 1
consistency 'One'
where '"SomeColumn" = 42'
max_threads 8
query 'SELECT id, value_1, value_2 FROM database_name.table_name'
))<source>
<cassandra>
<host>localhost</host>
<port>9042</port>
<user>username</user>
<password>qwerty123</password>
<keyspase>database_name</keyspase>
<column_family>table_name</column_family>
<allow_filtering>1</allow_filtering>
<partition_key_prefix>1</partition_key_prefix>
<consistency>One</consistency>
<where>"SomeColumn" = 42</where>
<max_threads>8</max_threads>
<query>SELECT id, value_1, value_2 FROM database_name.table_name</query>
</cassandra>
</source>Поля настроек:
| Настройка | Описание |
|---|---|
host |
Хост Cassandra или список хостов, разделённых запятыми. |
port |
Порт серверов Cassandra. Если не указан, используется порт по умолчанию 9042. |
user |
Имя пользователя Cassandra. |
password |
Пароль пользователя Cassandra. |
keyspace |
Имя keyspace (базы данных). |
column_family |
Имя семейства столбцов (таблицы). |
allow_filtering |
Флаг, разрешающий или запрещающий потенциально затратные условия для столбцов ключа кластеризации. Значение по умолчанию — 1. |
partition_key_prefix |
Количество столбцов ключа партиционирования в первичном ключе таблицы Cassandra. Обязательно для словарей с составным ключом. Порядок столбцов ключа в определении словаря должен совпадать с порядком в Cassandra. Значение по умолчанию — 1 (первый столбец ключа является ключом партиционирования, а остальные столбцы ключа — ключами кластеризации). |
consistency |
Уровень согласованности. Возможные значения: One, Two, Three, All, EachQuorum, Quorum, LocalQuorum, LocalOne, Serial, LocalSerial. Значение по умолчанию — One. |
where |
Необязательное условие отбора. |
max_threads |
Максимальное число потоков, используемых для загрузки данных из нескольких партиций в словарях с составным ключом. |
query |
Пользовательский запрос. Необязательный параметр. |