Hi Yogesh,
I think you need to build the dynamic SQL statement in your service and
then submit the SQL to flink cluster.
Best,
Shammon FY
On Mon, Jun 12, 2023 at 9:15 PM Yogesh Rao <yog...@gmail.com> wrote:
> Hi,
>
> Is there a way we can build a dynamic SQL in Flink from contents of Map ?
>
> Essentially trying to do achieve something like below
>
> StringBuilder builder = new StringBuilder("INSERT INTO sampleSink SELECT "
> );
>
> builder.append("getColumnsFromMap(dataMap), ");
>
> builder.append(" FROM Data").toString();
>
>
> Here getColumnsFromMap is registered as ScalarFunction which would return
> array of Strings basically column names.
>
>
> Regards,
>
> -Yogesh
>
