说明
如果想对 结果表 中的数据做进一步处理,如果 打印数据 等操作,就需要将 结果表 转成 流
结果表是动态表,每来一条数据,就会向流中放一条数据
例子
关键代码:
/*
将计算后的数据,append到ds,适用于普通查询
分组查询,来一条记录,需要重新计算,并更新原结果, toAppendStream 方法不支持,会报错
*/
DataStream<Order> dsRes = stEnv.toAppendStream(res, Order.class);
dsRes.print();
env.execute();
方式
上图是简单查询,如果是 聚合查询,查询结果是动态改变变的,详见 flink1.12.x Table API 和 SQL:更新模式:追加Append、撤回Retract、更新插入Upsert
参考:
https://cloud.tencent.com/developer/article/1483316
