This component aims at integrating Cassandra 2.0+ using the CQL3 API (not the Thrift API). It's based on Cassandra Java Driver provided by DataStax.
URI | Description |
---|---|
cql:localhost/keyspace | single host, default port, usual for testing |
cql:host1,host2/keyspace | multi host, default port |
cql:host1:host2:9042/keyspace | |
cql:host1:host2 | default port and keyspace |
cql:bean:sessionRef | provided Session reference |
cql:bean:clusterRef/keyspace | provided Cluster reference |
Option | Description |
---|---|
clusterName | cluster name |
username and password | session authentication |
cql | CQL query |
consistencyLevel | ANY , ONE , TWO , QUORUM , LOCAL_QUORUM ... |
resultSetConversionStrategy | how is ResultSet converted transformed into message body ALL , ONE , LIMIT_10 , LIMIT_100 ... |
Headers:
CamelCqlQuery
(optional, String): CQL queryBody
Object[]
or Collection<Object>
): CQL query parameters to be boundBody
List<Row>
if resultSetConversionStrategy is ALL or LIMIT_10Row
if resultSetConversionStrategy is ONE