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 <francis.con...@switchdin.com> wrote: > Hi Siddhesh, > > How are you getting this tuple of strings into the system? I think this is > the important question, you can create a DataStream in many ways, from a > collection, from a source, etc but all of these rely on the > ExecutionEnvironment you're using. > A RichMapFunction doesn't produce a datastream directly, it's used in the > context of the StreamExecutionEnvironment to create a stream i.e. > DataStream.map([YourRichMapFunction]) this implies that you already need a > datastream to transform a datastream using a mapFunction > (MapFunction/RichMapFunction) > Francis > > On Fri, 7 Jan 2022 at 01:48, Siddhesh Kalgaonkar < > kalgaonkarsiddh...@gmail.com> wrote: > >> 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 >> > > This email and any attachments are proprietary and confidential and are > intended solely for the use of the individual to whom it is addressed. Any > views or opinions expressed are solely those of the author and do not > necessarily reflect or represent those of SwitchDin Pty Ltd. If you have > received this email in error, please let us know immediately by reply email > and delete it from your system. You may not use, disseminate, distribute or > copy this message nor disclose its contents to anyone. > SwitchDin Pty Ltd (ABN 29 154893857) PO Box 1165, Newcastle NSW 2300 > Australia >
