Hi,
这个文档应该是1.9时更新漏掉了,我建个issue修复下。现在可以这样使用[1]:
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
EnvironmentSettings envSettings = EnvironmentSettings.newInstance()
.useOldPlanner()
.inStreamingMode()
.build();
StreamTableEnvironment tableEnvironment = StreamTableEnvironment.create(env,
envSettings);
Best,
Leonard Xu
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#create-a-tableenvironment
<https://ci.apache.org/projects/flink/flink-docs-master/dev/table/common.html#create-a-tableenvironment>
> 在 2020年6月12日,11:39,Zhou Zach <[email protected]> 写道:
>
>
>
> flink version 1.10.0
>
>
> 根据文档
> https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/streaming/temporal_tables.html#defining-temporal-table
> 想要Defining Temporal Table,但是没有发现getTableEnvironment。。
>
>
> val env = StreamExecutionEnvironment.getExecutionEnvironment
> val tEnv = TableEnvironment.getTableEnvironment(env)