Building Dynamic SQL using contents of Map datastructure

[Yogesh Rao]

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