Flink SQL ??????????????

[1048262223]

Hi all


??????????
Flink ??????1.10
Planner??old planner / blink planner



??????????Flink SQL????

source??????????????Tuple2.of(1, "{\"name\": \"a\"}");




query??select a.id, a.name, a.name from (select id, body_json_to_map(name) as 
name from data) a




sink??print




udf??body_json_to_map

????????

public Map<String, String&gt; eval(String json) {

&nbsp; &nbsp; logger.info("a");

&nbsp; &nbsp; return JsonUtil.fromJsonToMap(json);

}




??????????

a

a

1,{name=a},{name=a}

a

a

1,{name=a},{name=a}

a

a

1,{name=a},{name=a}




??????

????????????????????body_json_to_map?? json ????????????????????????????????

?????????? old planner ?? blink planner 
??????????????????????????????????????????????






select id,&nbsp;body_json_to_map(name),&nbsp;body_json_to_map(name)&nbsp;from 
data




????????????????

?? group by ??????????????????




?????????????????? flink planner ??????????????????????????????




Best,

Yichao Yang