开发者社区 问答 正文

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

我向做两次的窗口计算。 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*来自志愿者整理的flink邮件归档

展开
收起
EXCEED 2021-12-08 10:56:12 1267 分享 版权
1 条回答
写回答
取消 提交回答
  • 知道了,使用TUMBLE_ROWTIME HOP_ROWTIME SESSION_ROWTIME 可以传递了。

    *来自志愿者整理的flink

    2021-12-08 11:19:17
    赞同 展开评论
问答地址: