72.7. 집계 리포지토리
NamedCassandraAggregationRepository 는 다음과 같습니다.
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;
또는 Aggregation Repository 에는 NAME 열이 없으며 다른 데이터 모델을 사용하도록 확장할 수 있습니다.
| 옵션 | Default | 설명 |
|---|---|---|
|
|
| 테이블 이름 |
|
|
| 기본 키 열 |
|
|
| 교환 ID 열 |
|
|
| 교환 콘텐츠 열 |
|
|
리포지토리 이름, | |
|
| 사용할 수 있는 교환 시간 | |
|
|
교환을 삽입/삭제하는 데 사용되는 일관성 수준: | |
|
|
교환 |