flink 动态表输出问题

[金圣哲]

各位Flink社区大佬，
 你们好:

请教一下:

问题是 flink sql实现动态表之后,想基于动态表进行查询定时输出, 各位大神有什么实现的思路吗感激不尽.

SQL 1: tableEnv.sqlQuery("select date_id, id, latest(status, utime) as status, latest(user_id, utime) as user_id from waybillAppendTable group by date_id, id");

查询SQL2:tableEnv.sqlQuery("select date_id, user_id, status as status ,count(status) as status_count from " + waybillTbable + "  group by date_id,status,user_id”);

希望能每分钟输出查询SQL2的结果呢!!!


感激不尽