DataStreamAPI 与flink sql疑问

[张锴]

flink版本使用的是1.12.2.。请问如果在Dstream 上用一些Operater,比如map
,flatmap,process等，可以在其重写的方法中使用tableEnv.sqlQuery("xxx")
tableEnv.createTemporaryView(),这种sql吗，能这样结合吗？

[HunterXHunter]

你试过吗？



--
Sent from: http://apache-flink.147419.n8.nabble.com/

[Shengkai Fang]

Flink支持将DataStream 转换成一个 Table，然后通过API进行操作。如果想跟SQL相结合，可以将Table注册成一个
temporary view。

Best,
Shengkai

HunterXHunter <[hidden email]> 于2021年4月27日周二 上午9:46写道：

> 你试过吗？
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>