Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象

Sun, 15 Nov 2020 23:32:53 -0800 

DataSet 已经是社区准备 deprecate 的 API 了，不建议再使用。1.12 版本后推荐统一使用 DataStream，使用
sqlQuery 接口拿到 table 对象后转成 DataStream。

Asahi Lee <978466...@qq.com> 于2020年11月13日周五 下午4:05写道：

> BatchTableEnvironment对象可以进行table to dataset; dataset to table
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "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环境，该如何获取？

回复