Thanks Austin. I can make use of Rich functions to solve my problem. Thanks Yashoda
On Wed, Feb 15, 2023 at 12:42 AM Austin Cawley-Edwards < austin.caw...@gmail.com> wrote: > (note: please keep user@flink.apache.org included in replies) > > Ah, I see. Then no, this is not provided by Flink. When I've used > dependency inject with Flink in the past, I instantiated everything in the > `open()` method of the Flink Rich* classes. Could you solve this by having > a common base Sink class or builder that does the configuring? I'm just > wondering why it's necessary to solve it in Flink itself. > > Best, > Austin > > On Tue, Feb 14, 2023 at 11:05 AM Yashoda Krishna T < > yashoda.kris...@unbxd.com> wrote: > >> This is my use case. >> I have a sink function to push streaming data to S3. And I have a class >> lets call S3ConnProvider that provides me a connection object to S3, and a >> class lets say S3Util that has functions over S3 which injects >> S3ConnProvider. >> If dependency injection works I can inject S3Util alone in my >> SinkFunction class. If not I have to initialize S3ConnProvider first and >> then S3Util. >> This can become complex if there are too many initializations >> required depending on the use case. >> >>>
