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

2020-11-15 文章 Danny Chan
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
>
>
>
>
> -- 原始邮件 --
> 发件人:
>   "user-zh"
> <
> danny0...@apache.org>;
> 发送时间: 2020年11月10日(星期二) 下午2:43
> 收件人: "user-zh"
> 主题: Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象
>
>
>
> 拿 BatchTableEnvironment 对象作什么用处呢 ? 我们有 TableEnvironmentInternal 但是不推荐使用。
>
> Asahi Lee <978466...@qq.com> 于2020年11月9日周一 下午5:09写道:
>
> > 是的,BatchTableEnvironment 对象
> >
> >
> >
> >
> > --&nbsp;原始邮件&nbsp;--
> > 发件人:
> >  
> "user-zh"
> >                    
> <
> > danny0...@apache.org&gt;;
> > 发送时间:&nbsp;2020年11月9日(星期一) 中午12:34
> > 收件人:&nbsp;"user-zh" >
> > 主题:&nbsp;Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象
> >
> >
> >
> > &gt;
> > &gt; BatchTableEnvironment 环境
> >
> >
> > 是说&nbsp; BatchTableEnvironment 对象吗
> >
> > Asahi Lee <978466...@qq.com&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环境,该如何获取?


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

2020-11-09 文章 Danny Chan
拿 BatchTableEnvironment 对象作什么用处呢 ? 我们有 TableEnvironmentInternal 但是不推荐使用。

Asahi Lee <978466...@qq.com> 于2020年11月9日周一 下午5:09写道:

> 是的,BatchTableEnvironment 对象
>
>
>
>
> -- 原始邮件 --
> 发件人:
>   "user-zh"
> <
> danny0...@apache.org>;
> 发送时间: 2020年11月9日(星期一) 中午12:34
> 收件人: "user-zh"
> 主题: Re: flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象
>
>
>
> >
> > BatchTableEnvironment 环境
>
>
> 是说  BatchTableEnvironment 对象吗
>
> Asahi Lee <978466...@qq.com> 于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环境,该如何获取?


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

2020-11-08 文章 Danny Chan
>
> BatchTableEnvironment 环境


是说  BatchTableEnvironment 对象吗

Asahi Lee <978466...@qq.com> 于2020年11月9日周一 上午10:48写道:

> 你好!
>       我使用的是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环境,该如何获取?