· 4 years ago · Mar 18, 2021, 07:48 AM
1ADD JAR /opt/cloudera/parcels/CDH/lib/hive/lib/hive-contrib.jar;
2ADD jar hdfs:/opt/cloudera/parcels/CDH/lib/hive/lib/json-serde-1.3.8-jar-with-dependencies.jar;
3
4use buchnevva;
5
6drop table if exists kkt_text;
7create table kkt_text
8row format delimited fields terminated by '\t'
9stored as textfile
10as select * from kkt;
11
12drop table if exists kkt_orc;
13create table kkt_orc
14row format delimited fields terminated by '\t'
15stored as orc
16as select * from kkt;
17
18drop table if exists kkt_parquet;
19create table kkt_parquet
20row format delimited fields terminated by '\t'
21stored as parquet
22as select * from kkt;
23
24drop table if exists ans_text;
25create table ans_text as select content.userinn, sum(coalesce(content.totalsum, 0)) as totalsum from kkt_text group by content.userinn having content.userinn is not NULL order by totalsum desc limit 1;
26
27drop table if exists ans_orc;
28create table ans_orc as select content.userinn, sum(coalesce(content.totalsum, 0)) as totalsum from kkt_orc group by content.userinn order by totalsum desc limit 1;
29
30drop table if exists ans_parquet;
31create table ans_parquet as select content.userinn, sum(coalesce(content.totalsum, 0)) as totalsum from kkt_parquet group by content.userinn order by totalsum desc limit 1;
32
33select * from ans_text;
34