ddxygq / ddxygq.github.io

柯广的博客
http://www.ikeguang.com/
0 stars 0 forks source link

flink中数据与表的相互转换 | 柯广的博客 #103

Open ddxygq opened 4 years ago

ddxygq commented 4 years ago

http://www.ikeguang.com/2019/05/07/flink-stream-table/

flink中的datastream转换为table,便于进行sql查询;有时候,需要将table转换为datastream,再将数据保存到外部系统。 1、table 转换为datastream或者dataset将表转换为DataStream将a转换Table为a 有两种模式DataStream: 追加模式(toAppendStream):只有在动态Table仅通过INSERT更改修改时才能使用此