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