buyingyi | cf48fb5 | 2012-11-02 00:31:31 +0000 | [diff] [blame^] | 1 | DROP TABLE IF EXISTS lineitem; |
2 | DROP TABLE IF EXISTS u2_gby_external; | ||||
3 | |||||
4 | -- create the tables and load the data | ||||
5 | 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'; | ||||
6 | |||||
7 | -- create the result tables | ||||
8 | create table u2_gby_external(l_partkey int, t_sum_quantity double); | ||||
9 | |||||
10 | -- the query | ||||
11 | insert overwrite table u2_gby_external | ||||
12 | select | ||||
13 | l_orderkey, avg(L_QUANTITY) as t_sum_quantity | ||||
14 | from | ||||
15 | lineitem | ||||
16 | group by l_orderkey | ||||
17 | order by l_orderkey desc | ||||
18 | limit 10; | ||||
19 |