Hi, I'm trying to integrate a Cassandra sink in my project but honestly I'm a bit confused because I don't find any examples of use.
I want just to populate a table and query it on a single node instance of Cassandra. The only one link I found is: https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/cassandra.html <https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/cassandra.html> but I have problems also with imports: import org.apache.flink.streaming.connectors.cassandra.CassandraTupleSink; import org.apache.flink.streaming.connectors.cassandra.ClusterBuilder; not recognised by eclipse. I have added dependency in pom.xml file: <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-connector-cassandra_2.10</artifactId> <version>${flink.version}</version> <scope>provided</scope> </dependency> Please, can you provide me some examples of use of Cassandra and clarify me why Cassandra classes are not recognised? Thanks in advance, Andrea -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Writing-on-Cassandra-tp14744.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
