Cassandra
Cassandra source connector
Description
Read data from Apache Cassandra.
Key features
Options
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 |
host [string]
Cassandra
cluster address, the format is host:port
, allowing multiple hosts
to be specified. Such as
"cassandra1:9042,cassandra2:9042"
.
keyspace [string]
The Cassandra
keyspace.
cql [String]
The query cql used to search data though Cassandra session.
username [string]
Cassandra
user username.
password [string]
Cassandra
user password.
datacenter [String]
The Cassandra
datacenter, default is datacenter1
.
consistency_level [String]
The Cassandra
write consistency level, default is LOCAL_ONE
.
Examples
source {
Cassandra {
host = "localhost:9042"
username = "cassandra"
password = "cassandra"
datacenter = "datacenter1"
keyspace = "test"
cql = "select * from source_table"
plugin_output = "source_table"
}
}
Changelog
Change Log
Change | Commit | Version |
---|---|---|
[improve] cassandra connector options (#8608) | https://github.com/apache/seatunnel/commit/d9201108c | 2.3.10 |
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03 | 2.3.9 |
[Improve] Improve some connectors prepare check error message (#7465) | https://github.com/apache/seatunnel/commit/6930a25ed | 2.3.8 |
[Improve][Common] Introduce new error define rule (#5793) | https://github.com/apache/seatunnel/commit/9d1b2582b | 2.3.4 |
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755) | https://github.com/apache/seatunnel/commit/8de740810 | 2.3.4 |
[Feature][Connector V2] expose configurable options in Cassandra (#3681) | https://github.com/apache/seatunnel/commit/73f63a504 | 2.3.2 |
[Improve][build] Give the maven module a human readable name (#4114) | https://github.com/apache/seatunnel/commit/d7cd60105 | 2.3.1 |
[Improve][Project] Code format with spotless plugin. (#4101) | https://github.com/apache/seatunnel/commit/a2ab16656 | 2.3.1 |
[Feature][API & Connector & Doc] add parallelism and column projection interface (#3829) | https://github.com/apache/seatunnel/commit/b9164b8ba | 2.3.1 |
[Improve][Connector-V2] The log outputs detailed exception stack information (#3805) | https://github.com/apache/seatunnel/commit/d0c6217f2 | 2.3.1 |
[Improve][Connector-V2][Cassandra] Unified exception for cassandra source & sink connector (#3435) | https://github.com/apache/seatunnel/commit/28868797b | 2.3.0 |
[Feature][Connector-V2][Cassandra] Add Cassandra Source And Sink Connector (#3229) | https://github.com/apache/seatunnel/commit/12268a6f4 | 2.3.0 |