??????flinksql source ????????????????????????

Tue, 14 Dec 2021 18:12:10 -0800 

????




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<jank...@163.com&gt;;
????????:&nbsp;2021??12??13??(??????) ????5:27
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;flinksql source ????????????????????????



??????????flinkSQL 
KafkaConnector??????????Source????????????????????????????????????


????????????
1?????????? &gt; source????????????????, ????????????????????????
2???????? ??????&gt;?????????? source vertex?? Source: 
TableSourceScan-&gt;Calc(select??);
??Calc??select..????cpu??????json??????????????????????????????????????Calc??????????????????????????????????kafka??????????????????????????


?????????????????????????? / ??????????????????

回复