知道了，使用TUMBLE_ROWTIME HOP_ROWTIME SESSION_ROWTIME 可以传递了。
Tianwang Li <[email protected]> 于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 **************************************
