|
|
@@ -1,658 +1,625 @@
|
|
|
create database if not exists ${DB};
|
|
|
use ${DB};
|
|
|
+-- Table<store_sales (23 cols) partition=ss_sold_date_sk>
|
|
|
|
|
|
-drop table if exists call_center;
|
|
|
-
|
|
|
-create external table call_center(
|
|
|
- cc_call_center_sk bigint
|
|
|
-, cc_call_center_id string
|
|
|
-, cc_rec_start_date string
|
|
|
-, cc_rec_end_date string
|
|
|
-, cc_closed_date_sk bigint
|
|
|
-, cc_open_date_sk bigint
|
|
|
-, cc_name string
|
|
|
-, cc_class string
|
|
|
-, cc_employees int
|
|
|
-, cc_sq_ft int
|
|
|
-, cc_hours string
|
|
|
-, cc_manager string
|
|
|
-, cc_mkt_id int
|
|
|
-, cc_mkt_class string
|
|
|
-, cc_mkt_desc string
|
|
|
-, cc_market_manager string
|
|
|
-, cc_division int
|
|
|
-, cc_division_name string
|
|
|
-, cc_company int
|
|
|
-, cc_company_name string
|
|
|
-, cc_street_number string
|
|
|
-, cc_street_name string
|
|
|
-, cc_street_type string
|
|
|
-, cc_suite_number string
|
|
|
-, cc_city string
|
|
|
-, cc_county string
|
|
|
-, cc_state string
|
|
|
-, cc_zip string
|
|
|
-, cc_country string
|
|
|
-, cc_gmt_offset double
|
|
|
-, cc_tax_percentage double
|
|
|
+drop table if exists store_sales;
|
|
|
+create external table if not exists store_sales(
|
|
|
+ ss_sold_date_sk bigint
|
|
|
+, ss_sold_time_sk bigint
|
|
|
+, ss_item_sk bigint
|
|
|
+, ss_customer_sk bigint
|
|
|
+, ss_cdemo_sk bigint
|
|
|
+, ss_hdemo_sk bigint
|
|
|
+, ss_addr_sk bigint
|
|
|
+, ss_store_sk bigint
|
|
|
+, ss_promo_sk bigint
|
|
|
+, ss_ticket_number bigint
|
|
|
+, ss_quantity int
|
|
|
+, ss_wholesale_cost decimal(7,2)
|
|
|
+, ss_list_price decimal(7,2)
|
|
|
+, ss_sales_price decimal(7,2)
|
|
|
+, ss_ext_discount_amt decimal(7,2)
|
|
|
+, ss_ext_sales_price decimal(7,2)
|
|
|
+, ss_ext_wholesale_cost decimal(7,2)
|
|
|
+, ss_ext_list_price decimal(7,2)
|
|
|
+, ss_ext_tax decimal(7,2)
|
|
|
+, ss_coupon_amt decimal(7,2)
|
|
|
+, ss_net_paid decimal(7,2)
|
|
|
+, ss_net_paid_inc_tax decimal(7,2)
|
|
|
+, ss_net_profit decimal(7,2)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/call_center';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/store_sales'
|
|
|
+;
|
|
|
|
|
|
-drop table if exists catalog_page;
|
|
|
+-- Table<store_returns (20 cols) partition=sr_returned_date_sk>
|
|
|
|
|
|
-create external table catalog_page(
|
|
|
- cp_catalog_page_sk bigint
|
|
|
-, cp_catalog_page_id string
|
|
|
-, cp_start_date_sk bigint
|
|
|
-, cp_end_date_sk bigint
|
|
|
-, cp_department string
|
|
|
-, cp_catalog_number int
|
|
|
-, cp_catalog_page_number int
|
|
|
-, cp_description string
|
|
|
-, cp_type string
|
|
|
+drop table if exists store_returns;
|
|
|
+create external table if not exists store_returns(
|
|
|
+ sr_returned_date_sk bigint
|
|
|
+, sr_return_time_sk bigint
|
|
|
+, sr_item_sk bigint
|
|
|
+, sr_customer_sk bigint
|
|
|
+, sr_cdemo_sk bigint
|
|
|
+, sr_hdemo_sk bigint
|
|
|
+, sr_addr_sk bigint
|
|
|
+, sr_store_sk bigint
|
|
|
+, sr_reason_sk bigint
|
|
|
+, sr_ticket_number bigint
|
|
|
+, sr_return_quantity int
|
|
|
+, sr_return_amt decimal(7,2)
|
|
|
+, sr_return_tax decimal(7,2)
|
|
|
+, sr_return_amt_inc_tax decimal(7,2)
|
|
|
+, sr_fee decimal(7,2)
|
|
|
+, sr_return_ship_cost decimal(7,2)
|
|
|
+, sr_refunded_cash decimal(7,2)
|
|
|
+, sr_reversed_charge decimal(7,2)
|
|
|
+, sr_store_credit decimal(7,2)
|
|
|
+, sr_net_loss decimal(7,2)
|
|
|
)
|
|
|
row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/catalog_page';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+location '${LOCATION}/store_returns'
|
|
|
+;
|
|
|
|
|
|
-drop table if exists catalog_returns;
|
|
|
+-- Table<catalog_sales (34 cols) partition=cs_sold_date_sk>
|
|
|
|
|
|
-create external table catalog_returns
|
|
|
-(
|
|
|
- cr_returned_date_sk bigint,
|
|
|
- cr_returned_time_sk bigint,
|
|
|
- cr_item_sk bigint,
|
|
|
- cr_refunded_customer_sk bigint,
|
|
|
- cr_refunded_cdemo_sk bigint,
|
|
|
- cr_refunded_hdemo_sk bigint,
|
|
|
- cr_refunded_addr_sk bigint,
|
|
|
- cr_returning_customer_sk bigint,
|
|
|
- cr_returning_cdemo_sk bigint,
|
|
|
- cr_returning_hdemo_sk bigint,
|
|
|
- cr_returning_addr_sk bigint,
|
|
|
- cr_call_center_sk bigint,
|
|
|
- cr_catalog_page_sk bigint,
|
|
|
- cr_ship_mode_sk bigint,
|
|
|
- cr_warehouse_sk bigint,
|
|
|
- cr_reason_sk bigint,
|
|
|
- cr_order_number bigint,
|
|
|
- cr_return_quantity int,
|
|
|
- cr_return_amount double,
|
|
|
- cr_return_tax double,
|
|
|
- cr_return_amt_inc_tax double,
|
|
|
- cr_fee double,
|
|
|
- cr_return_ship_cost double,
|
|
|
- cr_refunded_cash double,
|
|
|
- cr_reversed_charge double,
|
|
|
- cr_store_credit double,
|
|
|
- cr_net_loss double
|
|
|
+drop table if exists catalog_sales;
|
|
|
+create external table if not exists catalog_sales(
|
|
|
+ cs_sold_date_sk bigint
|
|
|
+, cs_sold_time_sk bigint
|
|
|
+, cs_ship_date_sk bigint
|
|
|
+, cs_bill_customer_sk bigint
|
|
|
+, cs_bill_cdemo_sk bigint
|
|
|
+, cs_bill_hdemo_sk bigint
|
|
|
+, cs_bill_addr_sk bigint
|
|
|
+, cs_ship_customer_sk bigint
|
|
|
+, cs_ship_cdemo_sk bigint
|
|
|
+, cs_ship_hdemo_sk bigint
|
|
|
+, cs_ship_addr_sk bigint
|
|
|
+, cs_call_center_sk bigint
|
|
|
+, cs_catalog_page_sk bigint
|
|
|
+, cs_ship_mode_sk bigint
|
|
|
+, cs_warehouse_sk bigint
|
|
|
+, cs_item_sk bigint
|
|
|
+, cs_promo_sk bigint
|
|
|
+, cs_order_number bigint
|
|
|
+, cs_quantity int
|
|
|
+, cs_wholesale_cost decimal(7,2)
|
|
|
+, cs_list_price decimal(7,2)
|
|
|
+, cs_sales_price decimal(7,2)
|
|
|
+, cs_ext_discount_amt decimal(7,2)
|
|
|
+, cs_ext_sales_price decimal(7,2)
|
|
|
+, cs_ext_wholesale_cost decimal(7,2)
|
|
|
+, cs_ext_list_price decimal(7,2)
|
|
|
+, cs_ext_tax decimal(7,2)
|
|
|
+, cs_coupon_amt decimal(7,2)
|
|
|
+, cs_ext_ship_cost decimal(7,2)
|
|
|
+, cs_net_paid decimal(7,2)
|
|
|
+, cs_net_paid_inc_tax decimal(7,2)
|
|
|
+, cs_net_paid_inc_ship decimal(7,2)
|
|
|
+, cs_net_paid_inc_ship_tax decimal(7,2)
|
|
|
+, cs_net_profit decimal(7,2)
|
|
|
)
|
|
|
row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/catalog_returns';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+location '${LOCATION}/catalog_sales'
|
|
|
+;
|
|
|
|
|
|
-drop table if exists catalog_sales;
|
|
|
+-- Table<catalog_returns (27 cols) partition=cr_returned_date_sk>
|
|
|
|
|
|
-create external table catalog_sales
|
|
|
-(
|
|
|
- cs_sold_date_sk bigint,
|
|
|
- cs_sold_time_sk bigint,
|
|
|
- cs_ship_date_sk bigint,
|
|
|
- cs_bill_customer_sk bigint,
|
|
|
- cs_bill_cdemo_sk bigint,
|
|
|
- cs_bill_hdemo_sk bigint,
|
|
|
- cs_bill_addr_sk bigint,
|
|
|
- cs_ship_customer_sk bigint,
|
|
|
- cs_ship_cdemo_sk bigint,
|
|
|
- cs_ship_hdemo_sk bigint,
|
|
|
- cs_ship_addr_sk bigint,
|
|
|
- cs_call_center_sk bigint,
|
|
|
- cs_catalog_page_sk bigint,
|
|
|
- cs_ship_mode_sk bigint,
|
|
|
- cs_warehouse_sk bigint,
|
|
|
- cs_item_sk bigint,
|
|
|
- cs_promo_sk bigint,
|
|
|
- cs_order_number bigint,
|
|
|
- cs_quantity int,
|
|
|
- cs_wholesale_cost double,
|
|
|
- cs_list_price double,
|
|
|
- cs_sales_price double,
|
|
|
- cs_ext_discount_amt double,
|
|
|
- cs_ext_sales_price double,
|
|
|
- cs_ext_wholesale_cost double,
|
|
|
- cs_ext_list_price double,
|
|
|
- cs_ext_tax double,
|
|
|
- cs_coupon_amt double,
|
|
|
- cs_ext_ship_cost double,
|
|
|
- cs_net_paid double,
|
|
|
- cs_net_paid_inc_tax double,
|
|
|
- cs_net_paid_inc_ship double,
|
|
|
- cs_net_paid_inc_ship_tax double,
|
|
|
- cs_net_profit double
|
|
|
+drop table if exists catalog_returns;
|
|
|
+create external table if not exists catalog_returns(
|
|
|
+ cr_returned_date_sk bigint
|
|
|
+, cr_returned_time_sk bigint
|
|
|
+, cr_item_sk bigint
|
|
|
+, cr_refunded_customer_sk bigint
|
|
|
+, cr_refunded_cdemo_sk bigint
|
|
|
+, cr_refunded_hdemo_sk bigint
|
|
|
+, cr_refunded_addr_sk bigint
|
|
|
+, cr_returning_customer_sk bigint
|
|
|
+, cr_returning_cdemo_sk bigint
|
|
|
+, cr_returning_hdemo_sk bigint
|
|
|
+, cr_returning_addr_sk bigint
|
|
|
+, cr_call_center_sk bigint
|
|
|
+, cr_catalog_page_sk bigint
|
|
|
+, cr_ship_mode_sk bigint
|
|
|
+, cr_warehouse_sk bigint
|
|
|
+, cr_reason_sk bigint
|
|
|
+, cr_order_number bigint
|
|
|
+, cr_return_quantity int
|
|
|
+, cr_return_amount decimal(7,2)
|
|
|
+, cr_return_tax decimal(7,2)
|
|
|
+, cr_return_amt_inc_tax decimal(7,2)
|
|
|
+, cr_fee decimal(7,2)
|
|
|
+, cr_return_ship_cost decimal(7,2)
|
|
|
+, cr_refunded_cash decimal(7,2)
|
|
|
+, cr_reversed_charge decimal(7,2)
|
|
|
+, cr_store_credit decimal(7,2)
|
|
|
+, cr_net_loss decimal(7,2)
|
|
|
)
|
|
|
row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/catalog_sales';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+location '${LOCATION}/catalog_returns'
|
|
|
+;
|
|
|
|
|
|
-drop table if exists customer_address;
|
|
|
+-- Table<web_sales (34 cols) partition=ws_sold_date_sk>
|
|
|
|
|
|
-create external table customer_address
|
|
|
-(
|
|
|
- ca_address_sk bigint,
|
|
|
- ca_address_id string,
|
|
|
- ca_street_number string,
|
|
|
- ca_street_name string,
|
|
|
- ca_street_type string,
|
|
|
- ca_suite_number string,
|
|
|
- ca_city string,
|
|
|
- ca_county string,
|
|
|
- ca_state string,
|
|
|
- ca_zip string,
|
|
|
- ca_country string,
|
|
|
- ca_gmt_offset double,
|
|
|
- ca_location_type string
|
|
|
+drop table if exists web_sales;
|
|
|
+create external table if not exists web_sales(
|
|
|
+ ws_sold_date_sk bigint
|
|
|
+, ws_sold_time_sk bigint
|
|
|
+, ws_ship_date_sk bigint
|
|
|
+, ws_item_sk bigint
|
|
|
+, ws_bill_customer_sk bigint
|
|
|
+, ws_bill_cdemo_sk bigint
|
|
|
+, ws_bill_hdemo_sk bigint
|
|
|
+, ws_bill_addr_sk bigint
|
|
|
+, ws_ship_customer_sk bigint
|
|
|
+, ws_ship_cdemo_sk bigint
|
|
|
+, ws_ship_hdemo_sk bigint
|
|
|
+, ws_ship_addr_sk bigint
|
|
|
+, ws_web_page_sk bigint
|
|
|
+, ws_web_site_sk bigint
|
|
|
+, ws_ship_mode_sk bigint
|
|
|
+, ws_warehouse_sk bigint
|
|
|
+, ws_promo_sk bigint
|
|
|
+, ws_order_number bigint
|
|
|
+, ws_quantity int
|
|
|
+, ws_wholesale_cost decimal(7,2)
|
|
|
+, ws_list_price decimal(7,2)
|
|
|
+, ws_sales_price decimal(7,2)
|
|
|
+, ws_ext_discount_amt decimal(7,2)
|
|
|
+, ws_ext_sales_price decimal(7,2)
|
|
|
+, ws_ext_wholesale_cost decimal(7,2)
|
|
|
+, ws_ext_list_price decimal(7,2)
|
|
|
+, ws_ext_tax decimal(7,2)
|
|
|
+, ws_coupon_amt decimal(7,2)
|
|
|
+, ws_ext_ship_cost decimal(7,2)
|
|
|
+, ws_net_paid decimal(7,2)
|
|
|
+, ws_net_paid_inc_tax decimal(7,2)
|
|
|
+, ws_net_paid_inc_ship decimal(7,2)
|
|
|
+, ws_net_paid_inc_ship_tax decimal(7,2)
|
|
|
+, ws_net_profit decimal(7,2)
|
|
|
)
|
|
|
row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/customer_address';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+location '${LOCATION}/web_sales'
|
|
|
+;
|
|
|
|
|
|
-drop table if exists customer_demographics;
|
|
|
+-- Table<web_returns (24 cols) partition=wr_returned_date_sk>
|
|
|
|
|
|
-create external table customer_demographics
|
|
|
-(
|
|
|
- cd_demo_sk bigint,
|
|
|
- cd_gender string,
|
|
|
- cd_marital_status string,
|
|
|
- cd_education_status string,
|
|
|
- cd_purchase_estimate int,
|
|
|
- cd_credit_rating string,
|
|
|
- cd_dep_count int,
|
|
|
- cd_dep_employed_count int,
|
|
|
- cd_dep_college_count int
|
|
|
+drop table if exists web_returns;
|
|
|
+create external table if not exists web_returns(
|
|
|
+ wr_returned_date_sk bigint
|
|
|
+, wr_returned_time_sk bigint
|
|
|
+, wr_item_sk bigint
|
|
|
+, wr_refunded_customer_sk bigint
|
|
|
+, wr_refunded_cdemo_sk bigint
|
|
|
+, wr_refunded_hdemo_sk bigint
|
|
|
+, wr_refunded_addr_sk bigint
|
|
|
+, wr_returning_customer_sk bigint
|
|
|
+, wr_returning_cdemo_sk bigint
|
|
|
+, wr_returning_hdemo_sk bigint
|
|
|
+, wr_returning_addr_sk bigint
|
|
|
+, wr_web_page_sk bigint
|
|
|
+, wr_reason_sk bigint
|
|
|
+, wr_order_number bigint
|
|
|
+, wr_return_quantity int
|
|
|
+, wr_return_amt decimal(7,2)
|
|
|
+, wr_return_tax decimal(7,2)
|
|
|
+, wr_return_amt_inc_tax decimal(7,2)
|
|
|
+, wr_fee decimal(7,2)
|
|
|
+, wr_return_ship_cost decimal(7,2)
|
|
|
+, wr_refunded_cash decimal(7,2)
|
|
|
+, wr_reversed_charge decimal(7,2)
|
|
|
+, wr_account_credit decimal(7,2)
|
|
|
+, wr_net_loss decimal(7,2)
|
|
|
)
|
|
|
row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/customer_demographics';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+location '${LOCATION}/web_returns'
|
|
|
+;
|
|
|
|
|
|
-drop table if exists customer;
|
|
|
+-- Table<inventory (4 cols)>
|
|
|
|
|
|
-create external table customer
|
|
|
-(
|
|
|
- c_customer_sk bigint,
|
|
|
- c_customer_id string,
|
|
|
- c_current_cdemo_sk bigint,
|
|
|
- c_current_hdemo_sk bigint,
|
|
|
- c_current_addr_sk bigint,
|
|
|
- c_first_shipto_date_sk bigint,
|
|
|
- c_first_sales_date_sk bigint,
|
|
|
- c_salutation string,
|
|
|
- c_first_name string,
|
|
|
- c_last_name string,
|
|
|
- c_preferred_cust_flag string,
|
|
|
- c_birth_day int,
|
|
|
- c_birth_month int,
|
|
|
- c_birth_year int,
|
|
|
- c_birth_country string,
|
|
|
- c_login string,
|
|
|
- c_email_address string,
|
|
|
- c_last_review_date string
|
|
|
+drop table if exists inventory;
|
|
|
+create external table if not exists inventory(
|
|
|
+ inv_date_sk bigint
|
|
|
+, inv_item_sk bigint
|
|
|
+, inv_warehouse_sk bigint
|
|
|
+, inv_quantity_on_hand int
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/customer';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/inventory';
|
|
|
|
|
|
-drop table if exists date_dim;
|
|
|
+-- Table<store (29 cols)>
|
|
|
|
|
|
-create external table date_dim
|
|
|
-(
|
|
|
- d_date_sk bigint,
|
|
|
- d_date_id string,
|
|
|
- d_date string,
|
|
|
- d_month_seq int,
|
|
|
- d_week_seq int,
|
|
|
- d_quarter_seq int,
|
|
|
- d_year int,
|
|
|
- d_dow int,
|
|
|
- d_moy int,
|
|
|
- d_dom int,
|
|
|
- d_qoy int,
|
|
|
- d_fy_year int,
|
|
|
- d_fy_quarter_seq int,
|
|
|
- d_fy_week_seq int,
|
|
|
- d_day_name string,
|
|
|
- d_quarter_name string,
|
|
|
- d_holiday string,
|
|
|
- d_weekend string,
|
|
|
- d_following_holiday string,
|
|
|
- d_first_dom int,
|
|
|
- d_last_dom int,
|
|
|
- d_same_day_ly int,
|
|
|
- d_same_day_lq int,
|
|
|
- d_current_day string,
|
|
|
- d_current_week string,
|
|
|
- d_current_month string,
|
|
|
- d_current_quarter string,
|
|
|
- d_current_year string
|
|
|
+drop table if exists store;
|
|
|
+create external table if not exists store(
|
|
|
+ s_store_sk bigint
|
|
|
+, s_store_id char(16)
|
|
|
+, s_rec_start_date date
|
|
|
+, s_rec_end_date date
|
|
|
+, s_closed_date_sk bigint
|
|
|
+, s_store_name varchar(50)
|
|
|
+, s_number_employees int
|
|
|
+, s_floor_space int
|
|
|
+, s_hours char(20)
|
|
|
+, S_manager varchar(40)
|
|
|
+, S_market_id int
|
|
|
+, S_geography_class varchar(100)
|
|
|
+, S_market_desc varchar(100)
|
|
|
+, s_market_manager varchar(40)
|
|
|
+, s_division_id int
|
|
|
+, s_division_name varchar(50)
|
|
|
+, s_company_id int
|
|
|
+, s_company_name varchar(50)
|
|
|
+, s_street_number varchar(10)
|
|
|
+, s_street_name varchar(60)
|
|
|
+, s_street_type char(15)
|
|
|
+, s_suite_number char(10)
|
|
|
+, s_city varchar(60)
|
|
|
+, s_county varchar(30)
|
|
|
+, s_state char(2)
|
|
|
+, s_zip char(10)
|
|
|
+, s_country varchar(20)
|
|
|
+, s_gmt_offset decimal(5,2)
|
|
|
+, s_tax_percentage decimal(5,2)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/date_dim';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/store';
|
|
|
|
|
|
-drop table if exists household_demographics;
|
|
|
+-- Table<call_center (31 cols)>
|
|
|
|
|
|
-create external table household_demographics
|
|
|
-(
|
|
|
- hd_demo_sk bigint,
|
|
|
- hd_income_band_sk bigint,
|
|
|
- hd_buy_potential string,
|
|
|
- hd_dep_count int,
|
|
|
- hd_vehicle_count int
|
|
|
+drop table if exists call_center;
|
|
|
+create external table if not exists call_center(
|
|
|
+ cc_call_center_sk bigint
|
|
|
+, cc_call_center_id char(16)
|
|
|
+, cc_rec_start_date date
|
|
|
+, cc_rec_end_date date
|
|
|
+, cc_closed_date_sk bigint
|
|
|
+, cc_open_date_sk bigint
|
|
|
+, cc_name varchar(50)
|
|
|
+, cc_class varchar(50)
|
|
|
+, cc_employees int
|
|
|
+, cc_sq_ft int
|
|
|
+, cc_hours char(20)
|
|
|
+, cc_manager varchar(40)
|
|
|
+, cc_mkt_id int
|
|
|
+, cc_mkt_class char(50)
|
|
|
+, cc_mkt_desc varchar(100)
|
|
|
+, cc_market_manager varchar(40)
|
|
|
+, cc_division int
|
|
|
+, cc_division_name varchar(50)
|
|
|
+, cc_company int
|
|
|
+, cc_company_name char(50)
|
|
|
+, cc_street_number char(10)
|
|
|
+, cc_street_name varchar(60)
|
|
|
+, cc_street_type char(15)
|
|
|
+, cc_suite_number char(10)
|
|
|
+, cc_city varchar(60)
|
|
|
+, cc_county varchar(30)
|
|
|
+, cc_state char(2)
|
|
|
+, cc_zip char(10)
|
|
|
+, cc_country varchar(20)
|
|
|
+, cc_gmt_offset decimal(5,2)
|
|
|
+, cc_tax_percentage decimal(5,2)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/household_demographics';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/call_center';
|
|
|
|
|
|
-drop table if exists income_band;
|
|
|
+-- Table<catalog_page (9 cols)>
|
|
|
|
|
|
-create external table income_band(
|
|
|
- ib_income_band_sk bigint
|
|
|
-, ib_lower_bound int
|
|
|
-, ib_upper_bound int
|
|
|
+drop table if exists catalog_page;
|
|
|
+create external table if not exists catalog_page(
|
|
|
+ cp_catalog_page_sk bigint
|
|
|
+, cp_catalog_page_id char(16)
|
|
|
+, cp_start_date_sk bigint
|
|
|
+, cp_end_date_sk bigint
|
|
|
+, cp_department varchar(50)
|
|
|
+, cp_catalog_number int
|
|
|
+, cp_catalog_page_number int
|
|
|
+, cp_description varchar(100)
|
|
|
+, cp_type varchar(100)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/income_band';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/catalog_page';
|
|
|
|
|
|
-drop table if exists inventory;
|
|
|
+-- Table<web_site (26 cols)>
|
|
|
|
|
|
-create external table inventory
|
|
|
-(
|
|
|
- inv_date_sk bigint,
|
|
|
- inv_item_sk bigint,
|
|
|
- inv_warehouse_sk bigint,
|
|
|
- inv_quantity_on_hand int
|
|
|
+drop table if exists web_site;
|
|
|
+create external table if not exists web_site(
|
|
|
+ web_site_sk bigint
|
|
|
+, web_site_id char(16)
|
|
|
+, web_rec_start_date date
|
|
|
+, web_rec_end_date date
|
|
|
+, web_name varchar(50)
|
|
|
+, web_open_date_sk bigint
|
|
|
+, web_close_date_sk bigint
|
|
|
+, web_class varchar(50)
|
|
|
+, web_manager varchar(40)
|
|
|
+, web_mkt_id int
|
|
|
+, web_mkt_class varchar(50)
|
|
|
+, web_mkt_desc varchar(100)
|
|
|
+, web_market_manager varchar(40)
|
|
|
+, web_company_id int
|
|
|
+, web_company_name char(50)
|
|
|
+, web_street_number char(10)
|
|
|
+, web_street_name varchar(60)
|
|
|
+, web_street_type char(15)
|
|
|
+, web_suite_number char(10)
|
|
|
+, web_city varchar(60)
|
|
|
+, web_county varchar(30)
|
|
|
+, web_state char(2)
|
|
|
+, web_zip char(10)
|
|
|
+, web_country varchar(20)
|
|
|
+, web_gmt_offset decimal(5,2)
|
|
|
+, web_tax_percentage decimal(5,2)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/inventory';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/web_site';
|
|
|
|
|
|
-drop table if exists item;
|
|
|
+-- Table<web_page (14 cols)>
|
|
|
|
|
|
-create external table item
|
|
|
-(
|
|
|
- i_item_sk bigint,
|
|
|
- i_item_id string,
|
|
|
- i_rec_start_date string,
|
|
|
- i_rec_end_date string,
|
|
|
- i_item_desc string,
|
|
|
- i_current_price double,
|
|
|
- i_wholesale_cost double,
|
|
|
- i_brand_id int,
|
|
|
- i_brand string,
|
|
|
- i_class_id int,
|
|
|
- i_class string,
|
|
|
- i_category_id int,
|
|
|
- i_category string,
|
|
|
- i_manufact_id int,
|
|
|
- i_manufact string,
|
|
|
- i_size string,
|
|
|
- i_formulation string,
|
|
|
- i_color string,
|
|
|
- i_units string,
|
|
|
- i_container string,
|
|
|
- i_manager_id int,
|
|
|
- i_product_name string
|
|
|
+drop table if exists web_page;
|
|
|
+create external table if not exists web_page(
|
|
|
+ wp_web_page_sk bigint
|
|
|
+, wp_web_page_id char(16)
|
|
|
+, wp_rec_start_date date
|
|
|
+, wp_rec_end_date date
|
|
|
+, wp_creation_date_sk bigint
|
|
|
+, wp_access_date_sk bigint
|
|
|
+, wp_autogen_flag char(1)
|
|
|
+, wp_customer_sk bigint
|
|
|
+, wp_url varchar(100)
|
|
|
+, wp_type char(50)
|
|
|
+, wp_char_count int
|
|
|
+, wp_link_count int
|
|
|
+, wp_image_count int
|
|
|
+, wp_max_ad_count int
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/item';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/web_page';
|
|
|
|
|
|
-drop table if exists promotion;
|
|
|
+-- Table<warehouse (14 cols)>
|
|
|
|
|
|
-create external table promotion
|
|
|
-(
|
|
|
- p_promo_sk bigint,
|
|
|
- p_promo_id string,
|
|
|
- p_start_date_sk bigint,
|
|
|
- p_end_date_sk bigint,
|
|
|
- p_item_sk bigint,
|
|
|
- p_cost double,
|
|
|
- p_response_target int,
|
|
|
- p_promo_name string,
|
|
|
- p_channel_dmail string,
|
|
|
- p_channel_email string,
|
|
|
- p_channel_catalog string,
|
|
|
- p_channel_tv string,
|
|
|
- p_channel_radio string,
|
|
|
- p_channel_press string,
|
|
|
- p_channel_event string,
|
|
|
- p_channel_demo string,
|
|
|
- p_channel_details string,
|
|
|
- p_purpose string,
|
|
|
- p_discount_active string
|
|
|
+drop table if exists warehouse;
|
|
|
+create external table if not exists warehouse(
|
|
|
+ w_warehouse_sk bigint
|
|
|
+, w_warehouse_id char(16)
|
|
|
+, w_warehouse_name varchar(20)
|
|
|
+, w_warehouse_sq_ft int
|
|
|
+, w_street_number char(10)
|
|
|
+, w_street_name varchar(60)
|
|
|
+, w_street_type char(15)
|
|
|
+, w_suite_number char(10)
|
|
|
+, w_city varchar(60)
|
|
|
+, w_county varchar(30)
|
|
|
+, w_state char(2)
|
|
|
+, w_zip char(10)
|
|
|
+, w_country varchar(20)
|
|
|
+, w_gmt_offset decimal(5,2)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/promotion';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/warehouse';
|
|
|
|
|
|
-drop table if exists reason;
|
|
|
+-- Table<customer (18 cols)>
|
|
|
|
|
|
-create external table reason(
|
|
|
- r_reason_sk bigint
|
|
|
-, r_reason_id string
|
|
|
-, r_reason_desc string
|
|
|
+drop table if exists customer;
|
|
|
+create external table if not exists customer(
|
|
|
+ c_customer_sk bigint
|
|
|
+, c_customer_id char(16)
|
|
|
+, c_current_cdemo_sk bigint
|
|
|
+, c_current_hdemo_sk bigint
|
|
|
+, c_current_addr_sk bigint
|
|
|
+, c_first_shipto_date_sk bigint
|
|
|
+, c_first_sales_date_sk bigint
|
|
|
+, c_salutation char(10)
|
|
|
+, c_first_name char(20)
|
|
|
+, c_last_name char(30)
|
|
|
+, c_preferred_cust_flag char(1)
|
|
|
+, c_birth_day int
|
|
|
+, c_birth_month int
|
|
|
+, c_birth_year int
|
|
|
+, c_birth_country varchar(20)
|
|
|
+, c_login char(13)
|
|
|
+, c_email_address char(50)
|
|
|
+, c_last_review_date_sk bigint
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/reason';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/customer';
|
|
|
|
|
|
-drop table if exists ship_mode;
|
|
|
+-- Table<customer_address (13 cols)>
|
|
|
|
|
|
-create external table ship_mode(
|
|
|
- sm_ship_mode_sk bigint
|
|
|
-, sm_ship_mode_id string
|
|
|
-, sm_type string
|
|
|
-, sm_code string
|
|
|
-, sm_carrier string
|
|
|
-, sm_contract string
|
|
|
+drop table if exists customer_address;
|
|
|
+create external table if not exists customer_address(
|
|
|
+ ca_address_sk bigint
|
|
|
+, ca_address_id char(16)
|
|
|
+, ca_street_number char(10)
|
|
|
+, ca_street_name varchar(60)
|
|
|
+, ca_street_type char(15)
|
|
|
+, ca_suite_number char(10)
|
|
|
+, ca_city varchar(60)
|
|
|
+, ca_county varchar(30)
|
|
|
+, ca_state char(2)
|
|
|
+, ca_zip char(10)
|
|
|
+, ca_country varchar(20)
|
|
|
+, ca_gmt_offset decimal(5,2)
|
|
|
+, ca_location_type char(20)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/ship_mode';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/customer_address';
|
|
|
|
|
|
-drop table if exists store_returns;
|
|
|
+-- Table<customer_demographics (9 cols)>
|
|
|
|
|
|
-create external table store_returns
|
|
|
-(
|
|
|
- sr_returned_date_sk bigint,
|
|
|
- sr_return_time_sk bigint,
|
|
|
- sr_item_sk bigint,
|
|
|
- sr_customer_sk bigint,
|
|
|
- sr_cdemo_sk bigint,
|
|
|
- sr_hdemo_sk bigint,
|
|
|
- sr_addr_sk bigint,
|
|
|
- sr_store_sk bigint,
|
|
|
- sr_reason_sk bigint,
|
|
|
- sr_ticket_number bigint,
|
|
|
- sr_return_quantity int,
|
|
|
- sr_return_amt double,
|
|
|
- sr_return_tax double,
|
|
|
- sr_return_amt_inc_tax double,
|
|
|
- sr_fee double,
|
|
|
- sr_return_ship_cost double,
|
|
|
- sr_refunded_cash double,
|
|
|
- sr_reversed_charge double,
|
|
|
- sr_store_credit double,
|
|
|
- sr_net_loss double
|
|
|
+drop table if exists customer_demographics;
|
|
|
+create external table if not exists customer_demographics(
|
|
|
+ cd_demo_sk bigint
|
|
|
+, cd_gender char(1)
|
|
|
+, cd_marital_status char(1)
|
|
|
+, cd_education_status char(20)
|
|
|
+, cd_purchase_estimate int
|
|
|
+, cd_credit_rating char(10)
|
|
|
+, cd_dep_count int
|
|
|
+, cd_dep_employed_count int
|
|
|
+, cd_dep_college_count int
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/store_returns';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/customer_demographics';
|
|
|
|
|
|
-drop table if exists store_sales;
|
|
|
+-- Table<date_dim (28 cols)>
|
|
|
|
|
|
-create external table store_sales
|
|
|
-(
|
|
|
- ss_sold_date_sk bigint,
|
|
|
- ss_sold_time_sk bigint,
|
|
|
- ss_item_sk bigint,
|
|
|
- ss_customer_sk bigint,
|
|
|
- ss_cdemo_sk bigint,
|
|
|
- ss_hdemo_sk bigint,
|
|
|
- ss_addr_sk bigint,
|
|
|
- ss_store_sk bigint,
|
|
|
- ss_promo_sk bigint,
|
|
|
- ss_ticket_number bigint,
|
|
|
- ss_quantity int,
|
|
|
- ss_wholesale_cost double,
|
|
|
- ss_list_price double,
|
|
|
- ss_sales_price double,
|
|
|
- ss_ext_discount_amt double,
|
|
|
- ss_ext_sales_price double,
|
|
|
- ss_ext_wholesale_cost double,
|
|
|
- ss_ext_list_price double,
|
|
|
- ss_ext_tax double,
|
|
|
- ss_coupon_amt double,
|
|
|
- ss_net_paid double,
|
|
|
- ss_net_paid_inc_tax double,
|
|
|
- ss_net_profit double
|
|
|
+drop table if exists date_dim;
|
|
|
+create external table if not exists date_dim(
|
|
|
+ d_date_sk bigint
|
|
|
+, d_date_id char(16)
|
|
|
+, d_date date
|
|
|
+, d_month_seq int
|
|
|
+, d_week_seq int
|
|
|
+, d_quarter_seq int
|
|
|
+, d_year int
|
|
|
+, d_dow int
|
|
|
+, d_moy int
|
|
|
+, d_dom int
|
|
|
+, d_qoy int
|
|
|
+, d_fy_year int
|
|
|
+, d_fy_quarter_seq int
|
|
|
+, d_fy_week_seq int
|
|
|
+, d_day_name char(9)
|
|
|
+, d_quarter_name char(6)
|
|
|
+, d_holiday char(1)
|
|
|
+, d_weekend char(1)
|
|
|
+, d_following_holiday char(1)
|
|
|
+, d_first_dom int
|
|
|
+, d_last_dom int
|
|
|
+, d_same_day_ly int
|
|
|
+, d_same_day_lq int
|
|
|
+, d_current_day char(1)
|
|
|
+, d_current_week char(1)
|
|
|
+, d_current_month char(1)
|
|
|
+, d_current_quarter char(1)
|
|
|
+, d_current_year char(1)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/store_sales';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/date_dim';
|
|
|
|
|
|
-drop table if exists store;
|
|
|
+-- Table<household_demographics (5 cols)>
|
|
|
|
|
|
-create external table store
|
|
|
-(
|
|
|
- s_store_sk bigint,
|
|
|
- s_store_id string,
|
|
|
- s_rec_start_date string,
|
|
|
- s_rec_end_date string,
|
|
|
- s_closed_date_sk bigint,
|
|
|
- s_store_name string,
|
|
|
- s_number_employees int,
|
|
|
- s_floor_space int,
|
|
|
- s_hours string,
|
|
|
- s_manager string,
|
|
|
- s_market_id int,
|
|
|
- s_geography_class string,
|
|
|
- s_market_desc string,
|
|
|
- s_market_manager string,
|
|
|
- s_division_id int,
|
|
|
- s_division_name string,
|
|
|
- s_company_id int,
|
|
|
- s_company_name string,
|
|
|
- s_street_number string,
|
|
|
- s_street_name string,
|
|
|
- s_street_type string,
|
|
|
- s_suite_number string,
|
|
|
- s_city string,
|
|
|
- s_county string,
|
|
|
- s_state string,
|
|
|
- s_zip string,
|
|
|
- s_country string,
|
|
|
- s_gmt_offset double,
|
|
|
- s_tax_precentage double
|
|
|
+drop table if exists household_demographics;
|
|
|
+create external table if not exists household_demographics(
|
|
|
+ hd_demo_sk bigint
|
|
|
+, hd_income_band_sk bigint
|
|
|
+, hd_buy_potential char(15)
|
|
|
+, hd_dep_count int
|
|
|
+, hd_vehicle_count int
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/store';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/household_demographics';
|
|
|
|
|
|
-drop table if exists time_dim;
|
|
|
+-- Table<item (22 cols)>
|
|
|
|
|
|
-create external table time_dim
|
|
|
-(
|
|
|
- t_time_sk bigint,
|
|
|
- t_time_id string,
|
|
|
- t_time int,
|
|
|
- t_hour int,
|
|
|
- t_minute int,
|
|
|
- t_second int,
|
|
|
- t_am_pm string,
|
|
|
- t_shift string,
|
|
|
- t_sub_shift string,
|
|
|
- t_meal_time string
|
|
|
+drop table if exists item;
|
|
|
+create external table if not exists item(
|
|
|
+ i_item_sk bigint
|
|
|
+, i_item_id char(16)
|
|
|
+, i_rec_start_date date
|
|
|
+, i_rec_end_date date
|
|
|
+, i_item_desc varchar(200)
|
|
|
+, i_current_price decimal(7,2)
|
|
|
+, i_wholesale_cost decimal(7,2)
|
|
|
+, i_brand_id int
|
|
|
+, i_brand char(50)
|
|
|
+, i_class_id int
|
|
|
+, i_class char(50)
|
|
|
+, i_category_id int
|
|
|
+, i_category char(50)
|
|
|
+, i_manufact_id int
|
|
|
+, i_manufact char(50)
|
|
|
+, i_size char(20)
|
|
|
+, i_formulation char(20)
|
|
|
+, i_color char(20)
|
|
|
+, i_units char(10)
|
|
|
+, i_container char(10)
|
|
|
+, i_manager_id int
|
|
|
+, i_product_name char(50)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/time_dim';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/item';
|
|
|
|
|
|
-drop table if exists warehouse;
|
|
|
+-- Table<income_band (3 cols)>
|
|
|
|
|
|
-create external table warehouse(
|
|
|
- w_warehouse_sk bigint
|
|
|
-, w_warehouse_id string
|
|
|
-, w_warehouse_name string
|
|
|
-, w_warehouse_sq_ft int
|
|
|
-, w_street_number string
|
|
|
-, w_street_name string
|
|
|
-, w_street_type string
|
|
|
-, w_suite_number string
|
|
|
-, w_city string
|
|
|
-, w_county string
|
|
|
-, w_state string
|
|
|
-, w_zip string
|
|
|
-, w_country string
|
|
|
-, w_gmt_offset double
|
|
|
+drop table if exists income_band;
|
|
|
+create external table if not exists income_band(
|
|
|
+ ib_income_band_sk bigint
|
|
|
+, ib_lower_bound int
|
|
|
+, ib_upper_bound int
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/warehouse';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/income_band';
|
|
|
|
|
|
-drop table if exists web_page;
|
|
|
+-- Table<promotion (19 cols)>
|
|
|
|
|
|
-create external table web_page(
|
|
|
- wp_web_page_sk bigint
|
|
|
-, wp_web_page_id string
|
|
|
-, wp_rec_start_date string
|
|
|
-, wp_rec_end_date string
|
|
|
-, wp_creation_date_sk bigint
|
|
|
-, wp_access_date_sk bigint
|
|
|
-, wp_autogen_flag string
|
|
|
-, wp_customer_sk bigint
|
|
|
-, wp_url string
|
|
|
-, wp_type string
|
|
|
-, wp_char_count int
|
|
|
-, wp_link_count int
|
|
|
-, wp_image_count int
|
|
|
-, wp_max_ad_count int
|
|
|
+drop table if exists promotion;
|
|
|
+create external table if not exists promotion(
|
|
|
+ p_promo_sk bigint
|
|
|
+, p_promo_id char(16)
|
|
|
+, p_start_date_sk bigint
|
|
|
+, p_end_date_sk bigint
|
|
|
+, p_item_sk bigint
|
|
|
+, p_cost decimal(15,2)
|
|
|
+, p_response_target int
|
|
|
+, p_promo_name char(50)
|
|
|
+, p_channel_dmail char(1)
|
|
|
+, p_channel_email char(1)
|
|
|
+, p_channel_catalog char(1)
|
|
|
+, p_channel_tv char(1)
|
|
|
+, p_channel_radio char(1)
|
|
|
+, p_channel_press char(1)
|
|
|
+, p_channel_event char(1)
|
|
|
+, p_channel_demo char(1)
|
|
|
+, p_channel_details varchar(100)
|
|
|
+, p_purpose char(15)
|
|
|
+, p_discount_active char(1)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/web_page';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/promotion';
|
|
|
|
|
|
-drop table if exists web_returns;
|
|
|
+-- Table<reason (3 cols)>
|
|
|
|
|
|
-create external table web_returns
|
|
|
-(
|
|
|
- wr_returned_date_sk bigint,
|
|
|
- wr_returned_time_sk bigint,
|
|
|
- wr_item_sk bigint,
|
|
|
- wr_refunded_customer_sk bigint,
|
|
|
- wr_refunded_cdemo_sk bigint,
|
|
|
- wr_refunded_hdemo_sk bigint,
|
|
|
- wr_refunded_addr_sk bigint,
|
|
|
- wr_returning_customer_sk bigint,
|
|
|
- wr_returning_cdemo_sk bigint,
|
|
|
- wr_returning_hdemo_sk bigint,
|
|
|
- wr_returning_addr_sk bigint,
|
|
|
- wr_web_page_sk bigint,
|
|
|
- wr_reason_sk bigint,
|
|
|
- wr_order_number bigint,
|
|
|
- wr_return_quantity int,
|
|
|
- wr_return_amt double,
|
|
|
- wr_return_tax double,
|
|
|
- wr_return_amt_inc_tax double,
|
|
|
- wr_fee double,
|
|
|
- wr_return_ship_cost double,
|
|
|
- wr_refunded_cash double,
|
|
|
- wr_reversed_charge double,
|
|
|
- wr_account_credit double,
|
|
|
- wr_net_loss double
|
|
|
+drop table if exists reason;
|
|
|
+create external table if not exists reason(
|
|
|
+ r_reason_sk bigint
|
|
|
+, r_reason_id char(16)
|
|
|
+, r_reason_desc char(100)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/web_returns';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/reason';
|
|
|
|
|
|
-drop table if exists web_sales;
|
|
|
+-- Table<ship_mode (6 cols)>
|
|
|
|
|
|
-create external table web_sales
|
|
|
-(
|
|
|
- ws_sold_date_sk bigint,
|
|
|
- ws_sold_time_sk bigint,
|
|
|
- ws_ship_date_sk bigint,
|
|
|
- ws_item_sk bigint,
|
|
|
- ws_bill_customer_sk bigint,
|
|
|
- ws_bill_cdemo_sk bigint,
|
|
|
- ws_bill_hdemo_sk bigint,
|
|
|
- ws_bill_addr_sk bigint,
|
|
|
- ws_ship_customer_sk bigint,
|
|
|
- ws_ship_cdemo_sk bigint,
|
|
|
- ws_ship_hdemo_sk bigint,
|
|
|
- ws_ship_addr_sk bigint,
|
|
|
- ws_web_page_sk bigint,
|
|
|
- ws_web_site_sk bigint,
|
|
|
- ws_ship_mode_sk bigint,
|
|
|
- ws_warehouse_sk bigint,
|
|
|
- ws_promo_sk bigint,
|
|
|
- ws_order_number bigint,
|
|
|
- ws_quantity int,
|
|
|
- ws_wholesale_cost double,
|
|
|
- ws_list_price double,
|
|
|
- ws_sales_price double,
|
|
|
- ws_ext_discount_amt double,
|
|
|
- ws_ext_sales_price double,
|
|
|
- ws_ext_wholesale_cost double,
|
|
|
- ws_ext_list_price double,
|
|
|
- ws_ext_tax double,
|
|
|
- ws_coupon_amt double,
|
|
|
- ws_ext_ship_cost double,
|
|
|
- ws_net_paid double,
|
|
|
- ws_net_paid_inc_tax double,
|
|
|
- ws_net_paid_inc_ship double,
|
|
|
- ws_net_paid_inc_ship_tax double,
|
|
|
- ws_net_profit double
|
|
|
+drop table if exists ship_mode;
|
|
|
+create external table if not exists ship_mode(
|
|
|
+ sm_ship_mode_sk bigint
|
|
|
+, sm_ship_mode_id char(16)
|
|
|
+, sm_type char(30)
|
|
|
+, sm_code char(10)
|
|
|
+, sm_carrier char(20)
|
|
|
+, sm_contract char(20)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/web_sales';
|
|
|
-create database if not exists ${DB};
|
|
|
-use ${DB};
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/ship_mode';
|
|
|
|
|
|
-drop table if exists web_site;
|
|
|
+-- Table<time_dim (10 cols)>
|
|
|
|
|
|
-create external table web_site
|
|
|
-(
|
|
|
- web_site_sk bigint,
|
|
|
- web_site_id string,
|
|
|
- web_rec_start_date string,
|
|
|
- web_rec_end_date string,
|
|
|
- web_name string,
|
|
|
- web_open_date_sk bigint,
|
|
|
- web_close_date_sk bigint,
|
|
|
- web_class string,
|
|
|
- web_manager string,
|
|
|
- web_mkt_id int,
|
|
|
- web_mkt_class string,
|
|
|
- web_mkt_desc string,
|
|
|
- web_market_manager string,
|
|
|
- web_company_id int,
|
|
|
- web_company_name string,
|
|
|
- web_street_number string,
|
|
|
- web_street_name string,
|
|
|
- web_street_type string,
|
|
|
- web_suite_number string,
|
|
|
- web_city string,
|
|
|
- web_county string,
|
|
|
- web_state string,
|
|
|
- web_zip string,
|
|
|
- web_country string,
|
|
|
- web_gmt_offset double,
|
|
|
- web_tax_percentage double
|
|
|
+drop table if exists time_dim;
|
|
|
+create external table if not exists time_dim(
|
|
|
+ t_time_sk bigint
|
|
|
+, t_time_id char(16)
|
|
|
+, t_time int
|
|
|
+, t_hour int
|
|
|
+, t_minute int
|
|
|
+, t_second int
|
|
|
+, t_am_pm char(2)
|
|
|
+, t_shift char(20)
|
|
|
+, t_sub_shift char(20)
|
|
|
+, t_meal_time char(20)
|
|
|
)
|
|
|
-row format delimited fields terminated by '|'
|
|
|
-location '${LOCATION}/web_site';
|
|
|
+row format delimited fields terminated by '|'
|
|
|
+location '${LOCATION}/time_dim';
|
|
|
+
|
root