Re: Table API in process function

2023-10-15 Thread Feng Jin
Hi Yashoda, I think this is not a reasonable way and it is not supported at the moment. I suggest that you can convert the DataStream generated by windowsAll into a Table, and then use the TableAPI. AllWindowProcess -> ConvertDataStreamToTable -> ProcessUsingTableAPI Best, Feng On Fri, Oct 1

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