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



------------------ ???????? ------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<danny0...@apache.org&gt;;
????????:&nbsp;2020??11??10??(??????) ????2:43
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

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



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

Asahi Lee <978466...@qq.com&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; danny0...@apache.org&amp;gt;;
&gt; ????????:&amp;nbsp;2020??11??9??(??????) ????12:34
&gt; ??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&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 <978466...@qq.com&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??????????????????

回复