Thanks Yuxia for the proposal. > CALL [catalog_name.][database_name.]procedure_name ([ expression [, > expression]* ] )
The expression can be a function call. Does this need to be a function call? Do you have some example? > Procedure returns T[] Procedure looks like a TableFunction, do you consider using Collector something like TableFunction? (Supports large amount of data) Best, Jingsong On Mon, May 29, 2023 at 2:33 PM yuxia <luoyu...@alumni.sjtu.edu.cn> wrote: > > Hi, everyone. > > I’d like to start a discussion about FLIP-311: Support Call Stored Procedure > [1] > > Stored procedure provides a convenient way to encapsulate complex logic to > perform data manipulation or administrative tasks in external storage > systems. It's widely used in traditional databases and popular compute > engines like Trino for it's convenience. Therefore, we propose adding support > for call stored procedure in Flink to enable better integration with external > storage systems. > > With this FLIP, Flink will allow connector developers to develop their own > built-in stored procedures, and then enables users to call these predefiend > stored procedures. > > Looking forward to your feedbacks. > > [1]: > https://cwiki.apache.org/confluence/display/FLINK/FLIP-311%3A+Support+Call+Stored+Procedure > > Best regards, > Yuxia
