说明
Table 可以转换为 DataStream 或 DataSet ,这样自定义流处理或批处理程序就可以继续在 Table API 或 SQL 查询的结果上运行了,比如:打印查询结果
将
Table转换为DataStream或DataSet时,需要 指定生成的数据类型,即:要将表的每一行转换成的数据类型
例子:DataStream<Row> dsRes2 = stEnv.toAppendStream(res, Row.class);有些流式查询,其结果是动态更新的,如:聚合查询,
select count(1) from table,来第一条数据,查询结果是1,来第二条数据,查询结果是2,应该删掉上一条结果转换有两种转换模式:追加(Append)模式和撤回(Retract)模式
详见:flink1.12.x Table API 和 SQL:更新模式:追加Append、撤回Retract、更新插入Upsert