Re: Accessing Cassandra for reading and writing

2017-11-24 Thread Fabian Hueske
Hi Andre, Do you have a batch or streaming use case? Flink provides Cassandra Input and OutputFormats for DataSet (batch) jobs and a Cassandra Sink for DataStream applications. The is no Cassandra source for DataStream applications. Regarding your error, this looks more like a Zepplin configurati

Accessing Cassandra for reading and writing

2017-11-17 Thread André Schütz
Hi, 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 followi