?????? flink 1.11.2 ????????blink????????BatchTableEnvironment????

Fri, 13 Nov 2020 00:06:10 -0800 

BatchTableEnvironment????????????table to dataset; dataset to table




------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??11??10??(??????) ????2:43
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;Re: flink 1.11.2 ????????blink????????BatchTableEnvironment????



?? BatchTableEnvironment ???????????????? ?? ?????? TableEnvironmentInternal 
????????????????

Asahi Lee <[email protected]&gt; ??2020??11??9?????? ????5:09??????

&gt; ??????BatchTableEnvironment ????
&gt;
&gt;
&gt;
&gt;
&gt; ------------------&amp;nbsp;????????&amp;nbsp;------------------
&gt; ??????:
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 "user-zh"
&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 <
&gt; [email protected]&amp;gt;;
&gt; ????????:&amp;nbsp;2020??11??9??(??????) ????12:34
&gt; ??????:&amp;nbsp;"user-zh"<[email protected]&amp;gt;;
&gt;
&gt; ????:&amp;nbsp;Re: flink 1.11.2 
????????blink????????BatchTableEnvironment????
&gt;
&gt;
&gt;
&gt; &amp;gt;
&gt; &amp;gt; BatchTableEnvironment ????
&gt;
&gt;
&gt; ????&amp;nbsp; BatchTableEnvironment ??????
&gt;
&gt; Asahi Lee <[email protected]&amp;gt; ??2020??11??9?????? ????10:48??????
&gt;
&gt; &amp;gt; ??????
&gt; &amp;gt; &amp;amp;nbsp; &amp;amp;nbsp; &amp;amp;nbsp; ??????????flink
&gt; 1.11.2??????????????????????blink??batch????????????????????????
&gt; &amp;gt; // ****************** // BLINK BATCH QUERY // ******************
&gt; import
&gt; &amp;gt; org.apache.flink.table.api.EnvironmentSettings; import
&gt; &amp;gt; org.apache.flink.table.api.TableEnvironment; EnvironmentSettings
&gt; bbSettings
&gt; &amp;gt; =
&gt; &amp;gt;
&gt; EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
&gt; &amp;gt; TableEnvironment bbTableEnv =
&gt; &amp;gt;
&gt; 
TableEnvironment.create(bbSettings);??????????????????????????????????????????blink??batch??????????????????????BatchTableEnvironment??????????????????

回复