可以再解释一下吗?还是没有看太懂是哪里出错,以及为什么那样就可以解决问题。
------------------ 原始邮件 ------------------ 发件人: Tianwang Li <[hidden email]> 发送时间: 2020年8月6日 21:40 收件人: user-zh <[hidden email]> 主题: 回复:请教:时间属性字段传递问题,有办法解决吗? 知道了,使用TUMBLE_ROWTIME HOP_ROWTIME SESSION_ROWTIME 可以传递了。 Tianwang Li <[hidden email]> 于2020年8月6日周四 下午9:12写道: > > 我向做两次的窗口计算。 > 1、第一次5分钟窗口。 > 2、第二次10分钟窗口,使用的上一次窗口的结果。 > > > 我尝试了发生了异常, Window aggregate can only be defined over a time attribute > column, but TIMESTAMP(3) encountered. > > 请问有什么办法可以解决吗? > 我希望是一个窗口计算后面可以再接一个窗口计算。 > > > 第一次计算: > > CREATE VIEW tmp_5min AS > SELECT > > max(rowtime) as rowtime, > TUMBLE_START(`rowtime`, INTERVAL '5' minute) AS window_start, > > user_group, > COUNT(*) AS cnt > FROM user_behavior > > GROUP BY > > TUMBLE(`rowtime`, INTERVAL '5' minute), > > user_group > > 第二次计算: > > CREATE VIEW tmp_10min AS > SELECT > > max(rowtime) as rowtime, > TUMBLE_START(`rowtime`, INTERVAL '10' minute) AS window_start, > > user_group, > SUM(cnt) AS sum_cnt > FROM tmp_5min > > GROUP BY > > TUMBLE(`rowtime`, INTERVAL '10' minute), > > user_group > > > > -- > ************************************** > tivan > ************************************** > -- ************************************** tivanli ************************************** |
可以参考这里的文档[1]
[1] https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/queries.html#selecting-group-window-start-and-end-timestamps kcz <[hidden email]> 于2020年8月6日周四 下午11:04写道: > 可以再解释一下吗?还是没有看太懂是哪里出错,以及为什么那样就可以解决问题。 > > > > > > ------------------ 原始邮件 ------------------ > 发件人: Tianwang Li <[hidden email]> > 发送时间: 2020年8月6日 21:40 > 收件人: user-zh <[hidden email]> > 主题: 回复:请教:时间属性字段传递问题,有办法解决吗? > > > > 知道了,使用TUMBLE_ROWTIME HOP_ROWTIME SESSION_ROWTIME > 可以传递了。 > > > Tianwang Li <[hidden email]> 于2020年8月6日周四 下午9:12写道: > > > > > 我向做两次的窗口计算。 > > 1、第一次5分钟窗口。 > > 2、第二次10分钟窗口,使用的上一次窗口的结果。 > > > > > > 我尝试了发生了异常, Window aggregate can only be defined over a time attribute > > column, but TIMESTAMP(3) encountered. > > > > 请问有什么办法可以解决吗? > > 我希望是一个窗口计算后面可以再接一个窗口计算。 > > > > > > 第一次计算: > > > > CREATE VIEW tmp_5min AS > > SELECT > > > > max(rowtime) as rowtime, > > TUMBLE_START(`rowtime`, INTERVAL '5' minute) AS > window_start, > > > > user_group, > > COUNT(*) AS cnt > > FROM user_behavior > > > > GROUP BY > > > > TUMBLE(`rowtime`, INTERVAL '5' minute), > > > > user_group > > > > 第二次计算: > > > > CREATE VIEW tmp_10min AS > > SELECT > > > > max(rowtime) as rowtime, > > TUMBLE_START(`rowtime`, INTERVAL '10' minute) AS > window_start, > > > > user_group, > > SUM(cnt) AS sum_cnt > > FROM tmp_5min > > > > GROUP BY > > > > TUMBLE(`rowtime`, INTERVAL '10' minute), > > > > user_group > > > > > > > > -- > > ************************************** > > tivan > > ************************************** > > > > > -- > ************************************** > tivanli > ************************************** -- Best, Benchao Li |
Free forum by Nabble | Edit this page |