Cassandra source connector
Read data from Apache Cassandra.
name | type | required | default value |
---|---|---|---|
host | String | Yes | - |
keyspace | String | Yes | - |
cql | String | Yes | - |
username | String | No | - |
password | String | No | - |
datacenter | String | No | datacenter1 |
consistency_level | String | No | LOCAL_ONE |
Cassandra
cluster address, the format is host:port
, allowing multiple hosts
to be specified. Such as "cassandra1:9042,cassandra2:9042"
.
The Cassandra
keyspace.
The query cql used to search data though Cassandra session.
Cassandra
user username.
Cassandra
user password.
The Cassandra
datacenter, default is datacenter1
.
The Cassandra
write consistency level, default is LOCAL_ONE
.
source { Cassandra { host = "localhost:9042" username = "cassandra" password = "cassandra" datacenter = "datacenter1" keyspace = "test" cql = "select * from source_table" result_table_name = "source_table" } }