flink 动态表输出问题

Mon, 05 Aug 2019 20:26:54 -0700 

各位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的结果呢!!!


感激不尽

回复