1

我想知道是否可以计算一组 Id 的特定值的连续范围并返回每个 Id 的计算值。给定以下数据：

+----+----------+--------+
| ID | DATE_KEY | CREDIT |
+----+----------+--------+
|  1 |     8091 |    0.9 |
|  1 |     8092 |     20 |
|  1 |     8095 |   0.22 |
|  1 |     8096 |   0.23 |
|  1 |     8098 |   0.23 |
|  2 |     8095 |     12 |
|  2 |     8096 |     18 |
|  2 |     8097 |      3 |
|  2 |     8098 |   0.25 |
+----+----------+--------+

我想要以下输出：

+----+-------------------------------+
| ID | RANGE_DAYS_CREDIT_LESS_THAN_1 |
+----+-------------------------------+
|  1 |                             1 |
|  1 |                             2 |
|  1 |                             1 |
|  2 |                             1 |
+----+-------------------------------+

在这种情况下，范围是信用小于 1 的连续天数。如果 date_key 列之间存在间隙，则范围不必采用下一个值，例如 ID 1 中介于 8096 和 8098 之间的日期键。是否可以使用 Hive 中的窗口功能来做到这一点？

提前致谢！

4

2 回答 2

0

关键是折叠所有连续序列并计算它们的长度，我努力以一种相对笨拙的方式实现这一点：

with t_test as 
(
select num,row_number()over(order by num) as rn
from
(
select explode(array(1,3,4,5,6,9,10,15)) as num
)
)
select length(sign)+1 from
(
select explode(continue_sign) as sign
from 
(
select split(concat_ws('',collect_list(if(d>1,'v',d))), 'v') as continue_sign
from 
(
select t0.num-t1.num as d from t_test t0 
join t_test t1 on t0.rn=t1.rn+1
)
)
)
  1. 获取每个原始 a 的 seq 中的前一个数字 b；
  2. 检查是否ab == 1，表示是否存在“gap”，标记为'v'；
  3. 将所有 ab 合并为一个字符串，然后使用 'v' 拆分，并计算长度。

要取出 ID 列，应考虑另一个编码 id 的字符串。

于 2020-11-27T10:11:22.110 回答
0

您可以通过将行分类为组的运行总和来执行此操作，每次找到 credit<1 行时（按 date_key 顺序）递增 1。此后它只是一个group by.

select id,count(*) as range_days_credit_lt_1
from (select t.*
      ,sum(case when credit<1 then 0 else 1 end) over(partition by id order by date_key) as grp
      from tbl t
     ) t
where credit<1
group by id
于 2018-04-18T21:37:58.840 回答