【发布时间】:2021-09-18 17:07:46
【问题描述】:
如何在日期范围内执行聚合函数 (AVG)
源数据如下:
AccNo Amt Date
1 100 2/1/2021
1 200 2/5/2021
1 300 3/3/2021
2 400 5/20/2021
2 500 5/18/2021
目标需要通过以下方法导出:
例如:要导出 avg_past_week,计算日期范围 Date 到 Date - 7 内所有行的平均金额
同样,对于avg_past_month,它将是Date 到Date - 30
目标:
AccNo Amt Date Avg_past_week Avg_past_month Avg_past_3 month
1 100 2/1/2021 100 100 100
1 200 2/5/2021 150 150 150
1 300 3/3/2021 300 250 200
2 400 5/20/2021 450 450 450
2 500 5/18/2021 500 500 500
【问题讨论】:
标签: sql scala dataframe hive apache-spark-sql