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