72.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 열 |
|
|
| 콘텐츠 열 교환 |
|
|
리포지토리 이름, | |
|
| 자주 묻는 질문 | |
|
|
교환 삽입/삭제에 사용되는 일관성 수준: | |
|
|
Exchange 읽기/확인에 사용되는 일관성 수준: |