flink版本使用的是1.12.2.。请问如果在Dstream 上用一些Operater,比如map
,flatmap,process等,可以在其重写的方法中使用tableEnv.sqlQuery("xxx")
tableEnv.createTemporaryView(),这种sql吗,能这样结合吗?
- DataStreamAPI 与flink sql疑问 张锴
- Re: DataStreamAPI 与flink sql疑问 HunterXHunter
- Re: DataStreamAPI 与flink sql疑问 Shengkai Fang
