如何获得 Snowflake 的累积乘积？

Question

我想在雪花中计算跨行的累积产品。

基本上，我每月的费率在整个时间内累积。

（某些数据库为此具有product（） SQL函数）。

Answer 1

Sterling Paramore 建议的技巧：添加日志，然后对其求幂：

with data as (select $1 x from values (1),(2),(3),(4),(5))

select x
    , sum(x) over(order by x) sum
    , exp(sum(ln(x)) over(order by x)) mult
from data

Answer 2

如果内置函数不存在，通常可以使用 用户定义的表函数。

在本例中：

CREATE OR REPLACE FUNCTION CUMULATIVE_PRODUCT(VALUE double)
    RETURNS TABLE (PRODUCT double)
    LANGUAGE JAVASCRIPT
    AS '{
        initialize: function(argumentInfo, context) {
           this.cumulativeProduct = 1;
        },
        processRow: function f(row, rowWriter, context){
           this.cumulativeProduct = this.cumulativeProduct*row.VALUE;
           rowWriter.writeRow({PRODUCT: this.cumulativeProduct});
        }
    }';

示例表：

create temp table sample_numbers as (
select 1 as index, 5.1::double as current_value
    union all
select 2 as index, 4.3::double as current_value
    union all
select 3 as index, 3.7::double as current_value
    union all
select 4 as index, 3.9::double as current_value
)

调用 UDTF：

select index,current_value,PRODUCT as cumulative_product
from sample_numbers,table(CUMULATIVE_PRODUCT(current_value) over ())

注意 empty over() 子句 强制 Snowflake 对数据执行单次顺序运行，而不是将其拆分为并行块