flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 金圣哲 <kingsheng...@icloud.com.INVALID>
Subject Fwd: flink sql 状态表嵌套窗口查询
Date Fri, 15 Nov 2019 06:18:09 GMT
 谢谢老板回复 窗口嵌套窗口这个是可以传递的.

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

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

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

> 下面是被转发的邮件:
> 
> 发件人: "Yuan,Youjun" <yuanyoujun@baidu.com>
> 主题: 回复: flink sql 状态表嵌套窗口查询
> 日期: 2019年11月15日 GMT+8 下午1:39:46
> 收件人: "user-zh@flink.apache.org" <user-zh@flink.apache.org>
> 回复-收件人: user-zh@flink.apache.org
> 
> 内层query不是按时间窗查询的话,这恐怕是不支持。
> 如果内层query是按时间窗的,比如固定窗口,那还可以用tumble_rowtime来传递rowtime属性。
> 
> -----邮件原件-----
> 发件人: 金圣哲 <kingshengzhe@icloud.com.INVALID> 
> 发送时间: Friday, November 15, 2019 1:21 PM
> 收件人: user-zh@flink.apache.org
> 主题: 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会失去时间属性  哪位老板知道


Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message