flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Eamon Kavanagh <kavanagh.c.ea...@gmail.com>
Subject Cassamdra Connector in Scala
Date Sun, 19 Jun 2016 22:17:18 GMT
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 type it can't seem to properly infer it and if I do
define the type I still get an error saying there's a type mismatch.  The
compile errror is

*error: type arguments [(String, String, Int),Any] do not conform to method
addSink's type parameter bounds [IN,T <:
org.apache.flink.api.java.tuple.Tuple]*

Is this a Scala issue?  Should I switch over to Java?


Thanks!
Eamon

Mime
View raw message