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 열이 없으며 다른 데이터 모델을 사용하도록 확장할 수 있습니다.

옵션기본값설명

테이블

CAMEL_AGGREGATION

테이블 이름

pkColumns

NAME,KEY

기본 키 열

exchangeIdColumn

EXCHANGE_ID

교환 Id 열

exchangeColumn

EXCHANGE

콘텐츠 열 교환

name

 

리포지토리 이름, NAME 열에 사용된 값

ttl

 

자주 묻는 질문

writeConsistencyLevel

 

교환 삽입/삭제에 사용되는 일관성 수준: ANY,ONE,TWO,QUORUM,LOCAL_QUORUM,"

readConsistencyLevel

 

Exchange 읽기/확인에 사용되는 일관성 수준: one,TWO,QUORUM,LOCAL_QUORUM,"