blob: be9de2da39830dc9861343c22a4010e88104ee3d [file] [log] [blame]
DROP TABLE IF EXISTS lineitem;
DROP TABLE IF EXISTS u2_gby_external;
-- create the tables and load the data
create external table lineitem (L_ORDERKEY INT, L_PARTKEY INT, L_SUPPKEY INT, L_LINENUMBER INT, L_QUANTITY DOUBLE, L_EXTENDEDPRICE DOUBLE, L_DISCOUNT DOUBLE, L_TAX DOUBLE, L_RETURNFLAG STRING, L_LINESTATUS STRING, L_SHIPDATE STRING, L_COMMITDATE STRING, L_RECEIPTDATE STRING, L_SHIPINSTRUCT STRING, L_SHIPMODE STRING, L_COMMENT STRING) ROW FORMAT DELIMITED FIELDS TERMINATED BY '|' STORED AS TEXTFILE LOCATION '/tpch/lineitem';
-- create the result tables
create table u2_gby_external(l_partkey int, t_sum_quantity double);
-- the query
insert overwrite table u2_gby_external
select
l_orderkey, avg(L_QUANTITY) as t_sum_quantity
from
lineitem
group by l_orderkey
order by l_orderkey desc
limit 10;