Bladeren bron

Remove old DDL directory

cartershanklin 11 jaren geleden
bovenliggende
commit
9c9f2cff5d
50 gewijzigde bestanden met toevoegingen van 0 en 1965 verwijderingen
  1. 0 29
      ddl/bin_partitioned/analyze.sql
  2. 0 8
      ddl/bin_partitioned/call_center.sql
  3. 0 8
      ddl/bin_partitioned/catalog_page.sql
  4. 0 72
      ddl/bin_partitioned/catalog_returns.sql
  5. 0 86
      ddl/bin_partitioned/catalog_sales.sql
  6. 0 8
      ddl/bin_partitioned/customer.sql
  7. 0 8
      ddl/bin_partitioned/customer_address.sql
  8. 0 8
      ddl/bin_partitioned/customer_demographics.sql
  9. 0 8
      ddl/bin_partitioned/date_dim.sql
  10. 0 8
      ddl/bin_partitioned/household_demographics.sql
  11. 0 8
      ddl/bin_partitioned/income_band.sql
  12. 0 26
      ddl/bin_partitioned/inventory.sql
  13. 0 34
      ddl/bin_partitioned/item.sql
  14. 0 8
      ddl/bin_partitioned/promotion.sql
  15. 0 8
      ddl/bin_partitioned/reason.sql
  16. 0 8
      ddl/bin_partitioned/ship_mode.sql
  17. 0 8
      ddl/bin_partitioned/store.sql
  18. 0 58
      ddl/bin_partitioned/store_returns.sql
  19. 0 64
      ddl/bin_partitioned/store_sales.sql
  20. 0 8
      ddl/bin_partitioned/time_dim.sql
  21. 0 8
      ddl/bin_partitioned/warehouse.sql
  22. 0 8
      ddl/bin_partitioned/web_page.sql
  23. 0 66
      ddl/bin_partitioned/web_returns.sql
  24. 0 86
      ddl/bin_partitioned/web_sales.sql
  25. 0 8
      ddl/bin_partitioned/web_site.sql
  26. 0 658
      ddl/text/alltables.sql
  27. 0 40
      ddl/text/call_center.sql
  28. 0 18
      ddl/text/catalog_page.sql
  29. 0 37
      ddl/text/catalog_returns.sql
  30. 0 44
      ddl/text/catalog_sales.sql
  31. 0 28
      ddl/text/customer.sql
  32. 0 23
      ddl/text/customer_address.sql
  33. 0 19
      ddl/text/customer_demographics.sql
  34. 0 38
      ddl/text/date_dim.sql
  35. 0 15
      ddl/text/household_demographics.sql
  36. 0 12
      ddl/text/income_band.sql
  37. 0 14
      ddl/text/inventory.sql
  38. 0 32
      ddl/text/item.sql
  39. 0 29
      ddl/text/promotion.sql
  40. 0 12
      ddl/text/reason.sql
  41. 0 15
      ddl/text/ship_mode.sql
  42. 0 39
      ddl/text/store.sql
  43. 0 30
      ddl/text/store_returns.sql
  44. 0 33
      ddl/text/store_sales.sql
  45. 0 20
      ddl/text/time_dim.sql
  46. 0 23
      ddl/text/warehouse.sql
  47. 0 23
      ddl/text/web_page.sql
  48. 0 34
      ddl/text/web_returns.sql
  49. 0 44
      ddl/text/web_sales.sql
  50. 0 36
      ddl/text/web_site.sql

+ 0 - 29
ddl/bin_partitioned/analyze.sql

@@ -1,29 +0,0 @@
-use ${DB};
-ADD JAR file://${mysql_jar};
-
-ANALYZE TABLE date_dim COMPUTE STATISTICS;
-ANALYZE TABLE time_dim COMPUTE STATISTICS;
-ANALYZE TABLE item COMPUTE STATISTICS;
-ANALYZE TABLE customer COMPUTE STATISTICS;
-ANALYZE TABLE customer_demographics COMPUTE STATISTICS;
-ANALYZE TABLE household_demographics COMPUTE STATISTICS;
-ANALYZE TABLE customer_address COMPUTE STATISTICS;
-ANALYZE TABLE store COMPUTE STATISTICS;
-ANALYZE TABLE promotion COMPUTE STATISTICS;
-ANALYZE TABLE web_site COMPUTE STATISTICS;
-
-ANALYZE TABLE inventory partition(inv_date) COMPUTE STATISTICS;
-ANALYZE TABLE store_sales partition(ss_sold_date) COMPUTE STATISTICS;
-ANALYZE TABLE store_returns partition(sr_returned_date) COMPUTE STATISTICS;
-ANALYZE TABLE web_sales partition(ws_sold_date) COMPUTE STATISTICS;
-ANALYZE TABLE web_returns partition(wr_returned_date) COMPUTE STATISTICS;
-ANALYZE TABLE catalog_sales partition(cs_sold_date) COMPUTE STATISTICS;
-ANALYZE TABLE catalog_returns partition(cr_returned_date) COMPUTE STATISTICS;
-
-ANALYZE TABLE web_page COMPUTE STATISTICS;
-ANALYZE TABLE income_band COMPUTE STATISTICS;
-ANALYZE TABLE call_center COMPUTE STATISTICS;
-ANALYZE TABLE ship_mode COMPUTE STATISTICS;
-ANALYZE TABLE reason COMPUTE STATISTICS;
-ANALYZE TABLE catalog_page COMPUTE STATISTICS;
-ANALYZE TABLE warehouse COMPUTE STATISTICS;

+ 0 - 8
ddl/bin_partitioned/call_center.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists call_center;
-
-create table call_center
-stored as ${FILE}
-as select * from ${SOURCE}.call_center;

+ 0 - 8
ddl/bin_partitioned/catalog_page.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_page;
-
-create table catalog_page
-stored as ${FILE}
-as select * from ${SOURCE}.catalog_page;

+ 0 - 72
ddl/bin_partitioned/catalog_returns.sql

