flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From André Schütz <an...@wegtam.com>
Subject Accessing Cassandra for reading and writing
Date Fri, 17 Nov 2017 12:22:11 GMT

we want to read and write from and to Cassandra.

We found the Flink-Cassandra connector and added the JAR to the lib
folder of the running Flink cluster (local machine).

Trying to access the Cassandra database by adding the import
to a notebook within Apache Zeppelin, resulted in the following error:

import org.apache.flink.streaming.connectors.cassandra._

error: object connectors is not a member of package org.apache.flink.streaming
import org.apache.flink.streaming.connectors.cassandra._

We have Flink 1.3.2 running.

It would be great to see an example of what to implement for reading
from Cassandra and another that uses the Cassandra Connector sink (the
example from the documentation gave us the error above).
We tried to find something but had no luck.

Kind regards,

View raw message