spark偏移计算支持“按日期值范围”的滑动窗口吗？

spark偏移计算支持“按日期值范围”的滑动窗口吗？

如想计算某个商品近30天的销量，但是我的日期不是连续的，使用下面这个可以吗？
SUM([件数]) OVER (PARTITION BY [商品名称], [平台] ORDER BY [日期] RANGE BETWEEN INTERVAL '30' DAY PRECEDING AND CURRENT ROW)

关于这个问题，spark偏移计算仅支持“按行数”的移动计算/窗口范围，不支持“按日期值范围”的滑动窗口。

建议1:先在数据里补齐日期粒度，保证每个 商品名称 + 平台 每天都有一行，缺失销量填 0，然后再计算

1. 
   
2. <div>SUM([件数]) OVER (
   
3.   PARTITION BY [商品名称], [平台]
   
4.   ORDER BY [日期]
   
5.   RANGE BETWEEN 30 PRECEDING AND CURRENT ROW
   
6. )</div>

复制代码

建议2:如果不想补齐日期，可以在数据集 SQL / ETL SQL 节点里做自关联或原生 SQL 计算，不走卡片计算列。例如按日期条件聚合：

1. 
   
2. <div>
   
3. <div>SELECT
   
4.   t.`商品名称`,
   
5.   t.`平台`,
   
6.   t.`日期`,
   
7.   SUM(s.`件数`) AS `近30天销量`
   
8. FROM base t
   
9. LEFT JOIN base s
   
10.   ON s.`商品名称` = t.`商品名称`
    
11. AND s.`平台` = t.`平台`
    
12. AND s.`日期` BETWEEN DATE_SUB(t.`日期`, 29) AND t.`日期`
    
13. GROUP BY t.`商品名称`, t.`平台`, t.`日期`</div></div><p></p>
    
14. <div></div>

复制代码