代码之家 › 专栏 › 技术社区 › yabtzey

SQL计算基于配置单元中列的上一个值重置的累积和

partition-by hive sql

yabtzey · 技术社区 · 7 年前

我试图用这样的东西创造一个累积值

KEY1    Date_    VAL1    CUMU_VAL2
K1      D1      1       0
K1      D2      1       1
K1      D3      0       2
K1      D4      1       0
K1      D5      1       1

基本上,如果你在excel中这样做,那么单元格(D3)的公式是

  D3 = IF(C2>0, D2+1, 0)

我相信我应该可以这样做,但如何在前一个值为零的情况下进行加法,然后重置总和?

SELECT
   a1.*,
       SUM(a1.VAL1) OVER (PARTITION BY a1.KEY1 ORDER  BY a1.Date_ ) AS CUMU_VAL2
FROM source_table a1

2 回复 | 直到 7 年前

MatBailie 7 年前

我修改了戈登林诺夫的回答,因为他不太明白我的意思。

SELECT
  t.KEY1, t.Date_, t.VAL1,
  ROW_NUMBER() OVER (PARTITION BY key1, grp
                         ORDER BY Date_
                    )
                    - 1
                         AS CUMU_VAL2
FROM
(
  SELECT
    *,
    SUM(
      CASE WHEN val1 = 0 THEN 1 ELSE 0 END
    )
    OVER (
      PARTITION BY key1
          ORDER BY date_
    )
      AS grp
  FROM
    source_table
)
  t;

Gordon Linoff 7 年前

您可以分配一个组--它是0的和给定的行。然后使用 count()

select t.KEY1, t.Date_, t.VAL1,
       count(*) over (partition by key1, grp, (case when val1 = 0 then 0 else 1 end)
                      order by date_
                     ) as cume_val1
from (select t.*,
             sum(case when a.val1 = 0 then 1 else 0 end) over (partition by key1 order by date_ rows between 1 following and unbounded following) as grp
      from source_table t
     ) t;

如果 val1 只接受值0和1,然后使用 row_number() 计数() .

推荐文章

Victor Wong · 如何迭代列A以有条件地对列B求和?

1 年前

StripyTiger · 从配置单元中的列表检索元素

2 年前

mfcss · SQL:使用年/月/日分区查询某个时间段的数据

2 年前

MOMO · 配置单元重命名具有分区的表中的列

3 年前

Minnu · json结构类型加载到配置单元

3 年前

PPSATO · 替代在AWS Athena中使用last_value和first_value

3 年前

te time · 按组获取完整的行集

3 年前

MattRgx · 配置单元中的Regexp将一列拆分为3列

4 年前

mishalhaneef · 如何更新蜂箱颤振数据

4 年前

Bhanuchander Udhayakumar · 为什么spark sql的cpu利用率高于hive?

8 年前