PyFlink 中间表

哪位大佬知道Flink 1.10 PyFlink支持中间表 或者支持这种写法吗
  source = st_env.scan("source_kafka_ifang_dkt_log")
  dim_table = source.select("`cluster`, `caller`, `cid`,`content`, `ip` `path`, `type`")
  st_env.register_table('dim_table', dim_table)




[hidden email]

[Xingbo Huang]

Hi,

支持

Best,
Xingbo

[hidden email] <[hidden email]> 于2020年8月17日周一 下午7:55写道：

> 哪位大佬知道Flink 1.10 PyFlink支持中间表 或者支持这种写法吗
>   source = st_env.scan("source_kafka_ifang_dkt_log")
>   dim_table = source.select("`cluster`, `caller`, `cid`,`content`, `ip`
> `path`, `type`")
>   st_env.register_table('dim_table', dim_table)
>
>
>
>
> [hidden email]
>