在配置单元中使用unix秒的7天滚动平均值

abithluo  于 2021-06-27  发布在  Hive
关注(0)|答案(0)|浏览(282)

我需要找到7天的滚动平均温度。
使用数据集中提供的日期字符串,我创建了一个unix时间戳。我用当天午夜的unix时间戳替换了每天的第一个时间戳。

一周内有604800个unix秒,所以我尝试使用下面的代码来计算它,但是没有成功。如何修复此代码以使其正确执行窗口计算?

DROP VIEW IF EXISTS every_7_days;
CREATE VIEW every_7_days AS
SELECT weather_dt,
       time,
       fixed_unix_time,
       temperature,
       avg(temperature) OVER(ORDER BY fixed_unix_time RANGE BETWEEN 604800 PRECEDING AND CURRENT ROW) AS roll7day_avg
  FROM clean_first_row
  ORDER BY fixed_unix_time;

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题