Hi, we would like to read and write via Flink from and to a Cassandra Cluster.
Our current Apache Zeppelin compilation contains: - Apache Flink 1.3.2 - flink-connector-cassandra_2.11-1.3.2.jar is located in the /lib/ folder of the flink installation A Cassandra DB is running and can be accessed via Zeppelin by using the Cassandra interpreter. When using the following import, we get an 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._ Our question is: What do we have to do to read and write from and to Cassandra by using the Apache Flink interpreter within a notebook. Does anybody have an example? Any help would be great. Kind regards, Andre
