public class NamedCassandraAggregationRepository extends CassandraAggregationRepository
CassandraAggregationRepository
using 2
columns as primary key: name (partition key) and key (clustering key).Constructor and Description |
---|
NamedCassandraAggregationRepository() |
NamedCassandraAggregationRepository(com.datastax.driver.core.Cluster cluster,
String keyspace,
String name) |
NamedCassandraAggregationRepository(com.datastax.driver.core.Session session,
String name) |
Modifier and Type | Method and Description |
---|---|
String |
getName() |
void |
setName(String name) |
add, confirm, doStart, doStop, get, getDeadLetterUri, getExchangeColumn, getExchangeIdColumn, getKeys, getMaximumRedeliveries, getPKColumns, getPKValues, getPrefixPKValues, getReadConsistencyLevel, getRecoveryIntervalInMillis, getSession, getTable, getTtl, getWriteConsistencyLevel, initSelectStatement, isAllowSerializedHeaders, isUseRecovery, recover, remove, scan, selectKeyIds, setAllowSerializedHeaders, setDeadLetterUri, setExchangeColumn, setExchangeIdColumn, setMaximumRedeliveries, setPKColumns, setPrefixPKValues, setReadConsistencyLevel, setRecoveryInterval, setRecoveryInterval, setRecoveryIntervalInMillis, setSession, setTable, setTtl, setUseRecovery, setWriteConsistencyLevel
public NamedCassandraAggregationRepository()
public NamedCassandraAggregationRepository(com.datastax.driver.core.Session session, String name)
Apache Camel