| -- create tables and load 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/100/lineitem'; |
| |
| -- create the target table |
| create table q6_forecast_revenue_change (revenue double); |
| |
| -- the query |
| insert overwrite table q6_forecast_revenue_change |
| select |
| sum(l_extendedprice*l_discount) as revenue |
| from |
| lineitem |
| where |
| l_shipdate >= '1994-01-01' |
| and l_shipdate < '1995-01-01' |
| and l_discount >= 0.05 and l_discount <= 0.07 |
| and l_quantity < 24; |
| |
| DROP TABLE lineitem; |
| DROP TABLE q6_forecast_revenue_change; |