flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 金圣哲 <kingsheng...@icloud.com.INVALID>
Subject flink sql 状态表嵌套窗口查询
Date Fri, 15 Nov 2019 05:20:37 GMT
各位老板好:

"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会失去时间属性  哪位老板知道
Mime
View raw message