73.7. 集計リポジトリー
NamedCassandraAggregationRepository は、次のように Cassandra テーブルに相関キーによる交換を格納します。
CAMEL_AGGREGATION.cql
CREATE TABLE CAMEL_AGGREGATION (
NAME varchar, -- Repository name
KEY varchar, -- Correlation id
EXCHANGE_ID varchar, -- Exchange id
EXCHANGE blob, -- Serialized exchange
PRIMARY KEY (NAME, KEY)
) WITH compaction = {'class':'LeveledCompactionStrategy'}
AND gc_grace_seconds = 86400;
または、CassandraAggregationRepository には NAME 列がなく、別のデータモデルを使用するように拡張できます。
| オプション | デフォルト | 説明 |
|---|---|---|
|
|
| テーブル名 |
|
|
| プライマリーキー列 |
|
|
| 交換 ID 列 |
|
|
| 交換内容欄 |
|
|
リポジトリー名、 | |
|
| 生存時間の交換 | |
|
|
交換の挿入/削除に使用される一貫性レベル: | |
|
|
交換の読み取り/チェックに使用される整合性レベル: |
