开发者社区> 问答> 正文

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

我向做两次的窗口计算。 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 1131 0
1 条回答
写回答
取消 提交回答
  • 知道了,使用TUMBLE_ROWTIME HOP_ROWTIME SESSION_ROWTIME 可以传递了。

    *来自志愿者整理的flink

    2021-12-08 11:19:17
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
用计算和数据去改变整个世界 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载