設定例:
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 |
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 |
カスタムクエリです。任意です。 |