@@ -1,72 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_returns;
-
-create table catalog_returns
-(
-    cr_returned_date_sk       int,
-    cr_returned_time_sk       int,
-    cr_item_sk                int,
-    cr_refunded_customer_sk   int,
-    cr_refunded_cdemo_sk      int,
-    cr_refunded_hdemo_sk      int,
-    cr_refunded_addr_sk       int,
-    cr_returning_customer_sk  int,
-    cr_returning_cdemo_sk     int,
-    cr_returning_hdemo_sk     int,
-    cr_returning_addr_sk      int,
-    cr_call_center_sk         int,
-    cr_catalog_page_sk        int,
-    cr_ship_mode_sk           int,
-    cr_warehouse_sk           int,
-    cr_reason_sk              int,
-    cr_order_number           int,
-    cr_return_quantity        int,
-    cr_return_amount          float,
-    cr_return_tax             float,
-    cr_return_amt_inc_tax     float,
-    cr_fee                    float,
-    cr_return_ship_cost       float,
-    cr_refunded_cash          float,
-    cr_reversed_charge        float,
-    cr_store_credit           float,
-    cr_net_loss               float
-)
-partitioned by (cr_returned_date string)
-clustered by (cr_item_sk) sorted by (cr_item_sk) into ${RETURN_BUCKETS} buckets
-stored as ${FILE};
-
-insert overwrite table catalog_returns partition (cr_returned_date) 
-select
-        cr.cr_returned_date_sk,
-        cr.cr_returned_time_sk,
-        cr.cr_item_sk,
-        cr.cr_refunded_customer_sk,
-        cr.cr_refunded_cdemo_sk,
-        cr.cr_refunded_hdemo_sk,
-        cr.cr_refunded_addr_sk,
-        cr.cr_returning_customer_sk,
-        cr.cr_returning_cdemo_sk,
-        cr.cr_returning_hdemo_sk,
-        cr.cr_returning_addr_sk,
-        cr.cr_call_center_sk,
-        cr.cr_catalog_page_sk,
-        cr.cr_ship_mode_sk,
-        cr.cr_warehouse_sk,
-        cr.cr_reason_sk,
-        cr.cr_order_number,
-        cr.cr_return_quantity,
-        cr.cr_return_amount,
-        cr.cr_return_tax,
-        cr.cr_return_amt_inc_tax,
-        cr.cr_fee,
-        cr.cr_return_ship_cost,
-        cr.cr_refunded_cash,
-        cr.cr_reversed_charge,
-        cr.cr_store_credit,
-        cr.cr_net_loss,
-        dd.d_date as cr_returned_date
-      from ${SOURCE}.catalog_returns cr
-      join ${SOURCE}.date_dim dd
-      on (cr.cr_returned_date_sk = dd.d_date_sk);

+ 0 - 86
ddl/bin_partitioned/catalog_sales.sql

@@ -1,86 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_sales;
-
-create table catalog_sales
-(
-    cs_sold_date_sk           int,
-    cs_sold_time_sk           int,
-    cs_ship_date_sk           int,
-    cs_bill_customer_sk       int,
-    cs_bill_cdemo_sk          int,
-    cs_bill_hdemo_sk          int,
-    cs_bill_addr_sk           int,
-    cs_ship_customer_sk       int,
-    cs_ship_cdemo_sk          int,
-    cs_ship_hdemo_sk          int,
-    cs_ship_addr_sk           int,
-    cs_call_center_sk         int,
-    cs_catalog_page_sk        int,
-    cs_ship_mode_sk           int,
-    cs_warehouse_sk           int,
-    cs_item_sk                int,
-    cs_promo_sk               int,
-    cs_order_number           int,
-    cs_quantity               int,
-    cs_wholesale_cost         float,
-    cs_list_price             float,
-    cs_sales_price            float,
-    cs_ext_discount_amt       float,
-    cs_ext_sales_price        float,
-    cs_ext_wholesale_cost     float,
-    cs_ext_list_price         float,
-    cs_ext_tax                float,
-    cs_coupon_amt             float,
-    cs_ext_ship_cost          float,
-    cs_net_paid               float,
-    cs_net_paid_inc_tax       float,
-    cs_net_paid_inc_ship      float,
-    cs_net_paid_inc_ship_tax  float,
-    cs_net_profit             float
-)
-partitioned by (cs_sold_date string)
-clustered by (cs_item_sk) sorted by (cs_item_sk) into ${BUCKETS} buckets
-stored as ${FILE};
-
-insert overwrite table catalog_sales partition (cs_sold_date) 
-select
-        cs.cs_sold_date_sk,
-        cs.cs_sold_time_sk,
-        cs.cs_ship_date_sk,
-        cs.cs_bill_customer_sk,
-        cs.cs_bill_cdemo_sk,
-        cs.cs_bill_hdemo_sk,
-        cs.cs_bill_addr_sk,
-        cs.cs_ship_customer_sk,
-        cs.cs_ship_cdemo_sk,
-        cs.cs_ship_hdemo_sk,
-        cs.cs_ship_addr_sk,
-        cs.cs_call_center_sk,
-        cs.cs_catalog_page_sk,
-        cs.cs_ship_mode_sk,
-        cs.cs_warehouse_sk,
-        cs.cs_item_sk,
-        cs.cs_promo_sk,
-        cs.cs_order_number,
-        cs.cs_quantity,
-        cs.cs_wholesale_cost,
-        cs.cs_list_price,
-        cs.cs_sales_price,
-        cs.cs_ext_discount_amt,
-        cs.cs_ext_sales_price,
-        cs.cs_ext_wholesale_cost,
-        cs.cs_ext_list_price,
-        cs.cs_ext_tax,
-        cs.cs_coupon_amt,
-        cs.cs_ext_ship_cost,
-        cs.cs_net_paid,
-        cs.cs_net_paid_inc_tax,
-        cs.cs_net_paid_inc_ship,
-        cs.cs_net_paid_inc_ship_tax,
-        cs.cs_net_profit,
-        dd.d_date as cs_sold_date
-      from ${SOURCE}.catalog_sales cs
-      join ${SOURCE}.date_dim dd
-      on (cs.cs_sold_date_sk = dd.d_date_sk);

+ 0 - 8
ddl/bin_partitioned/customer.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer;
-
-create table customer
-stored as ${FILE}
-as select * from ${SOURCE}.customer;

