flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: Applying an void function to DataStream
Date Thu, 19 Apr 2018 13:19:58 GMT
Hi Soheil,

Flink supports the type "java.lang.Void" which you can use in this case.


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?

View raw message