请教：时间属性字段传递问题，有办法解决吗？

Thu, 06 Aug 2020 06:13:12 -0700 

我向做两次的窗口计算。
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
**************************************

回复