+ 0 - 8
ddl/bin_partitioned/customer_address.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer_address;
-
-create table customer_address
-stored as ${FILE}
-as select * from ${SOURCE}.customer_address;

+ 0 - 8
ddl/bin_partitioned/customer_demographics.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer_demographics;
-
-create table customer_demographics
-stored as ${FILE}
-as select * from ${SOURCE}.customer_demographics;

+ 0 - 8
ddl/bin_partitioned/date_dim.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists date_dim;
-
-create table date_dim
-stored as ${FILE}
-as select * from ${SOURCE}.date_dim;

+ 0 - 8
ddl/bin_partitioned/household_demographics.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists household_demographics;
-
-create table household_demographics
-stored as ${FILE}
-as select * from ${SOURCE}.household_demographics;

+ 0 - 8
ddl/bin_partitioned/income_band.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists income_band;
-
-create table income_band
-stored as ${FILE}
-as select * from ${SOURCE}.income_band;

+ 0 - 26
ddl/bin_partitioned/inventory.sql

@@ -1,26 +0,0 @@
-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);

+ 0 - 34
ddl/bin_partitioned/item.sql

@@ -1,34 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists item;
-
-create table item
-(
-    i_item_sk                 int,
-    i_item_id                 string,
-    i_rec_start_date          string,
-    i_rec_end_date            string,
-    i_item_desc               string,
-    i_current_price           float,
-    i_wholesale_cost          float,
-    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
-)
-stored as ${FILE};
-
-insert overwrite table item
-select * from ${SOURCE}.item;

+ 0 - 8
ddl/bin_partitioned/promotion.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists promotion;
-
-create table promotion
-stored as ${FILE}
-as select * from ${SOURCE}.promotion;

+ 0 - 8
ddl/bin_partitioned/reason.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists reason;
-
-create table reason
-stored as ${FILE}
-as select * from ${SOURCE}.reason;

+ 0 - 8
ddl/bin_partitioned/ship_mode.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists ship_mode;
-
-create table ship_mode
-stored as ${FILE}
-as select * from ${SOURCE}.ship_mode;

+ 0 - 8
ddl/bin_partitioned/store.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store;
-
-create table store
-stored as ${FILE}
-as select * from ${SOURCE}.store;

+ 0 - 58
ddl/bin_partitioned/store_returns.sql

@@ -1,58 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store_returns;
-
-create table store_returns
-(
-    sr_returned_date_sk       int,
-    sr_return_time_sk         int,
-    sr_item_sk                int,
-    sr_customer_sk            int,
-    sr_cdemo_sk               int,
-    sr_hdemo_sk               int,
-    sr_addr_sk                int,
-    sr_store_sk               int,
-    sr_reason_sk              int,
-    sr_ticket_number          int,
-    sr_return_quantity        int,
-    sr_return_amt             float,
-    sr_return_tax             float,
-    sr_return_amt_inc_tax     float,
-    sr_fee                    float,
-    sr_return_ship_cost       float,
-    sr_refunded_cash          float,
-    sr_reversed_charge        float,
-    sr_store_credit           float,
-    sr_net_loss               float
-)
-partitioned by (sr_returned_date string)
-clustered by (sr_item_sk) sorted by (sr_item_sk) into ${RETURN_BUCKETS} buckets
-stored as ${FILE};
-
-insert overwrite table store_returns partition (sr_returned_date) 
-select
-        sr.sr_returned_date_sk,
-        sr.sr_return_time_sk,
-        sr.sr_item_sk,
-        sr.sr_customer_sk,
-        sr.sr_cdemo_sk,
-        sr.sr_hdemo_sk,
-        sr.sr_addr_sk,
-        sr.sr_store_sk,
-        sr.sr_reason_sk,
-        sr.sr_ticket_number,
-        sr.sr_return_quantity,
-        sr.sr_return_amt,
-        sr.sr_return_tax,
-        sr.sr_return_amt_inc_tax,
-        sr.sr_fee,
-        sr.sr_return_ship_cost,
-        sr.sr_refunded_cash,
-        sr.sr_reversed_charge,
-        sr.sr_store_credit,
-        sr.sr_net_loss,
-        dd.d_date as sr_returned_date
-      from ${SOURCE}.store_returns sr
-      join ${SOURCE}.date_dim dd
-      on (sr.sr_returned_date_sk = dd.d_date_sk);

+ 0 - 64
ddl/bin_partitioned/store_sales.sql

@@ -1,64 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store_sales;
-
-create table store_sales
-(
-    ss_sold_date_sk           int,
-    ss_sold_time_sk           int,
-    ss_item_sk                int,
-    ss_customer_sk            int,
-    ss_cdemo_sk               int,
-    ss_hdemo_sk               int,
-    ss_addr_sk                int,
-    ss_store_sk               int,
-    ss_promo_sk               int,
-    ss_ticket_number          int,
-    ss_quantity               int,
-    ss_wholesale_cost         float,
-    ss_list_price             float,
-    ss_sales_price            float,
-    ss_ext_discount_amt       float,
-    ss_ext_sales_price        float,
-    ss_ext_wholesale_cost     float,
-    ss_ext_list_price         float,
-    ss_ext_tax                float,
-    ss_coupon_amt             float,
-    ss_net_paid               float,
-    ss_net_paid_inc_tax       float,
-    ss_net_profit             float
-)
-partitioned by (ss_sold_date string)
-clustered by (ss_item_sk) sorted by (ss_item_sk) into ${BUCKETS} buckets
-stored as ${FILE};
-
-insert overwrite table store_sales partition (ss_sold_date) 
-select
-        ss.ss_sold_date_sk,
-        ss.ss_sold_time_sk,
-        ss.ss_item_sk,
-        ss.ss_customer_sk,
-        ss.ss_cdemo_sk,
-        ss.ss_hdemo_sk,
-        ss.ss_addr_sk,
-        ss.ss_store_sk,
-        ss.ss_promo_sk,
-        ss.ss_ticket_number,
-        ss.ss_quantity,
-        ss.ss_wholesale_cost,
-        ss.ss_list_price,
-        ss.ss_sales_price,
-        ss.ss_ext_discount_amt,
-        ss.ss_ext_sales_price,
-        ss.ss_ext_wholesale_cost,
-        ss.ss_ext_list_price,
-        ss.ss_ext_tax,
-        ss.ss_coupon_amt,
-        ss.ss_net_paid,
-        ss.ss_net_paid_inc_tax,
-        ss.ss_net_profit,
-        dd.d_date as ss_sold_date
-      from ${SOURCE}.store_sales ss
-      join ${SOURCE}.date_dim dd
-      on (ss.ss_sold_date_sk = dd.d_date_sk);

