DI in flink

2023-02-14 Thread Yashoda Krishna T
Does flink support dependency injection in flink task functions in java? If not is there an alternative?

Re: DI in flink

2023-02-14 Thread Yashoda Krishna T
27;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 >&

Table API in process function

2023-10-13 Thread Yashoda Krishna T
Is it possible to use table API inside a processAll window function . Lets say, the use case is process function should enrich for each element by querying some SQL queries over the entire elements in the window using table API. Is this case supported in flink? If not what is the suggested way Tha