Scylla connector

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Scylla connector

Lian Jiang
Hi,

i am new to Flink. Is there scylla connector equivalent to the cassandra connector: https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/connectors/cassandra.html? Or can Flink use Scylla as a sink via the cassandra connector? Thanks.
Reply | Threaded
Open this post in threaded view
|

Re: Scylla connector

Elias Levy
Scylla is protocol compatible with Cassandra, so you can just use the Cassandra connector. Scylla has extended the Go gocql package to make it shard aware, but such an extension does not exist for the Cassandra Java driver.  That just means that the driver will sent requests to any shard on a node, rather than to the specific shard that will process the request, resulting in slightly higher load.

On Sun, Aug 11, 2019 at 11:06 PM Lian Jiang <[hidden email]> wrote:
Hi,

i am new to Flink. Is there scylla connector equivalent to the cassandra connector: https://ci.apache.org/projects/flink/flink-docs-release-1.8/dev/connectors/cassandra.html? Or can Flink use Scylla as a sink via the cassandra connector? Thanks.