Hey Jamie,
Here's a simple example that I modeled off of the github example (
https://github.com/apache/flink/blob/master/flink-streaming-connectors/flink-connector-cassandra/src/test/java/org/apache/flink/streaming/connectors/cassandra/example/CassandraTupleSinkExample.java).
Let me know if I'm d
This looks like a simple type mismatch. It's impossible to help with this
without seeing your code, though. Can you post it here? Thanks.
-Jamie
On Sun, Jun 19, 2016 at 3:17 PM, Eamon Kavanagh
wrote:
> Hey Mailing List,
>
> I'm trying to use the Cassandra connector that came out recently (
Hey Mailing List,
I'm trying to use the Cassandra connector that came out recently (
https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/connectors/cassandra.html)
in Scala but I'm having trouble with types when I use
CassandraSink.addSink(in: DataStream).
If I don't define the
