请教:时间属性字段传递问题,有办法解决吗?

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

请教:时间属性字段传递问题,有办法解决吗?

Tianwang Li
我向做两次的窗口计算。
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
**************************************
Reply | Threaded
Open this post in threaded view
|

Re: 请教:时间属性字段传递问题,有办法解决吗?

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