知道了,使用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
**************************************