+ 0 - 8
ddl/bin_partitioned/time_dim.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists time_dim;
-
-create table time_dim
-stored as ${FILE}
-as select * from ${SOURCE}.time_dim;

+ 0 - 8
ddl/bin_partitioned/warehouse.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists warehouse;
-
-create table warehouse
-stored as ${FILE}
-as select * from ${SOURCE}.warehouse;

+ 0 - 8
ddl/bin_partitioned/web_page.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_page;
-
-create table web_page
-stored as ${FILE}
-as select * from ${SOURCE}.web_page;

+ 0 - 66
ddl/bin_partitioned/web_returns.sql

@@ -1,66 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_returns;
-
-create table web_returns
-(
-    wr_returned_date_sk       int,
-    wr_returned_time_sk       int,
-    wr_item_sk                int,
-    wr_refunded_customer_sk   int,
-    wr_refunded_cdemo_sk      int,
-    wr_refunded_hdemo_sk      int,
-    wr_refunded_addr_sk       int,
-    wr_returning_customer_sk  int,
-    wr_returning_cdemo_sk     int,
-    wr_returning_hdemo_sk     int,
-    wr_returning_addr_sk      int,
-    wr_web_page_sk            int,
-    wr_reason_sk              int,
-    wr_order_number           int,
-    wr_return_quantity        int,
-    wr_return_amt             float,
-    wr_return_tax             float,
-    wr_return_amt_inc_tax     float,
-    wr_fee                    float,
-    wr_return_ship_cost       float,
-    wr_refunded_cash          float,
-    wr_reversed_charge        float,
-    wr_account_credit         float,
-    wr_net_loss               float
-)
-partitioned by (wr_returned_date string)
-clustered by (wr_item_sk) sorted by (wr_item_sk) into ${RETURN_BUCKETS} buckets
-stored as ${FILE};
-
-insert overwrite table web_returns partition (wr_returned_date)
-select
-        wr.wr_returned_date_sk,
-        wr.wr_returned_time_sk,
-        wr.wr_item_sk,
-        wr.wr_refunded_customer_sk,
-        wr.wr_refunded_cdemo_sk,
-        wr.wr_refunded_hdemo_sk,
-        wr.wr_refunded_addr_sk,
-        wr.wr_returning_customer_sk,
-        wr.wr_returning_cdemo_sk,
-        wr.wr_returning_hdemo_sk,
-        wr.wr_returning_addr_sk,
-        wr.wr_web_page_sk,
-        wr.wr_reason_sk,
-        wr.wr_order_number,
-        wr.wr_return_quantity,
-        wr.wr_return_amt,
-        wr.wr_return_tax,
-        wr.wr_return_amt_inc_tax,
-        wr.wr_fee,
-        wr.wr_return_ship_cost,
-        wr.wr_refunded_cash,
-        wr.wr_reversed_charge,
-        wr.wr_account_credit,
-        wr.wr_net_loss,
-        dd.d_date as wr_returned_date
-      from ${SOURCE}.web_returns wr
-      join ${SOURCE}.date_dim dd
-      on (wr.wr_returned_date_sk = dd.d_date_sk);

+ 0 - 86
ddl/bin_partitioned/web_sales.sql

@@ -1,86 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_sales;
-
-create table web_sales
-(
-    ws_sold_date_sk           int,
-    ws_sold_time_sk           int,
-    ws_ship_date_sk           int,
-    ws_item_sk                int,
-    ws_bill_customer_sk       int,
-    ws_bill_cdemo_sk          int,
-    ws_bill_hdemo_sk          int,
-    ws_bill_addr_sk           int,
-    ws_ship_customer_sk       int,
-    ws_ship_cdemo_sk          int,
-    ws_ship_hdemo_sk          int,
-    ws_ship_addr_sk           int,
-    ws_web_page_sk            int,
-    ws_web_site_sk            int,
-    ws_ship_mode_sk           int,
-    ws_warehouse_sk           int,
-    ws_promo_sk               int,
-    ws_order_number           int,
-    ws_quantity               int,
-    ws_wholesale_cost         float,
-    ws_list_price             float,
-    ws_sales_price            float,
-    ws_ext_discount_amt       float,
-    ws_ext_sales_price        float,
-    ws_ext_wholesale_cost     float,
-    ws_ext_list_price         float,
-    ws_ext_tax                float,
-    ws_coupon_amt             float,
-    ws_ext_ship_cost          float,
-    ws_net_paid               float,
-    ws_net_paid_inc_tax       float,
-    ws_net_paid_inc_ship      float,
-    ws_net_paid_inc_ship_tax  float,
-    ws_net_profit             float
-)
-partitioned by (ws_sold_date string)
-clustered by (ws_item_sk) sorted by (ws_item_sk) into ${BUCKETS} buckets
-stored as ${FILE};
-
-insert overwrite table web_sales partition (ws_sold_date) 
-select
-        ws.ws_sold_date_sk,
-        ws.ws_sold_time_sk,
-        ws.ws_ship_date_sk,
-        ws.ws_item_sk,
-        ws.ws_bill_customer_sk,
-        ws.ws_bill_cdemo_sk,
-        ws.ws_bill_hdemo_sk,
-        ws.ws_bill_addr_sk,
-        ws.ws_ship_customer_sk,
-        ws.ws_ship_cdemo_sk,
-        ws.ws_ship_hdemo_sk,
-        ws.ws_ship_addr_sk,
-        ws.ws_web_page_sk,
-        ws.ws_web_site_sk,
-        ws.ws_ship_mode_sk,
-        ws.ws_warehouse_sk,
-        ws.ws_promo_sk,
-        ws.ws_order_number,
-        ws.ws_quantity,
-        ws.ws_wholesale_cost,
-        ws.ws_list_price,
-        ws.ws_sales_price,
-        ws.ws_ext_discount_amt,
-        ws.ws_ext_sales_price,
-        ws.ws_ext_wholesale_cost,
-        ws.ws_ext_list_price,
-        ws.ws_ext_tax,
-        ws.ws_coupon_amt,
-        ws.ws_ext_ship_cost,
-        ws.ws_net_paid,
-        ws.ws_net_paid_inc_tax,
-        ws.ws_net_paid_inc_ship,
-        ws.ws_net_paid_inc_ship_tax,
-        ws.ws_net_profit,
-        dd.d_date as ws_sold_date
-      from ${SOURCE}.web_sales ws
-      join ${SOURCE}.date_dim dd
-      on (ws.ws_sold_date_sk = dd.d_date_sk);

