建表与导入TPC-DS数据

DROP FOREIGN TABLE IF EXISTS customer_address_ext;
CREATE FOREIGN TABLE customer_address_ext
(
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/customer_address.dat* | gsfs://192.168.0.90:5003/customer_address.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)WITH  customer_address_err;
DROP FOREIGN TABLE IF EXISTS customer_demographics_ext;
CREATE FOREIGN TABLE customer_demographics_ext
(
cd_demo_sk                bigint                        ,
cd_gender                 char(1)                       ,
cd_marital_status         char(1)                       ,
cd_education_status       char(20)                      ,
cd_purchase_estimate      bigint                        ,
cd_credit_rating          char(10)                      ,
cd_dep_count              bigint                        ,
cd_dep_employed_count     bigint                        ,
cd_dep_college_count      bigint
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/customer_demographics.dat* | gsfs://192.168.0.90:5003/customer_demographics.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  customer_demographics_err
;
DROP FOREIGN TABLE IF EXISTS date_dim_ext;
CREATE FOREIGN TABLE date_dim_ext
(
d_date_sk                 bigint                       ,
d_date_id                 char(16)                     ,
d_date                    date                         ,
d_month_seq               bigint                       ,
d_week_seq                bigint                       ,
d_quarter_seq             bigint                       ,
d_year                    bigint                       ,
d_dow                     bigint                       ,
d_moy                     bigint                       ,
d_dom                     bigint                       ,
d_qoy                     bigint                       ,
d_fy_year                 bigint                       ,
d_fy_quarter_seq          bigint                       ,
d_fy_week_seq             bigint                       ,
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               bigint                       ,
d_last_dom                bigint                       ,
d_same_day_ly             bigint                       ,
d_same_day_lq             bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/date_dim.dat* | gsfs://192.168.0.90:5003/date_dim.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  date_dim_err
;
DROP FOREIGN TABLE IF EXISTS warehouse_ext;
CREATE FOREIGN TABLE warehouse_ext
(
w_warehouse_sk            bigint                        ,
w_warehouse_id            char(16)                      ,
w_warehouse_name          varchar(20)                   ,
w_warehouse_sq_ft         bigint                        ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/warehouse.dat* | gsfs://192.168.0.90:5003/warehouse.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  warehouse_err
;
DROP FOREIGN TABLE IF EXISTS ship_mode_ext;
CREATE FOREIGN TABLE ship_mode_ext
(
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/ship_mode.dat* | gsfs://192.168.0.90:5003/ship_mode.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  ship_mode_err
;
DROP FOREIGN TABLE IF EXISTS time_dim_ext;
CREATE FOREIGN TABLE time_dim_ext
(
t_time_sk                 bigint                       ,
t_time_id                 char(16)                     ,
t_time                    bigint                       ,
t_hour                    bigint                       ,
t_minute                  bigint                       ,
t_second                  bigint                       ,
t_am_pm                   char(2)                      ,
t_shift                   char(20)                     ,
t_sub_shift               char(20)                     ,
t_meal_time               char(20)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/time_dim.dat* | gsfs://192.168.0.90:5003/time_dim.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  time_dim_err
;
DROP FOREIGN TABLE IF EXISTS reason_ext;
CREATE FOREIGN TABLE reason_ext
(
r_reason_sk               bigint                ,
r_reason_id               char(16)              ,
r_reason_desc             char(100)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/reason.dat* | gsfs://192.168.0.90:5003/reason.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH reason_err
;
DROP FOREIGN TABLE IF EXISTS income_band_ext;
CREATE FOREIGN TABLE income_band_ext
(
ib_income_band_sk         bigint               ,
ib_lower_bound            bigint               ,
ib_upper_bound            bigint
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/income_band.dat* | gsfs://192.168.0.90:5003/income_band.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  income_band_err
;
DROP FOREIGN TABLE IF EXISTS item_ext;
CREATE FOREIGN TABLE item_ext
(
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                bigint                        ,
i_brand                   char(50)                      ,
i_class_id                bigint                        ,
i_class                   char(50)                      ,
i_category_id             bigint                        ,
i_category                char(50)                      ,
i_manufact_id             bigint                        ,
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              bigint                        ,
i_product_name            char(50)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/item.dat* | gsfs://192.168.0.90:5003/item.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  item_err
;
DROP FOREIGN TABLE IF EXISTS store_ext;
CREATE FOREIGN TABLE store_ext
(
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        bigint                       ,
s_floor_space             bigint                       ,
s_hours                   char(20)                      ,
s_manager                 varchar(40)                   ,
s_market_id               bigint                       ,
s_geography_class         varchar(100)                  ,
s_market_desc             varchar(100)                  ,
s_market_manager          varchar(40)                   ,
s_division_id             bigint                       ,
s_division_name           varchar(50)                   ,
s_company_id              bigint                       ,
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_precentage          decimal(5,2)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/store_[^rs]_* | gsfs://192.168.0.90:5003/store_[^rs]_*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH store_err
;
DROP FOREIGN TABLE IF EXISTS call_center_ext;
CREATE FOREIGN TABLE call_center_ext
(
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              bigint                       ,
cc_sq_ft                  bigint                       ,
cc_hours                  char(20)                      ,
cc_manager                varchar(40)                   ,
cc_mkt_id                 bigint                       ,
cc_mkt_class              char(50)                      ,
cc_mkt_desc               varchar(100)                  ,
cc_market_manager         varchar(40)                   ,
cc_division               bigint                       ,
cc_division_name          varchar(50)                   ,
cc_company                bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/call_center.dat* | gsfs://192.168.0.90:5003/call_center.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH call_center_err
;
DROP FOREIGN TABLE IF EXISTS customer_ext;
CREATE FOREIGN TABLE customer_ext
(
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               bigint                       ,
c_birth_month             bigint                       ,
c_birth_year              bigint                       ,
c_birth_country           varchar(20)                   ,
c_login                   char(13)                      ,
c_email_address           char(50)                      ,
c_last_review_date_sk        char(10)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/customer_[^ad]_* | gsfs://192.168.0.90:5003/customer_[^ad]_*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'GBK',
mode 'Normal'
)
WITH  customer_err
;
DROP FOREIGN TABLE IF EXISTS web_site_ext;
CREATE FOREIGN TABLE web_site_ext
(
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                bigint                       ,
web_mkt_class             varchar(50)                   ,
web_mkt_desc              varchar(100)                  ,
web_market_manager        varchar(40)                   ,
web_company_id            bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/web_site.dat* | gsfs://192.168.0.90:5003/web_site.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  web_site_err
;
DROP FOREIGN TABLE IF EXISTS store_returns_ext;
CREATE FOREIGN TABLE store_returns_ext
(
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        bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/store_returns.dat* | gsfs://192.168.0.90:5003/store_returns.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH store_returns_err
;
DROP FOREIGN TABLE IF EXISTS household_demographics_ext;
CREATE FOREIGN TABLE household_demographics_ext
(
hd_demo_sk                bigint               ,
hd_income_band_sk         bigint                       ,
hd_buy_potential          char(15)                      ,
hd_dep_count              bigint                       ,
hd_vehicle_count          bigint
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/household_demographics.dat* | gsfs://192.168.0.90:5003/household_demographics.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  household_demographics_err
;
DROP FOREIGN TABLE IF EXISTS web_page_ext;
CREATE FOREIGN TABLE web_page_ext
(
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             bigint                       ,
wp_link_count             bigint                       ,
wp_image_count            bigint                       ,
wp_max_ad_count           bigint
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/web_page.dat* | gsfs://192.168.0.90:5003/web_page.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH web_page_err
;
DROP FOREIGN TABLE IF EXISTS promotion_ext;
CREATE FOREIGN TABLE promotion_ext
(
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         bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/promotion.dat* | gsfs://192.168.0.90:5003/promotion.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH promotion_err
;
DROP FOREIGN TABLE IF EXISTS catalog_page_ext;
CREATE FOREIGN TABLE catalog_page_ext
(
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         bigint                       ,
cp_catalog_page_number    bigint                       ,
cp_description            varchar(100)                  ,
cp_type                   varchar(100)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/catalog_page.dat* | gsfs://192.168.0.90:5003/catalog_page.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH  catalog_page_err
;
DROP FOREIGN TABLE IF EXISTS inventory_ext;
CREATE FOREIGN TABLE inventory_ext
(
inv_date_sk               bigint               ,
inv_item_sk               bigint               ,
inv_warehouse_sk          bigint               ,
inv_quantity_on_hand      integer
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/inventory.dat* | gsfs://192.168.0.90:5003/inventory.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH inventory_err
;
DROP FOREIGN TABLE IF EXISTS catalog_returns_ext;
CREATE FOREIGN TABLE catalog_returns_ext
(
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        bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/catalog_returns.dat* | gsfs://192.168.0.90:5003/catalog_returns.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH catalog_returns_err
;
DROP FOREIGN TABLE IF EXISTS web_returns_ext;
CREATE FOREIGN TABLE web_returns_ext
(
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        bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/web_returns.dat* | gsfs://192.168.0.90:5003/web_returns.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
)
WITH web_returns_err
;
DROP FOREIGN TABLE IF EXISTS web_sales_ext;
CREATE FOREIGN TABLE web_sales_ext
(
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               bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/web_sales.dat* | gsfs://192.168.0.90:5003/web_sales.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
) WITH web_sales_err ;
DROP FOREIGN TABLE IF EXISTS catalog_sales_ext;
CREATE FOREIGN TABLE catalog_sales_ext
(
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               bigint                       ,
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)
)
SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/catalog_sales.dat* | gsfs://192.168.0.90:5003/catalog_sales.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
) WITH  catalog_sales_err ;
DROP FOREIGN TABLE IF EXISTS store_sales_ext;
CREATE FOREIGN TABLE store_sales_ext
(
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               bigint                       ,
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)
) SERVER gsmpp_server
OPTIONS(location 'gsfs://192.168.0.90:5002/store_sales.dat* | gsfs://192.168.0.90:5003/store_sales.dat*',
FORMAT 'TEXT' ,
DELIMITER '|',
encoding 'utf8',
mode 'Normal'
) WITH store_sales_err;