flink1.12.x Table API 和 SQL:开发流程-动态表 和 持续查询

说明

当流中有新数据到来,动态表中会插入一行记录,基于 该动态表定义的 select SQL,就要执行一次查询,这就是 持续查询

查询结果放在 结果表中,结果表也是动态表

查询方式

  • SQL
  • table api

例子

关键代码

Table res=stEnv.sqlQuery("select * from t_order where price>60");
System.out.println("Schema信息:");
//打印Schema
res.printSchema();

原文出处:/show_1IX4ElNigTl9.html