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

The only one link I found is: 

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:


Please, can you provide me some examples of use of Cassandra and clarify me
why Cassandra classes are not recognised?

Thanks in advance, 

View this message in context: 
Sent from the Apache Flink User Mailing List archive. mailing list archive at 

Reply via email to