Fwd: flink sql 状态表嵌套窗口查询

Thu, 14 Nov 2019 22:19:16 -0800 

 谢谢老板回复 窗口嵌套窗口这个是可以传递的.

  主要是大多数场景状态变更,需要一张最新状态表,  基于这张表做窗口查询的需求特别多的.

如果sql内置不能完成  我们将内存表在转化成datastream 赋予时间属性之后在转换成表 进行窗口查询 理论上是可以的

这样子会很繁琐,也想了解一下开源的flink 这边有啥这方面的计划没有

> 下面是被转发的邮件：
> 
> 发件人: "Yuan,Youjun" <[email protected]>
> 主题: 回复: flink sql 状态表嵌套窗口查询
> 日期: 2019年11月15日 GMT+8 下午1:39:46
> 收件人: "[email protected]" <[email protected]>
> 回复－收件人: [email protected]
> 
> 内层query不是按时间窗查询的话，这恐怕是不支持。
> 如果内层query是按时间窗的，比如固定窗口，那还可以用tumble_rowtime来传递rowtime属性。
> 
> -----邮件原件-----
> 发件人: 金圣哲 <[email protected]> 
> 发送时间: Friday, November 15, 2019 1:21 PM
> 收件人: [email protected]
> 主题: flink sql 状态表嵌套窗口查询
> 
> 各位老板好:
> 
> "select    rider_id, waybill_status as waybill_status ,count(id) as 
> waybill_status_count,   TUMBLE_START(ctime, INTERVAL '1' DAY) as wStart from  
> (select   id, min(ctime)  as rowtime ,latest(status, utime) as 
> waybill_status, latest(rider_id, utime) as rider_id from  user group by id) 
> group by TUMBLE(ctime, INTERVAL '1' DAY),waybill_status,rider_id"
> 
> 问一下 想用状态表作为子表  外面嵌套窗口 如何实现呢 因为状态表group by之后 ctime会失去时间属性  哪位老板知道

回复