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

[Asahi Lee]

你好！
      我使用的是flink 1.11.2版本，官网的文档中说明blink的batch执行环境以如下方式获取：
// ****************** // BLINK BATCH QUERY // ****************** import org.apache.flink.table.api.EnvironmentSettings; import org.apache.flink.table.api.TableEnvironment; EnvironmentSettings bbSettings = EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build(); TableEnvironment bbTableEnv = TableEnvironment.create(bbSettings);除过上述的方法之外，是否还有其他方式获取到blink的batch执行环境？而我需要的是BatchTableEnvironment环境，该如何获取？

[Danny Chan-2]

>
> BatchTableEnvironment 环境


是说  BatchTableEnvironment 对象吗

Asahi Lee <[hidden email]> 于2020年11月9日周一 上午10:48写道：

> 你好！
> &nbsp; &nbsp; &nbsp; 我使用的是flink 1.11.2版本，官网的文档中说明blink的batch执行环境以如下方式获取：
> // ****************** // BLINK BATCH QUERY // ****************** import
> org.apache.flink.table.api.EnvironmentSettings; import
> org.apache.flink.table.api.TableEnvironment; EnvironmentSettings bbSettings
> =
> EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
> TableEnvironment bbTableEnv =
> TableEnvironment.create(bbSettings);除过上述的方法之外，是否还有其他方式获取到blink的batch执行环境？而我需要的是BatchTableEnvironment环境，该如何获取？

[Asahi Lee]

是的，BatchTableEnvironment 对象




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年11月9日(星期一) 中午12:34
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象



&gt;
&gt; BatchTableEnvironment 环境


是说&nbsp; BatchTableEnvironment 对象吗

Asahi Lee <[hidden email]&gt; 于2020年11月9日周一 上午10:48写道：

&gt; 你好！
&gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; 我使用的是flink 1.11.2版本，官网的文档中说明blink的batch执行环境以如下方式获取：
&gt; // ****************** // BLINK BATCH QUERY // ****************** import
&gt; org.apache.flink.table.api.EnvironmentSettings; import
&gt; org.apache.flink.table.api.TableEnvironment; EnvironmentSettings bbSettings
&gt; =
&gt; EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
&gt; TableEnvironment bbTableEnv =
&gt; TableEnvironment.create(bbSettings);除过上述的方法之外，是否还有其他方式获取到blink的batch执行环境？而我需要的是BatchTableEnvironment环境，该如何获取？

[Danny Chan-2]

拿 BatchTableEnvironment 对象作什么用处呢 ？ 我们有 TableEnvironmentInternal 但是不推荐使用。

Asahi Lee <[hidden email]> 于2020年11月9日周一 下午5:09写道：

> 是的，BatchTableEnvironment 对象
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> [hidden email]&gt;;
> 发送时间:&nbsp;2020年11月9日(星期一) 中午12:34
> 收件人:&nbsp;"user-zh"<[hidden email]&gt;;
>
> 主题:&nbsp;Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象
>
>
>
> &gt;
> &gt; BatchTableEnvironment 环境
>
>
> 是说&nbsp; BatchTableEnvironment 对象吗
>
> Asahi Lee <[hidden email]&gt; 于2020年11月9日周一 上午10:48写道：
>
> &gt; 你好！
> &gt; &amp;nbsp; &amp;nbsp; &amp;nbsp; 我使用的是flink
> 1.11.2版本，官网的文档中说明blink的batch执行环境以如下方式获取：
> &gt; // ****************** // BLINK BATCH QUERY // ******************
> import
> &gt; org.apache.flink.table.api.EnvironmentSettings; import
> &gt; org.apache.flink.table.api.TableEnvironment; EnvironmentSettings
> bbSettings
> &gt; =
> &gt;
> EnvironmentSettings.newInstance().useBlinkPlanner().inBatchMode().build();
> &gt; TableEnvironment bbTableEnv =
> &gt;
> TableEnvironment.create(bbSettings);除过上述的方法之外，是否还有其他方式获取到blink的batch执行环境？而我需要的是BatchTableEnvironment环境，该如何获取？

[Asahi Lee]

BatchTableEnvironment对象可以进行table to dataset; dataset to table




------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年11月10日(星期二) 下午2:43
收件人:&nbsp;"user-zh"<[hidden email]&gt;;

主题:&nbsp;Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象



拿 BatchTableEnvironment 对象作什么用处呢 ？ 我们有 TableEnvironmentInternal 但是不推荐使用。

Asahi Lee <[hidden email]&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; [hidden email]&amp;gt;;
&gt; 发送时间:&amp;nbsp;2020年11月9日(星期一) 中午12:34
&gt; 收件人:&amp;nbsp;"user-zh"<[hidden email]&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 <[hidden email]&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环境，该如何获取？

[Danny Chan-2]

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

Asahi Lee <[hidden email]> 于2020年11月13日周五 下午4:05写道：

> BatchTableEnvironment对象可以进行table to dataset; dataset to table
>
>
>
>
> ------------------&nbsp;原始邮件&nbsp;------------------
> 发件人:
>                                                   "user-zh"
>                                                                     <
> [hidden email]&gt;;
> 发送时间:&nbsp;2020年11月10日(星期二) 下午2:43
> 收件人:&nbsp;"user-zh"<[hidden email]&gt;;
>
> 主题:&nbsp;Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象
>
>
>
> 拿 BatchTableEnvironment 对象作什么用处呢 ？ 我们有 TableEnvironmentInternal 但是不推荐使用。
>
> Asahi Lee <[hidden email]&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; [hidden email]&amp;gt;;
> &gt; 发送时间:&amp;nbsp;2020年11月9日(星期一) 中午12:34
> &gt; 收件人:&amp;nbsp;"user-zh"<[hidden email]&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 <[hidden email]&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环境，该如何获取？