RichMapFunction to convert tuple of strings to DataStream[(String,String)]

Hi, As I am new and I am facing one issue so I came across RichMapFunction. How can I use RichMapFunction to convert a tuple of strings to datastream? If not how can I do it apart from using StreamExecutionEnvironment? Thanks, Sid

Re: RichMapFunction to convert tuple of strings to DataStream[(String,String)]

Hi Francis, What I am trying to do is you can see over here https://stackoverflow.com/questions/70592174/richsinkfunction-for-cassandra-in-flink/70593375?noredirect=1#comment124796734_70593375 On Fri, Jan 7, 2022 at 5:07 AM Francis Conroy wrote: > Hi Siddhesh, > > How are you getting this tupl

Re: RichMapFunction to convert tuple of strings to DataStream[(String,String)]

Hi Sid, I don't see on the stackoverflow explanation of what are you trying to do here (no mentions of MapFunction or a tuple). If you want to create a `DataStream` from some a pre existing/static Tuple of Strings, the easiest thing would be to convert the tuple to a collection/iterator and use `

Re: RichMapFunction to convert tuple of strings to DataStream[(String,String)]

Hi Piotr, Thanks for the reply. I was looking for how to create a DataStream under a process function since using that I had to call something else but I came across one of Fabian's posts where he mentioned that this way of creating DS is not "encouraged and tested". So, I figured out an alternate

Re: RichMapFunction to convert tuple of strings to DataStream[(String,String)]

Glad to hear it. Best, Piotrek pon., 10 sty 2022 o 20:08 Siddhesh Kalgaonkar napisał(a): > Hi Piotr, > > Thanks for the reply. I was looking for how to create a DataStream under a > process function since using that I had to call something else but I came > across one of Fabian's posts where he