Cassandra Dictionary ソース

ClickHouse で Cassandra を Dictionary ソースとして設定します。

設定例:

DDL

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

column_family フィールドまたは where フィールドは、query フィールドと併用できません。また、column_family フィールドと query フィールドのいずれか一方は必ず指定する必要があります。