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
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
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
`
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
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