DI in flink

Does flink support dependency injection in flink task functions in java? If not is there an alternative?

Re: DI in flink

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

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

Re: Flink SQL Lateral Join

Forgot to mention, Iam using flink version 1.18.1 On Wed, Apr 23, 2025 at 1:00 AM Yashoda Krishna T < yashoda.kris...@netcoreunbxd.com> wrote: > Hi, > I have tried using lateral join on two tables in flink sql similar to the > example > > > https://gith

Flink SQL Lateral Join

Hi, I have tried using lateral join on two tables in flink sql similar to the example https://github.com/apache/flink/blob/c724168fad4215626b5596dd63cb66e477948aa0/flink-examples/flink-examples-table/src/main/java/org/apache/flink/table/examples/java/basics/UpdatingTopCityExample.java#L130 But I