如何像配置单元中的Map一样将两列合并为一列?

vcudknz3  于 2021-06-24  发布在  Hive
关注(0)|答案(2)|浏览(361)

在配置单元中,表中有两列:

user_id    product_id    score
1          1, 2, 3       0.7, 0.2, 0.1
2          2, 3, 1       0.5, 0.25, 0.25

产品id和分数的类型都是字符串。现在我希望生成一个新的列,该列按产品id和分数组合,如下所示:

user_id    product_score
1          1:0.7, 2:0.2, 3:0.1
2          2:0.5, 3:0.25, 1:0.25

在新表中,product\u score列就像一个Map,product\u id是键,score是值,但实际上它仍然是一个字符串。产品id和分数由“:”连接。不同的产品标识通过“,”连接,并通过初始表中产品标识中的初始订单进行排序。我怎样才能做到这一点?

gpnt7bae

gpnt7bae1#

已解决-按顺序合并两个数组列,如键和值Map。
用posexplode方法逼近-分解数组,从多列中得到相等的pos值
sql查询-

with rowidcol as 
(
   select user_id, split(product_id, ',') prod_arr, split(score, ',') score_arr, row_number() over() as row_id 
   from prod 
),
coltorows as 
(
   select row_id, user_id, prod_arr[prd_index] product, score_arr[score_index] score, prd_index, score_index 
   from rowidcol 
      LATERAL view posexplode(prod_arr) ptable as prd_index, pdid 
      LATERAL view posexplode(score_arr) prtable as score_index, sid 
),
colselect as 
(
   select row_id, user_id, collect_list(concat(product, ':', score)) product_score 
   from coltorows 
   where prd_index = score_index 
   group by row_id, user_id 
)
select user_id, concat_ws(',', product_score) as prodcut_score 
from colselect 
order by user_id;

输入-表名-产品-

user_id  product_id    score     
1         A,B,C,D      10,20,30,40       
2         X,Y,Z        1,2,3         
3         K,F,G        100,200,300

输出-

user_id   prodcut_score    
1         A:10,B:20,C:30,D:40     
2         X:1,Y:2,Z:3        
3         K:100,F:200,G:300
wixjitnu

wixjitnu2#

使用split()获取数组,使用map()转换为map

select user_id, 
       map(product_id[0], score[0],
           product_id[1], score[1], 
           product_id[2], score[2]
       ) as product_score

(
select user_id, split(product_id,',') as product_id, split(score,',') as score
  from ...
)s;

相关问题