Maybe you could format your code for more answers: set hive.enforce.sorting=true;
insert into database2.filtered_rn
select cust_id, timeOf, keys, cd, score, collect_list(weight), concat_WS(',',collect_list(ui)), comp, ROW_NUMBER() over(partition by cust_id order by timeOf desc) as row_num
FROM (
select ld.cust_id, ld.timeOf, ld.keys, lf.cd, ld.score, t.weight, t.ui, COALESCE(ld.compI, 0L) as comp
from database1.xxxx ld
inner join database2.xxxx lf on ld.lof_id = lf.lof_id
left join database1.xxxx r on r.lof_id = ld.lof_id
left join datbase1.xxxx t on r.score_id = t.score_id)
distribute by (cust_id,timeOf)
sort by abs(weight) desc)
sub group by cust_id, timeOf, keys, cd, score, comp;
... View more
