| 1234567891011121314151617181920212223242526 |
- create database if not exists ${DB};
- use ${DB};
- drop table if exists inventory;
- create table inventory
- (
- inv_date_sk int,
- inv_item_sk int,
- inv_warehouse_sk int,
- inv_quantity_on_hand int
- )
- partitioned by (inv_date string)
- clustered by (inv_item_sk) sorted by (inv_item_sk) into ${BUCKETS} buckets
- stored as ${FILE};
- insert overwrite table inventory partition (inv_date)
- select
- i.inv_date_sk,
- i.inv_item_sk,
- i.inv_warehouse_sk,
- i.inv_quantity_on_hand,
- d.d_date as inv_date
- from ${SOURCE}.inventory i
- join ${SOURCE}.date_dim d
- on (d.d_date_sk = i.inv_date_sk);
|