+ 0 - 8
ddl/bin_partitioned/web_site.sql

@@ -1,8 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_site;
-
-create table web_site
-stored as ${FILE}
-as select * from ${SOURCE}.web_site;

+ 0 - 658
ddl/text/alltables.sql

@@ -1,658 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists call_center;
-
-create external table call_center(
-      cc_call_center_sk         int               
-,     cc_call_center_id         string              
-,     cc_rec_start_date        string                         
-,     cc_rec_end_date          string                         
-,     cc_closed_date_sk         int                       
-,     cc_open_date_sk           int                       
-,     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             float                  
-,     cc_tax_percentage         float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/call_center';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_page;
-
-create external table catalog_page(
-      cp_catalog_page_sk        int               
-,     cp_catalog_page_id        string              
-,     cp_start_date_sk          int                       
-,     cp_end_date_sk            int                       
-,     cp_department             string                   
-,     cp_catalog_number         int                       
-,     cp_catalog_page_number    int                       
-,     cp_description            string                  
-,     cp_type                   string
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/catalog_page';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_returns;
-
-create external table catalog_returns
-(
-    cr_returned_date_sk       int,
-    cr_returned_time_sk       int,
-    cr_item_sk                int,
-    cr_refunded_customer_sk   int,
-    cr_refunded_cdemo_sk      int,
-    cr_refunded_hdemo_sk      int,
-    cr_refunded_addr_sk       int,
-    cr_returning_customer_sk  int,
-    cr_returning_cdemo_sk     int,
-    cr_returning_hdemo_sk     int,
-    cr_returning_addr_sk      int,
-    cr_call_center_sk         int,
-    cr_catalog_page_sk        int,
-    cr_ship_mode_sk           int,
-    cr_warehouse_sk           int,
-    cr_reason_sk              int,
-    cr_order_number           int,
-    cr_return_quantity        int,
-    cr_return_amount          float,
-    cr_return_tax             float,
-    cr_return_amt_inc_tax     float,
-    cr_fee                    float,
-    cr_return_ship_cost       float,
-    cr_refunded_cash          float,
-    cr_reversed_charge        float,
-    cr_store_credit           float,
-    cr_net_loss               float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/catalog_returns';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_sales;
-
-create external table catalog_sales
-(
-    cs_sold_date_sk           int,
-    cs_sold_time_sk           int,
-    cs_ship_date_sk           int,
-    cs_bill_customer_sk       int,
-    cs_bill_cdemo_sk          int,
-    cs_bill_hdemo_sk          int,
-    cs_bill_addr_sk           int,
-    cs_ship_customer_sk       int,
-    cs_ship_cdemo_sk          int,
-    cs_ship_hdemo_sk          int,
-    cs_ship_addr_sk           int,
-    cs_call_center_sk         int,
-    cs_catalog_page_sk        int,
-    cs_ship_mode_sk           int,
-    cs_warehouse_sk           int,
-    cs_item_sk                int,
-    cs_promo_sk               int,
-    cs_order_number           int,
-    cs_quantity               int,
-    cs_wholesale_cost         float,
-    cs_list_price             float,
-    cs_sales_price            float,
-    cs_ext_discount_amt       float,
-    cs_ext_sales_price        float,
-    cs_ext_wholesale_cost     float,
-    cs_ext_list_price         float,
-    cs_ext_tax                float,
-    cs_coupon_amt             float,
-    cs_ext_ship_cost          float,
-    cs_net_paid               float,
-    cs_net_paid_inc_tax       float,
-    cs_net_paid_inc_ship      float,
-    cs_net_paid_inc_ship_tax  float,
-    cs_net_profit             float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/catalog_sales';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer_address;
-
-create external table customer_address
-(
-    ca_address_sk             int,
-    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             float,
-    ca_location_type          string
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/customer_address';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer_demographics;
-
-create external table customer_demographics
-(
-    cd_demo_sk                int,
-    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 
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/customer_demographics';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer;
-
-create external table customer
-(
-    c_customer_sk             int,
-    c_customer_id             string,
-    c_current_cdemo_sk        int,
-    c_current_hdemo_sk        int,
-    c_current_addr_sk         int,
-    c_first_shipto_date_sk    int,
-    c_first_sales_date_sk     int,
-    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
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/customer';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists date_dim;
-
-create external table date_dim
-(
-    d_date_sk                 int,
-    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 
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/date_dim';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists household_demographics;
-
-create external table household_demographics
-(
-    hd_demo_sk                int,
-    hd_income_band_sk         int,
-    hd_buy_potential          string,
-    hd_dep_count              int,
-    hd_vehicle_count          int
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/household_demographics';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists income_band;
-
-create external table income_band(
-      ib_income_band_sk         int               
-,     ib_lower_bound            int                       
-,     ib_upper_bound            int
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/income_band';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists inventory;
-
-create external table inventory
-(
-    inv_date_sk			int,
-    inv_item_sk			int,
-    inv_warehouse_sk		int,
-    inv_quantity_on_hand	int
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/inventory';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists item;
-
-create external table item
-(
-    i_item_sk                 int,
-    i_item_id                 string,
-    i_rec_start_date          string,
-    i_rec_end_date            string,
-    i_item_desc               string,
-    i_current_price           float,
-    i_wholesale_cost          float,
-    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
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/item';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists promotion;
-
-create external table promotion
-(
-    p_promo_sk                int,
-    p_promo_id                string,
-    p_start_date_sk           int,
-    p_end_date_sk             int,
-    p_item_sk                 int,
-    p_cost                    float,
-    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 
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/promotion';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists reason;
-
-create external table reason(
-      r_reason_sk               int               
-,     r_reason_id               string              
-,     r_reason_desc             string                
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/reason';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists ship_mode;
-
-create external table ship_mode(
-      sm_ship_mode_sk           int               
-,     sm_ship_mode_id           string              
-,     sm_type                   string                      
-,     sm_code                   string                      
-,     sm_carrier                string                      
-,     sm_contract               string                      
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/ship_model';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store_returns;
-
-create external table store_returns
-(
-    sr_returned_date_sk       int,
-    sr_return_time_sk         int,
-    sr_item_sk                int,
-    sr_customer_sk            int,
-    sr_cdemo_sk               int,
-    sr_hdemo_sk               int,
-    sr_addr_sk                int,
-    sr_store_sk               int,
-    sr_reason_sk              int,
-    sr_ticket_number          int,
-    sr_return_quantity        int,
-    sr_return_amt             float,
-    sr_return_tax             float,
-    sr_return_amt_inc_tax     float,
-    sr_fee                    float,
-    sr_return_ship_cost       float,
-    sr_refunded_cash          float,
-    sr_reversed_charge        float,
-    sr_store_credit           float,
-    sr_net_loss               float             
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/store_returns';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store_sales;
-
-create external table store_sales
-(
-    ss_sold_date_sk           int,
-    ss_sold_time_sk           int,
-    ss_item_sk                int,
-    ss_customer_sk            int,
-    ss_cdemo_sk               int,
-    ss_hdemo_sk               int,
-    ss_addr_sk                int,
-    ss_store_sk               int,
-    ss_promo_sk               int,
-    ss_ticket_number          int,
-    ss_quantity               int,
-    ss_wholesale_cost         float,
-    ss_list_price             float,
-    ss_sales_price            float,
-    ss_ext_discount_amt       float,
-    ss_ext_sales_price        float,
-    ss_ext_wholesale_cost     float,
-    ss_ext_list_price         float,
-    ss_ext_tax                float,
-    ss_coupon_amt             float,
-    ss_net_paid               float,
-    ss_net_paid_inc_tax       float,
-    ss_net_profit             float                  
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/store_sales';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store;
-
-create external table store
-(
-    s_store_sk                int,
-    s_store_id                string,
-    s_rec_start_date          string,
-    s_rec_end_date            string,
-    s_closed_date_sk          int,
-    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              float,
-    s_tax_precentage          float                  
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/store';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists time_dim;
-
-create external table time_dim
-(
-    t_time_sk                 int,
-    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
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/time_dim';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists warehouse;
-
-create external table warehouse(
-      w_warehouse_sk            int               
-,     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              float                  
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/warehouse';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_page;
-
-create external table web_page(
-      wp_web_page_sk            int               
-,     wp_web_page_id            string              
-,     wp_rec_start_date        string                         
-,     wp_rec_end_date          string                         
-,     wp_creation_date_sk       int                       
-,     wp_access_date_sk         int                       
-,     wp_autogen_flag           string                       
-,     wp_customer_sk            int                       
-,     wp_url                    string                  
-,     wp_type                   string                      
-,     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}/web_page';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_returns;
-
-create external table web_returns
-(
-    wr_returned_date_sk       int,
-    wr_returned_time_sk       int,
-    wr_item_sk                int,
-    wr_refunded_customer_sk   int,
-    wr_refunded_cdemo_sk      int,
-    wr_refunded_hdemo_sk      int,
-    wr_refunded_addr_sk       int,
-    wr_returning_customer_sk  int,
-    wr_returning_cdemo_sk     int,
-    wr_returning_hdemo_sk     int,
-    wr_returning_addr_sk      int,
-    wr_web_page_sk            int,
-    wr_reason_sk              int,
-    wr_order_number           int,
-    wr_return_quantity        int,
-    wr_return_amt             float,
-    wr_return_tax             float,
-    wr_return_amt_inc_tax     float,
-    wr_fee                    float,
-    wr_return_ship_cost       float,
-    wr_refunded_cash          float,
-    wr_reversed_charge        float,
-    wr_account_credit         float,
-    wr_net_loss               float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/web_returns';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_sales;
-
-create external table web_sales
-(
-    ws_sold_date_sk           int,
-    ws_sold_time_sk           int,
-    ws_ship_date_sk           int,
-    ws_item_sk                int,
-    ws_bill_customer_sk       int,
-    ws_bill_cdemo_sk          int,
-    ws_bill_hdemo_sk          int,
-    ws_bill_addr_sk           int,
-    ws_ship_customer_sk       int,
-    ws_ship_cdemo_sk          int,
-    ws_ship_hdemo_sk          int,
-    ws_ship_addr_sk           int,
-    ws_web_page_sk            int,
-    ws_web_site_sk            int,
-    ws_ship_mode_sk           int,
-    ws_warehouse_sk           int,
-    ws_promo_sk               int,
-    ws_order_number           int,
-    ws_quantity               int,
-    ws_wholesale_cost         float,
-    ws_list_price             float,
-    ws_sales_price            float,
-    ws_ext_discount_amt       float,
-    ws_ext_sales_price        float,
-    ws_ext_wholesale_cost     float,
-    ws_ext_list_price         float,
-    ws_ext_tax                float,
-    ws_coupon_amt             float,
-    ws_ext_ship_cost          float,
-    ws_net_paid               float,
-    ws_net_paid_inc_tax       float,
-    ws_net_paid_inc_ship      float,
-    ws_net_paid_inc_ship_tax  float,
-    ws_net_profit             float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/web_sales';
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_site;
-
-create external table web_site
-(
-    web_site_sk           int,
-    web_site_id           string,
-    web_rec_start_date    string,
-    web_rec_end_date      string,
-    web_name              string,
-    web_open_date_sk      int,
-    web_close_date_sk     int,
-    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        float,
-    web_tax_percentage    float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}/web_site';

+ 0 - 40
ddl/text/call_center.sql

@@ -1,40 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists call_center;
-
-create external table call_center(
-      cc_call_center_sk         int               
-,     cc_call_center_id         string              
-,     cc_rec_start_date        string                         
-,     cc_rec_end_date          string                         
-,     cc_closed_date_sk         int                       
-,     cc_open_date_sk           int                       
-,     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             float                  
-,     cc_tax_percentage         float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 18
ddl/text/catalog_page.sql

@@ -1,18 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_page;
-
-create external table catalog_page(
-      cp_catalog_page_sk        int               
-,     cp_catalog_page_id        string              
-,     cp_start_date_sk          int                       
-,     cp_end_date_sk            int                       
-,     cp_department             string                   
-,     cp_catalog_number         int                       
-,     cp_catalog_page_number    int                       
-,     cp_description            string                  
-,     cp_type                   string
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 37
ddl/text/catalog_returns.sql

@@ -1,37 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_returns;
-
-create external table catalog_returns
-(
-    cr_returned_date_sk       int,
-    cr_returned_time_sk       int,
-    cr_item_sk                int,
-    cr_refunded_customer_sk   int,
-    cr_refunded_cdemo_sk      int,
-    cr_refunded_hdemo_sk      int,
-    cr_refunded_addr_sk       int,
-    cr_returning_customer_sk  int,
-    cr_returning_cdemo_sk     int,
-    cr_returning_hdemo_sk     int,
-    cr_returning_addr_sk      int,
-    cr_call_center_sk         int,
-    cr_catalog_page_sk        int,
-    cr_ship_mode_sk           int,
-    cr_warehouse_sk           int,
-    cr_reason_sk              int,
-    cr_order_number           int,
-    cr_return_quantity        int,
-    cr_return_amount          float,
-    cr_return_tax             float,
-    cr_return_amt_inc_tax     float,
-    cr_fee                    float,
-    cr_return_ship_cost       float,
-    cr_refunded_cash          float,
-    cr_reversed_charge        float,
-    cr_store_credit           float,
-    cr_net_loss               float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 44
ddl/text/catalog_sales.sql

@@ -1,44 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists catalog_sales;
-
-create external table catalog_sales
-(
-    cs_sold_date_sk           int,
-    cs_sold_time_sk           int,
-    cs_ship_date_sk           int,
-    cs_bill_customer_sk       int,
-    cs_bill_cdemo_sk          int,
-    cs_bill_hdemo_sk          int,
-    cs_bill_addr_sk           int,
-    cs_ship_customer_sk       int,
-    cs_ship_cdemo_sk          int,
-    cs_ship_hdemo_sk          int,
-    cs_ship_addr_sk           int,
-    cs_call_center_sk         int,
-    cs_catalog_page_sk        int,
-    cs_ship_mode_sk           int,
-    cs_warehouse_sk           int,
-    cs_item_sk                int,
-    cs_promo_sk               int,
-    cs_order_number           int,
-    cs_quantity               int,
-    cs_wholesale_cost         float,
-    cs_list_price             float,
-    cs_sales_price            float,
-    cs_ext_discount_amt       float,
-    cs_ext_sales_price        float,
-    cs_ext_wholesale_cost     float,
-    cs_ext_list_price         float,
-    cs_ext_tax                float,
-    cs_coupon_amt             float,
-    cs_ext_ship_cost          float,
-    cs_net_paid               float,
-    cs_net_paid_inc_tax       float,
-    cs_net_paid_inc_ship      float,
-    cs_net_paid_inc_ship_tax  float,
-    cs_net_profit             float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 28
ddl/text/customer.sql

@@ -1,28 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer;
-
-create external table customer
-(
-    c_customer_sk             int,
-    c_customer_id             string,
-    c_current_cdemo_sk        int,
-    c_current_hdemo_sk        int,
-    c_current_addr_sk         int,
-    c_first_shipto_date_sk    int,
-    c_first_sales_date_sk     int,
-    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
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 23
ddl/text/customer_address.sql

@@ -1,23 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer_address;
-
-create external table customer_address
-(
-    ca_address_sk             int,
-    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             float,
-    ca_location_type          string
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 19
ddl/text/customer_demographics.sql

@@ -1,19 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists customer_demographics;
-
-create external table customer_demographics
-(
-    cd_demo_sk                int,
-    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 
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 38
ddl/text/date_dim.sql

@@ -1,38 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists date_dim;
-
-create external table date_dim
-(
-    d_date_sk                 int,
-    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 
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 15
ddl/text/household_demographics.sql

@@ -1,15 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists household_demographics;
-
-create external table household_demographics
-(
-    hd_demo_sk                int,
-    hd_income_band_sk         int,
-    hd_buy_potential          string,
-    hd_dep_count              int,
-    hd_vehicle_count          int
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 12
ddl/text/income_band.sql

@@ -1,12 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists income_band;
-
-create external table income_band(
-      ib_income_band_sk         int               
-,     ib_lower_bound            int                       
-,     ib_upper_bound            int
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 14
ddl/text/inventory.sql

@@ -1,14 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists inventory;
-
-create external table inventory
-(
-    inv_date_sk			int,
-    inv_item_sk			int,
-    inv_warehouse_sk		int,
-    inv_quantity_on_hand	int
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 32
ddl/text/item.sql

@@ -1,32 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists item;
-
-create external table item
-(
-    i_item_sk                 int,
-    i_item_id                 string,
-    i_rec_start_date          string,
-    i_rec_end_date            string,
-    i_item_desc               string,
-    i_current_price           float,
-    i_wholesale_cost          float,
-    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
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 29
ddl/text/promotion.sql

@@ -1,29 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists promotion;
-
-create external table promotion
-(
-    p_promo_sk                int,
-    p_promo_id                string,
-    p_start_date_sk           int,
-    p_end_date_sk             int,
-    p_item_sk                 int,
-    p_cost                    float,
-    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 
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 12
ddl/text/reason.sql

@@ -1,12 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists reason;
-
-create external table reason(
-      r_reason_sk               int               
-,     r_reason_id               string              
-,     r_reason_desc             string                
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 15
ddl/text/ship_mode.sql

@@ -1,15 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists ship_mode;
-
-create external table ship_mode(
-      sm_ship_mode_sk           int               
-,     sm_ship_mode_id           string              
-,     sm_type                   string                      
-,     sm_code                   string                      
-,     sm_carrier                string                      
-,     sm_contract               string                      
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 39
ddl/text/store.sql

@@ -1,39 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store;
-
-create external table store
-(
-    s_store_sk                int,
-    s_store_id                string,
-    s_rec_start_date          string,
-    s_rec_end_date            string,
-    s_closed_date_sk          int,
-    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              float,
-    s_tax_precentage          float                  
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 30
ddl/text/store_returns.sql

@@ -1,30 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store_returns;
-
-create external table store_returns
-(
-    sr_returned_date_sk       int,
-    sr_return_time_sk         int,
-    sr_item_sk                int,
-    sr_customer_sk            int,
-    sr_cdemo_sk               int,
-    sr_hdemo_sk               int,
-    sr_addr_sk                int,
-    sr_store_sk               int,
-    sr_reason_sk              int,
-    sr_ticket_number          int,
-    sr_return_quantity        int,
-    sr_return_amt             float,
-    sr_return_tax             float,
-    sr_return_amt_inc_tax     float,
-    sr_fee                    float,
-    sr_return_ship_cost       float,
-    sr_refunded_cash          float,
-    sr_reversed_charge        float,
-    sr_store_credit           float,
-    sr_net_loss               float             
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 33
ddl/text/store_sales.sql

@@ -1,33 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists store_sales;
-
-create external table store_sales
-(
-    ss_sold_date_sk           int,
-    ss_sold_time_sk           int,
-    ss_item_sk                int,
-    ss_customer_sk            int,
-    ss_cdemo_sk               int,
-    ss_hdemo_sk               int,
-    ss_addr_sk                int,
-    ss_store_sk               int,
-    ss_promo_sk               int,
-    ss_ticket_number          int,
-    ss_quantity               int,
-    ss_wholesale_cost         float,
-    ss_list_price             float,
-    ss_sales_price            float,
-    ss_ext_discount_amt       float,
-    ss_ext_sales_price        float,
-    ss_ext_wholesale_cost     float,
-    ss_ext_list_price         float,
-    ss_ext_tax                float,
-    ss_coupon_amt             float,
-    ss_net_paid               float,
-    ss_net_paid_inc_tax       float,
-    ss_net_profit             float                  
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 20
ddl/text/time_dim.sql

@@ -1,20 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists time_dim;
-
-create external table time_dim
-(
-    t_time_sk                 int,
-    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
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 23
ddl/text/warehouse.sql

@@ -1,23 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists warehouse;
-
-create external table warehouse(
-      w_warehouse_sk            int               
-,     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              float                  
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 23
ddl/text/web_page.sql

@@ -1,23 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_page;
-
-create external table web_page(
-      wp_web_page_sk            int               
-,     wp_web_page_id            string              
-,     wp_rec_start_date        string                         
-,     wp_rec_end_date          string                         
-,     wp_creation_date_sk       int                       
-,     wp_access_date_sk         int                       
-,     wp_autogen_flag           string                       
-,     wp_customer_sk            int                       
-,     wp_url                    string                  
-,     wp_type                   string                      
-,     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}';

+ 0 - 34
ddl/text/web_returns.sql

@@ -1,34 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_returns;
-
-create external table web_returns
-(
-    wr_returned_date_sk       int,
-    wr_returned_time_sk       int,
-    wr_item_sk                int,
-    wr_refunded_customer_sk   int,
-    wr_refunded_cdemo_sk      int,
-    wr_refunded_hdemo_sk      int,
-    wr_refunded_addr_sk       int,
-    wr_returning_customer_sk  int,
-    wr_returning_cdemo_sk     int,
-    wr_returning_hdemo_sk     int,
-    wr_returning_addr_sk      int,
-    wr_web_page_sk            int,
-    wr_reason_sk              int,
-    wr_order_number           int,
-    wr_return_quantity        int,
-    wr_return_amt             float,
-    wr_return_tax             float,
-    wr_return_amt_inc_tax     float,
-    wr_fee                    float,
-    wr_return_ship_cost       float,
-    wr_refunded_cash          float,
-    wr_reversed_charge        float,
-    wr_account_credit         float,
-    wr_net_loss               float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 44
ddl/text/web_sales.sql

@@ -1,44 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_sales;
-
-create external table web_sales
-(
-    ws_sold_date_sk           int,
-    ws_sold_time_sk           int,
-    ws_ship_date_sk           int,
-    ws_item_sk                int,
-    ws_bill_customer_sk       int,
-    ws_bill_cdemo_sk          int,
-    ws_bill_hdemo_sk          int,
-    ws_bill_addr_sk           int,
-    ws_ship_customer_sk       int,
-    ws_ship_cdemo_sk          int,
-    ws_ship_hdemo_sk          int,
-    ws_ship_addr_sk           int,
-    ws_web_page_sk            int,
-    ws_web_site_sk            int,
-    ws_ship_mode_sk           int,
-    ws_warehouse_sk           int,
-    ws_promo_sk               int,
-    ws_order_number           int,
-    ws_quantity               int,
-    ws_wholesale_cost         float,
-    ws_list_price             float,
-    ws_sales_price            float,
-    ws_ext_discount_amt       float,
-    ws_ext_sales_price        float,
-    ws_ext_wholesale_cost     float,
-    ws_ext_list_price         float,
-    ws_ext_tax                float,
-    ws_coupon_amt             float,
-    ws_ext_ship_cost          float,
-    ws_net_paid               float,
-    ws_net_paid_inc_tax       float,
-    ws_net_paid_inc_ship      float,
-    ws_net_paid_inc_ship_tax  float,
-    ws_net_profit             float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';

+ 0 - 36
ddl/text/web_site.sql

@@ -1,36 +0,0 @@
-create database if not exists ${DB};
-use ${DB};
-
-drop table if exists web_site;
-
-create external table web_site
-(
-    web_site_sk           int,
-    web_site_id           string,
-    web_rec_start_date    string,
-    web_rec_end_date      string,
-    web_name              string,
-    web_open_date_sk      int,
-    web_close_date_sk     int,
-    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        float,
-    web_tax_percentage    float
-)
-row format delimited fields terminated by '|' 
-location '${LOCATION}';