Hi Soheil,
Flink supports the type "java.lang.Void" which you can use in this case.
Regards,
Timo
Am 19.04.18 um 15:16 schrieb Soheil Pourbafrani:
Hi, I have a void function that takes a String, parse it and write it
into Cassandra (Using pure java, not Flink Cassandra connector). Using
Apache Flink Kafka connector, I've got some data into
DataStream<String>. Now I want to apply Parse function to each message
in DataStream<String>, but as the Parse function returns nothing (is
void), I got the error
no instance of type variable R exists so that void conforms to R
Is there any way to do such process using apache Flink?
