Commit c141ffb5 by wangjf

fix

parent e193136c
......@@ -8,9 +8,10 @@ SET mapreduce.reduce.java.opts=-Xmx8192m;
SET hive.mapred.mode=nonstrict;
DROP TABLE IF EXISTS package_num;
CREATE TABLE package_num AS SELECT d.package_name,count(1) install_num FROM dwh.dm_install_list_v2 d,dwh.dim_package_tags t
WHERE d.dt = '${dt}' AND d.update_date BETWEEN '${LAST_DT}' AND '${dt}' AND d.package_name <> t.package_name
GROUP BY d.package_name HAVING count(1) > 30000
CREATE TABLE package_num AS SELECT package_name,count(1) install_num FROM dwh.dm_install_list_v2
WHERE dt = '${dt}' AND update_date BETWEEN '${LAST_DT}' AND '${dt}'
AND package_name NOT IN (SELECT distinct package_name FROM dwh.dim_package_tags)
GROUP BY package_name HAVING count(1) > 30000
ORDER BY install_num DESC LIMIT 5000;
DROP TABLE IF EXISTS package_info;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment