Выполните следующий запрос:

COPY dbgen_version
TO '/home/test/tpcds_tables100/dbgen_version.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY customer_address
TO '/home/test/tpcds_tables100/customer_address.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY customer_demographics
TO '/home/test/tpcds_tables100/customer_demographics.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY date_dim
TO '/home/test/tpcds_tables100/date_dim.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY warehouse
TO '/home/test/tpcds_tables100/warehouse.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY ship_mode
TO '/home/test/tpcds_tables100/ship_mode.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY time_dim
TO '/home/test/tpcds_tables100/time_dim.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY reason
TO '/home/test/tpcds_tables100/reason.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY income_band
TO '/home/test/tpcds_tables100/income_band.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY item
TO '/home/test/tpcds_tables100/item.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY store
TO '/home/test/tpcds_tables100/store.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY call_center
TO '/home/test/tpcds_tables100/call_center.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY customer
TO '/home/test/tpcds_tables100/customer.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY web_site
TO '/home/test/tpcds_tables100/web_site.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY store_returns
TO '/home/test/tpcds_tables100/store_returns.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY household_demographics
TO '/home/test/tpcds_tables100/household_demographics.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY web_page
TO '/home/test/tpcds_tables100/web_page.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY promotion
TO '/home/test/tpcds_tables100/promotion.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY catalog_page
TO '/home/test/tpcds_tables100/catalog_page.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY inventory
TO '/home/test/tpcds_tables100/inventory.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY catalog_returns
TO '/home/test/tpcds_tables100/catalog_returns.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY web_returns
TO '/home/test/tpcds_tables100/web_returns.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY web_sales
TO '/home/test/tpcds_tables100/web_sales.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY catalog_sales
TO '/home/test/tpcds_tables100/catalog_sales.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');

COPY store_sales
TO '/home/test/tpcds_tables100/store_sales.parquet'
(FORMAT 'parquet', COMPRESSION 'zstd');


CREATE VIEW dbgen_version_parquet AS SELECT
  r['dv_version']::text AS dv_version,
  r['dv_create_date']::date AS dv_create_date,
  r['dv_create_time']::time AS dv_create_time,
  r['dv_cmdline_args']::text AS dv_cmdline_args FROM
read_parquet('/home/test/tpcds_tables100/dbgen_version.parquet', binary_as_string => true) r;

CREATE VIEW customer_address_parquet AS SElECT
  r['ca_address_sk']::integer AS ca_address_sk,
  r['ca_address_id']::text AS ca_address_id,
  r['ca_street_number']::text AS ca_street_number,
  r['ca_street_name']::text AS ca_street_name,
  r['ca_street_type']::text AS ca_street_type,
  r['ca_suite_number']::text AS ca_suite_number,
  r['ca_city']::text AS ca_city,
  r['ca_county']::text AS ca_county,
  r['ca_state']::text AS ca_state,
  r['ca_zip']::text AS ca_zip,
  r['ca_country']::text AS ca_country,
  r['ca_gmt_offset']::decimal(5,2) AS ca_gmt_offset,
  r['ca_location_type']::text AS ca_location_type FROM
read_parquet('/home/test/tpcds_tables100/customer_address.parquet', binary_as_string => true) r;

CREATE VIEW customer_demographics_parquet AS SELECT
  r['cd_demo_sk']::integer AS cd_demo_skz
  r['cd_gender']::text AS cd_gender,
  r['cd_marital_status']::text AS cd_marital_status,
  r['cd_education_status']::text AS cd_education_status,
  r['cd_purchase_estimate']::integer AS cd_purchase_estimate,
  r['cd_credit_rating']::text AS cd_credit_rating,
  r['cd_dep_count']::integer AS cd_dep_count,
  r['cd_dep_employed_count']::integer AS cd_dep_employed_count,
  r['cd_dep_college_count']::integer AS cd_dep_college_count FROM
read_parquet('/home/test/tpcds_tables100/customer_demographics.parquet', binary_as_string => true) r;

CREATE VIEW date_dim_parquet AS SELECT
  r['d_date_sk']::integer AS d_date_sk,
  r['d_date_id']::text AS d_date_id,
  r['d_date']::date AS d_date,
  r['d_month_seq']::integer AS d_month_seq,
  r['d_week_seq']::integer AS d_week_seq,
  r['d_quarter_seq']::integer AS d_quarter_seq,
  r['d_year']::integer AS d_year,
  r['d_dow']::integer AS d_dow,
  r['d_moy']::integer AS d_moy,
  r['d_dom']::integer AS d_dom,
  r['d_qoy']::integer AS d_qoy,
  r['d_fy_year']::integer AS d_fy_year,
  r['d_fy_quarter_seq']::integer AS d_fy_quarter_seq,
  r['d_fy_week_seq']::integer AS d_fy_week_seq,
  r['d_day_name']::text AS d_day_name,
  r['d_quarter_name']::text AS d_quarter_name,
  r['d_holiday']::text AS d_holiday,
  r['d_weekend']::text AS d_weekend,
  r['d_following_holiday']::text AS d_following_holiday,
  r['d_first_dom']::integer AS d_first_dom,
  r['d_last_dom']::integer AS d_last_dom,
  r['d_same_day_ly']::integer AS d_same_day_ly,
  r['d_same_day_lq']::integer AS d_same_day_lq,
  r['d_current_day']::text AS d_current_day,
  r['d_current_week']::text AS d_current_week,
  r['d_current_month']::text AS d_current_month,
  r['d_current_quarter']::text AS d_current_quarter,
  r['d_current_year']::text AS d_current_year FROM
read_parquet('/home/test/tpcds_tables100/date_dim.parquet', binary_as_string => true) r;

CREATE VIEW warehouse_parquet AS SELECT
  r['w_warehouse_sk']::integer AS w_warehouse_sk,
  r['w_warehouse_id']::text AS w_warehouse_id,
  r['w_warehouse_name']::text AS w_warehouse_name,
  r['w_warehouse_sq_ft']::integer AS w_warehouse_sq_ft,
  r['w_street_number']::text AS w_street_number,
  r['w_street_name']::text AS w_street_name,
  r['w_street_type']::text AS w_street_type,
  r['w_suite_number']::text AS w_suite_number,
  r['w_city']::text AS w_city,
  r['w_county']::text AS w_county,
  r['w_state']::text AS w_state,
  r['w_zip']::text AS w_zip,
  r['w_country']::text AS w_country,
  r['w_gmt_offset']::decimal(5,2) AS w_gmt_offset FROM
read_parquet('/home/test/tpcds_tables100/warehouse.parquet', binary_as_string => true) r;

CREATE VIEW ship_mode_parquet AS SELECT
  r['sm_ship_mode_sk']::integer AS sm_ship_mode_sk,
  r['sm_ship_mode_id']::text AS sm_ship_mode_id,
  r['sm_type']::text AS sm_type,
  r['sm_code']::text AS sm_code,
  r['sm_carrier']::text AS sm_carrier,
  r['sm_contract']::text AS sm_contract FROM
read_parquet('/home/test/tpcds_tables100/ship_mode.parquet', binary_as_string => true) r;

CREATE VIEW time_dim_parquet AS SELECT
  r['t_time_sk']::integer AS t_time_sk,
  r['t_time_id']::text AS t_time_id,
  r['t_time']::integer AS t_time,
  r['t_hour']::integer AS t_hour,
  r['t_minute']::integer AS t_minute,
  r['t_second']::integer AS t_second,
  r['t_am_pm']::text AS t_am_pm,
  r['t_shift']::text AS t_shift,
  r['t_sub_shift']::text AS t_sub_shift,
  r['t_meal_time']::text AS t_meal_time FROM
read_parquet('/home/test/tpcds_tables100/time_dim.parquet', binary_as_string => true) r;

CREATE VIEW reason_parquet AS SELECT
  r['r_reason_sk']::integer AS r_reason_sk,
  r['r_reason_id']::text AS r_reason_id,
  r['r_reason_desc']::text AS r_reason_desc FROM
read_parquet('/home/test/tpcds_tables100/reason.parquet', binary_as_string => true) r;

CREATE VIEW income_band_parquet AS SELECT
  r['ib_income_band_sk']::integer AS ib_income_band_sk,
  r['ib_lower_bound']::integer AS ib_lower_bound,
  r['ib_upper_bound']::integer AS ib_upper_bound FROM
read_parquet('/home/test/tpcds_tables100/income_band.parquet', binary_as_string => true) r;

CREATE VIEW item_parquet AS SELECT
  r['i_item_sk']::integer AS i_item_sk,
  r['i_item_id']::text AS i_item_id,
  r['i_rec_start_date']::date AS i_rec_start_date,
  r['i_rec_end_date']::date AS i_rec_end_date,
  r['i_item_desc']::text AS i_item_desc,
  r['i_current_price']::decimal(7,2) AS i_current_price,
  r['i_wholesale_cost']::decimal(7,2) AS i_wholesale_cost,
  r['i_brand_id']::integer AS i_brand_id,
  r['i_brand']::text AS i_brand,
  r['i_class_id']::integer AS i_class_id,
  r['i_class']::text AS i_class,
  r['i_category_id']::integer AS i_category_id,
  r['i_category']::text AS i_category,
  r['i_manufact_id']::integer AS i_manufact_id,
  r['i_manufact']::text AS i_manufact,
  r['i_size']::text AS i_size,
  r['i_formulation']::text AS i_formulation,
  r['i_color']::text AS i_color,
  r['i_units']::text AS i_units,
  r['i_container']::text AS i_container,
  r['i_manager_id']::integer AS i_manager_id,
  r['i_product_name']::text AS i_product_name FROM
read_parquet('/home/test/tpcds_tables100/item.parquet', binary_as_string => true) r;

create view store_parquet AS SELECT
  r['s_store_sk']::integer AS s_store_sk,
  r['s_store_id']::text AS s_store_id,
  r['s_rec_start_date']::date AS s_rec_start_date,
  r['s_rec_end_date']::date AS s_rec_end_date,
  r['s_closed_date_sk']::integer AS s_closed_date_sk,
  r['s_store_name']::text AS s_store_name,
  r['s_number_employees']::integer AS s_number_employees,
  r['s_floor_space']::integer AS s_floor_space,
  r['s_hours']::text AS s_hours,
  r['s_manager']::text AS s_manager,
  r['s_market_id']::integer AS s_market_id,
  r['s_geography_class']::text AS s_geography_class,
  r['s_market_desc']::text AS s_market_desc,
  r['s_market_manager']::text AS s_market_manager,
  r['s_division_id']::integer AS s_division_id,
  r['s_division_name']::text AS s_division_name,
  r['s_company_id']::integer AS s_company_id,
  r['s_company_name']::text AS s_company_name,
  r['s_street_number']::text AS s_street_number,
  r['s_street_name']::text AS s_street_name,
  r['s_street_type']::text AS s_street_type,
  r['s_suite_number']::text AS s_suite_number,
  r['s_city']::text AS s_city,
  r['s_county']::text AS s_county,
  r['s_state']::text AS s_state,
  r['s_zip']::text AS s_zip,
  r['s_country']::text AS s_country,
  r['s_gmt_offset']::decimal(5,2) AS s_gmt_offset,
  r['s_tax_precentage']::decimal(5,2) AS s_tax_precentage FROM
read_parquet('/home/test/tpcds_tables100/store.parquet', binary_as_string => true) r;

CREATE VIEW call_center_parquet AS SELECT
  r['cc_call_center_sk']::integer AS cc_call_center_sk,
  r['cc_call_center_id']::text AS cc_call_center_id,
  r['cc_rec_start_date']::date AS cc_rec_start_date,
  r['cc_rec_end_date']::date AS cc_rec_end_date,
  r['cc_closed_date_sk']::integer AS cc_closed_date_sk,
  r['cc_open_date_sk']::integer AS cc_open_date_sk,
  r['cc_name']::text AS cc_name,
  r['cc_class']::text AS cc_class,
  r['cc_employees']::integer AS cc_employees,
  r['cc_sq_ft']::integer AS cc_sq_ft,
  r['cc_hours']::text AS cc_hours,
  r['cc_manager']::text AS cc_manager,
  r['cc_mkt_id']::integer AS cc_mkt_id,
  r['cc_mkt_class']::text AS cc_mkt_class,
  r['cc_mkt_desc']::text AS cc_mkt_desc,
  r['cc_market_manager']::text AS cc_market_manager,
  r['cc_division']::integer AS cc_division,
  r['cc_division_name']::text AS cc_division_name,
  r['cc_company']::integer AS cc_company,
  r['cc_company_name']::text AS cc_company_name,
  r['cc_street_number']::text AS cc_street_number,
  r['cc_street_name']::text AS cc_street_name,
  r['cc_street_type']::text AS cc_street_type,
  r['cc_suite_number']::text AS cc_suite_number,
  r['cc_city']::text AS cc_city,
  r['cc_county']::text AS cc_county,
  r['cc_state']::text AS cc_state,
  r['cc_zip']::text AS cc_zip,
  r['cc_country']::text AS cc_country,
  r['cc_gmt_offset']::decimal(5,2) AS cc_gmt_offset,
  r['cc_tax_percentage']::decimal(5,2) AS cc_tax_percentage FROM
read_parquet('/home/test/tpcds_tables100/call_center.parquet', binary_as_string => true) r;

CREATE VIEW customer_parquet AS SELECT
  r['c_customer_sk']::integer AS c_customer_sk,
  r['c_customer_id']::text AS c_customer_id,
  r['c_current_cdemo_sk']::integer AS c_current_cdemo_sk,
  r['c_current_hdemo_sk']::integer AS c_current_hdemo_sk,
  r['c_current_addr_sk']::integer AS c_current_addr_sk,
  r['c_first_shipto_date_sk']::integer AS c_first_shipto_date_sk,
  r['c_first_sales_date_sk']::integer AS c_first_sales_date_sk,
  r['c_salutation']::text AS c_salutation,
  r['c_first_name']::text AS c_first_name,
  r['c_last_name']::text AS c_last_name,
  r['c_preferred_cust_flag']::text AS c_preferred_cust_flag,
  r['c_birth_day']::integer AS c_birth_day,
  r['c_birth_month']::integer AS c_birth_month,
  r['c_birth_year']::integer AS c_birth_year,
  r['c_birth_country']::text AS c_birth_country,
  r['c_login']::text AS c_login,
  r['c_email_address']::text AS c_email_address,
  r['c_last_review_date_sk']::integer AS c_last_review_date_sk FROM
read_parquet('/home/test/tpcds_tables100/customer.parquet', binary_as_string => true) r;

CREATE VIEW web_site_parquet AS SELECT
  r['web_site_sk']::integer AS web_site_sk,
  r['web_site_id']::text AS web_site_id,
  r['web_rec_start_date']::date AS web_rec_start_date,
  r['web_rec_end_date']::date AS web_rec_end_date,
  r['web_name']::text AS web_name,
  r['web_open_date_sk']::integer AS web_open_date_sk,
  r['web_close_date_sk']::integer AS web_close_date_sk,
  r['web_class']::text AS web_class,
  r['web_manager']::text AS web_manager,
  r['web_mkt_id']::integer AS web_mkt_id,
  r['web_mkt_class']::text AS web_mkt_class,
  r['web_mkt_desc']::text AS web_mkt_desc,
  r['web_market_manager']::text AS web_market_manager,
  r['web_company_id']::integer AS web_company_id,
  r['web_company_name']::text AS web_company_name,
  r['web_street_number']::text AS web_street_number,
  r['web_street_name']::text AS web_street_name,
  r['web_street_type']::text AS web_street_type,
  r['web_suite_number']::text AS web_suite_number,
  r['web_city']::text AS web_city,
  r['web_county']::text AS web_county,
  r['web_state']::text AS web_state,
  r['web_zip']::text AS web_zip,
  r['web_country']::text AS web_country,
  r['web_gmt_offset']::decimal(5,2) AS web_gmt_offset,
  r['web_tax_percentage']::decimal(5,2) AS web_tax_percentage FROM
read_parquet('/home/test/tpcds_tables100/web_site.parquet', binary_as_string => true) r;

CREATE VIEW store_returns_parquet AS SELECT
  r['sr_returned_date_sk']::integer AS sr_returned_date_sk,
  r['sr_return_time_sk']::integer AS sr_return_time_sk,
  r['sr_item_sk']::integer AS sr_item_sk,
  r['sr_customer_sk']::integer AS sr_customer_sk,
  r['sr_cdemo_sk']::integer AS sr_cdemo_sk,
  r['sr_hdemo_sk']::integer AS sr_hdemo_sk,
  r['sr_addr_sk']::integer AS sr_addr_sk,
  r['sr_store_sk']::integer AS sr_store_sk,
  r['sr_reason_sk']::integer AS sr_reason_sk,
  r['sr_ticket_number']::integer AS sr_ticket_number,
  r['sr_return_quantity']::integer AS sr_return_quantity,
  r['sr_return_amt']::decimal(7,2) AS sr_return_amt,
  r['sr_return_tax']::decimal(7,2) AS sr_return_tax,
  r['sr_return_amt_inc_tax']::decimal(7,2) AS sr_return_amt_inc_tax,
  r['sr_fee']::decimal(7,2) AS sr_fee,
  r['sr_return_ship_cost']::decimal(7,2) AS sr_return_ship_cost,
  r['sr_refunded_cash']::decimal(7,2) AS sr_refunded_cash,
  r['sr_reversed_charge']::decimal(7,2) AS sr_reversed_charge,
  r['sr_store_credit']::decimal(7,2) AS sr_store_credit,
  r['sr_net_loss']::decimal(7,2) AS sr_net_loss FROM
read_parquet('/home/test/tpcds_tables100/store_returns.parquet', binary_as_string => true) r;

CREATE VIEW household_demographics_parquet AS SELECT
  r['hd_demo_sk']::integer AS hd_demo_sk,
  r['hd_income_band_sk']::integer AS hd_income_band_sk,
  r['hd_buy_potential']::text AS hd_buy_potential,
  r['hd_dep_count']::integer AS hd_dep_count,
  r['hd_vehicle_count']::integer AS hd_vehicle_count FROM
read_parquet('/home/test/tpcds_tables100/household_demographics.parquet', binary_as_string => true) r;

CREATE VIEW web_page_parquet AS SELECT
  r['wp_web_page_sk']::integer AS wp_web_page_sk,
  r['wp_web_page_id']::text AS wp_web_page_id,
  r['wp_rec_start_date']::date AS wp_rec_start_date,
  r['wp_rec_end_date']::date AS wp_rec_end_date,
  r['wp_creation_date_sk']::integer AS wp_creation_date_sk,
  r['wp_access_date_sk']::integer AS wp_access_date_sk,
  r['wp_autogen_flag']::text AS wp_autogen_flag,
  r['wp_customer_sk']::integer AS wp_customer_sk,
  r['wp_url']::text AS wp_url,
  r['wp_type']::text AS wp_type,
  r['wp_char_count']::integer AS wp_char_count,
  r['wp_link_count']::integer AS wp_link_count,
  r['wp_image_count']::integer AS wp_image_count,
  r['wp_max_ad_count']::integer AS wp_max_ad_count FROM
read_parquet('/home/test/tpcds_tables100/web_page.parquet', binary_as_string => true) r;

CREATE VIEW promotion_parquet AS SELECT
  r['p_promo_sk']::integer AS p_promo_sk,
  r['p_promo_id']::text AS p_promo_id,
  r['p_start_date_sk']::integer AS p_start_date_sk,
  r['p_end_date_sk']::integer AS p_end_date_sk,
  r['p_item_sk']::integer AS p_item_sk,
  r['p_cost']::decimal(15,2) AS p_cost,
  r['p_response_target']::integer as p_response_target,
  r['p_promo_name']::text AS p_promo_name,
  r['p_channel_dmail']::text AS p_channel_dmail,
  r['p_channel_email']::text AS p_channel_email,
  r['p_channel_catalog']::text AS p_channel_catalog,
  r['p_channel_tv']::text AS p_channel_tv,
  r['p_channel_radio']::text AS p_channel_radio,
  r['p_channel_press']::text AS p_channel_press,
  r['p_channel_event']::text AS p_channel_event,
  r['p_channel_demo']::text AS p_channel_demo,
  r['p_channel_details']::text AS p_channel_details,
  r['p_purpose']::text AS p_purpose,
  r['p_discount_active']::text AS p_discount_active FROM
read_parquet('/home/test/tpcds_tables100/promotion.parquet', binary_as_string => true) r;

CREATE VIEW catalog_page_parquet AS SELECT
  r['cp_catalog_page_sk']::integer AS cp_catalog_page_sk,
  r['cp_catalog_page_id']::text AS cp_catalog_page_id,
  r['cp_start_date_sk']::integer AS cp_start_date_sk,
  r['cp_end_date_sk']::integer AS cp_end_date_sk,
  r['cp_department']::text AS cp_department,
  r['cp_catalog_number']::integer AS cp_catalog_number,
  r['cp_catalog_page_number']::integer AS cp_catalog_page_number,
  r['cp_description']::text AS cp_description,
  r['cp_type']::text AS cp_type FROM
read_parquet('/home/test/tpcds_tables100/catalog_page.parquet', binary_as_string => true) r;

CREATE VIEW inventory_parquet AS SELECT
  r['inv_date_sk']::integer AS inv_date_sk,
  r['inv_item_sk']::integer AS inv_item_sk,
  r['inv_warehouse_sk']::integer AS inv_warehouse_sk,
  r['inv_quantity_on_hand']::integer AS inv_quantity_on_hand FROM
read_parquet('/home/test/tpcds_tables100/inventory.parquet', binary_as_string => true) r;

CREATE VIEW catalog_returns_parquet AS SELECT
  r['cr_returned_date_sk']::integer AS cr_returned_date_sk,
  r['cr_returned_time_sk']::integer AS cr_returned_time_sk,
  r['cr_item_sk']::integer AS cr_item_sk,
  r['cr_refunded_customer_sk']::integer AS cr_refunded_customer_sk,
  r['cr_refunded_cdemo_sk']::integer AS cr_refunded_cdemo_sk,
  r['cr_refunded_hdemo_sk']::integer AS cr_refunded_hdemo_sk,
  r['cr_refunded_addr_sk']::integer AS cr_refunded_addr_sk,
  r['cr_returning_customer_sk']::integer AS cr_returning_customer_sk,
  r['cr_returning_cdemo_sk']::integer AS cr_returning_cdemo_sk,
  r['cr_returning_hdemo_sk']::integer AS cr_returning_hdemo_sk,
  r['cr_returning_addr_sk']::integer AS cr_returning_addr_sk,
  r['cr_call_center_sk']::integer AS cr_call_center_sk,
  r['cr_catalog_page_sk']::integer AS cr_catalog_page_sk,
  r['cr_ship_mode_sk']::integer AS cr_ship_mode_sk,
  r['cr_warehouse_sk']::integer AS cr_warehouse_sk,
  r['cr_reason_sk']::integer AS cr_reason_sk,
  r['cr_order_number']::integer AS cr_order_number,
  r['cr_return_quantity']::integer AS cr_return_quantity,
  r['cr_return_amount']::decimal(7,2) AS cr_return_amount,
  r['cr_return_tax']::decimal(7,2) AS cr_return_tax,
  r['cr_return_amt_inc_tax']::decimal(7,2) AS cr_return_amt_inc_tax,
  r['cr_fee']::decimal(7,2) AS cr_fee,
  r['cr_return_ship_cost']::decimal(7,2) AS cr_return_ship_cost,
  r['cr_refunded_cash']::decimal(7,2) AS cr_refunded_cash,
  r['cr_reversed_charge']::decimal(7,2) AS cr_reversed_charge,
  r['cr_store_credit']::decimal(7,2) AS cr_store_credit,
  r['cr_net_loss']::decimal(7,2) AS cr_net_loss FROM
read_parquet('/home/test/tpcds_tables100/catalog_returns.parquet', binary_as_string => true) r;

CREATE VIEW web_returns_parquet AS SELECT
  r['wr_returned_date_sk']::integer AS wr_returned_date_sk,
  r['wr_returned_time_sk']::integer AS wr_returned_time_sk,
  r['wr_item_sk']::integer AS wr_item_sk,
  r['wr_refunded_customer_sk']::integer AS wr_refunded_customer_sk,
  r['wr_refunded_cdemo_sk']::integer AS wr_refunded_cdemo_sk,
  r['wr_refunded_hdemo_sk']::integer AS wr_refunded_hdemo_sk,
  r['wr_refunded_addr_sk']::integer AS wr_refunded_addr_sk,
  r['wr_returning_customer_sk']::integer AS wr_returning_customer_sk,
  r['wr_returning_cdemo_sk']::integer AS wr_returning_cdemo_sk,
  r['wr_returning_hdemo_sk']::integer AS wr_returning_hdemo_sk,
  r['wr_returning_addr_sk']::integer AS wr_returning_addr_sk,
  r['wr_web_page_sk']::integer AS wr_web_page_sk,
  r['wr_reason_sk']::integer AS wr_reason_sk,
  r['wr_order_number']::integer AS wr_order_number,
  r['wr_return_quantity']::integer AS wr_return_quantity,
  r['wr_return_amt']::decimal(7,2) AS wr_return_amt,
  r['wr_return_tax']::decimal(7,2) AS wr_return_tax,
  r['wr_return_amt_inc_tax']::decimal(7,2) AS wr_return_amt_inc_tax,
  r['wr_fee']::decimal(7,2) AS wr_fee,
  r['wr_return_ship_cost']::decimal(7,2) AS wr_return_ship_cost,
  r['wr_refunded_cash']::decimal(7,2) AS wr_refunded_cash,
  r['wr_reversed_charge']::decimal(7,2) AS wr_reversed_charge,
  r['wr_account_credit']::decimal(7,2) AS wr_account_credit,
  r['wr_net_loss']::decimal(7,2) AS wr_net_loss FROM
read_parquet('/home/test/tpcds_tables100/web_returns.parquet', binary_as_string => true) r;

CREATE VIEW web_sales_parquet AS SELECT
  r['ws_sold_date_sk']::integer AS ws_sold_date_sk,
  r['ws_sold_time_sk']::integer AS ws_sold_time_sk,
  r['ws_ship_date_sk']::integer AS ws_ship_date_sk,
  r['ws_item_sk']::integer AS ws_item_sk,
  r['ws_bill_customer_sk']::integer AS ws_bill_customer_sk,
  r['ws_bill_cdemo_sk']::integer AS ws_bill_cdemo_sk,
  r['ws_bill_hdemo_sk']::integer AS ws_bill_hdemo_sk,
  r['ws_bill_addr_sk']::integer AS ws_bill_addr_sk,
  r['ws_ship_customer_sk']::integer AS ws_ship_customer_sk,
  r['ws_ship_cdemo_sk']::integer AS ws_ship_cdemo_sk,
  r['ws_ship_hdemo_sk']::integer AS ws_ship_hdemo_sk,
  r['ws_ship_addr_sk']::integer AS ws_ship_addr_sk,
  r['ws_web_page_sk']::integer AS ws_web_page_sk,
  r['ws_web_site_sk']::integer AS ws_web_site_sk,
  r['ws_ship_mode_sk']::integer AS ws_ship_mode_sk,
  r['ws_warehouse_sk']::integer AS ws_warehouse_sk,
  r['ws_promo_sk']::integer AS ws_promo_sk,
  r['ws_order_number']::integer AS ws_order_number,
  r['ws_quantity']::integer AS ws_quantity,
  r['ws_wholesale_cost']::decimal(7,2) AS ws_wholesale_cost,
  r['ws_list_price']::decimal(7,2) AS ws_list_price,
  r['ws_sales_price']::decimal(7,2) AS ws_sales_price,
  r['ws_ext_discount_amt']::decimal(7,2) AS ws_ext_discount_amt,
  r['ws_ext_sales_price']::decimal(7,2) AS ws_ext_sales_price,
  r['ws_ext_wholesale_cost']::decimal(7,2) AS ws_ext_wholesale_cost,
  r['ws_ext_list_price']::decimal(7,2) AS ws_ext_list_price,
  r['ws_ext_tax']::decimal(7,2) AS ws_ext_tax,
  r['ws_coupon_amt']::decimal(7,2) AS ws_coupon_amt,
  r['ws_ext_ship_cost']::decimal(7,2) AS ws_ext_ship_cost,
  r['ws_net_paid']::decimal(7,2) AS ws_net_paid,
  r['ws_net_paid_inc_tax']::decimal(7,2) AS ws_net_paid_inc_tax,
  r['ws_net_paid_inc_ship']::decimal(7,2) AS ws_net_paid_inc_ship,
  r['ws_net_paid_inc_ship_tax']::decimal(7,2) AS ws_net_paid_inc_ship_tax,
  r['ws_net_profit']::decimal(7,2) AS ws_net_profit FROM
read_parquet('/home/test/tpcds_tables100/web_sales.parquet', binary_as_string => true) r;

CREATE VIEW catalog_sales_parquet AS SELECT
  r['cs_sold_date_sk']::integer AS cs_sold_date_sk,
  r['cs_sold_time_sk']::integer AS cs_sold_time_sk,
  r['cs_ship_date_sk']::integer AS cs_ship_date_sk,
  r['cs_bill_customer_sk']::integer AS cs_bill_customer_sk,
  r['cs_bill_cdemo_sk']::integer AS cs_bill_cdemo_sk,
  r['cs_bill_hdemo_sk']::integer AS cs_bill_hdemo_sk,
  r['cs_bill_addr_sk']::integer AS cs_bill_addr_sk,
  r['cs_ship_customer_sk']::integer AS cs_ship_customer_sk,
  r['cs_ship_cdemo_sk']::integer AS cs_ship_cdemo_sk,
  r['cs_ship_hdemo_sk']::integer AS cs_ship_hdemo_sk,
  r['cs_ship_addr_sk']::integer AS cs_ship_addr_sk,
  r['cs_call_center_sk']::integer AS cs_call_center_sk,
  r['cs_catalog_page_sk']::integer AS cs_catalog_page_sk,
  r['cs_ship_mode_sk']::integer AS cs_ship_mode_sk,
  r['cs_warehouse_sk']::integer AS cs_warehouse_sk,
  r['cs_item_sk']::integer AS cs_item_sk,
  r['cs_promo_sk']::integer AS cs_promo_sk,
  r['cs_order_number']::integer AS cs_order_number,
  r['cs_quantity']::integer AS cs_quantity,
  r['cs_wholesale_cost']::decimal(7,2) AS cs_wholesale_cost,
  r['cs_list_price']::decimal(7,2) AS cs_list_price,
  r['cs_sales_price']::decimal(7,2) AS cs_sales_price,
  r['cs_ext_discount_amt']::decimal(7,2) AS cs_ext_discount_amt,
  r['cs_ext_sales_price']::decimal(7,2) AS cs_ext_sales_price,
  r['cs_ext_wholesale_cost']::decimal(7,2) AS cs_ext_wholesale_cost,
  r['cs_ext_list_price']::decimal(7,2) AS cs_ext_list_price,
  r['cs_ext_tax']::decimal(7,2) AS cs_ext_tax,
  r['cs_coupon_amt']::decimal(7,2) AS cs_coupon_amt,
  r['cs_ext_ship_cost']::decimal(7,2) AS cs_ext_ship_cost,
  r['cs_net_paid']::decimal(7,2) AS cs_net_paid,
  r['cs_net_paid_inc_tax']::decimal(7,2) AS cs_net_paid_inc_tax,
  r['cs_net_paid_inc_ship']::decimal(7,2) AS cs_net_paid_inc_ship,
  r['cs_net_paid_inc_ship_tax']::decimal(7,2) AS cs_net_paid_inc_ship_tax,
  r['cs_net_profit']::decimal(7,2) AS cs_net_profit FROM
read_parquet('/home/test/tpcds_tables100/catalog_sales.parquet', binary_as_string => true) r;

CREATE VIEW store_sales_parquet AS SELECT
  r['ss_sold_date_sk']::integer AS ss_sold_date_sk,
  r['ss_sold_time_sk']::integer AS ss_sold_time_sk,
  r['ss_item_sk']::integer AS ss_item_sk,
  r['ss_customer_sk']::integer as ss_customer_sk,
  r['ss_cdemo_sk']::integer AS ss_cdemo_sk,
  r['ss_hdemo_sk']::integer AS ss_hdemo_sk,
  r['ss_addr_sk']::integer AS ss_addr_sk,
  r['ss_store_sk']::integer AS ss_store_sk,
  r['ss_promo_sk']::integer AS ss_promo_sk,
  r['ss_ticket_number']::integer AS ss_ticket_number,
  r['ss_quantity']::integer AS ss_quantity,
  r['ss_wholesale_cost']::decimal(7,2) AS ss_wholesale_cost,
  r['ss_list_price']::decimal(7,2) AS ss_list_price,
  r['ss_sales_price']::decimal(7,2) AS ss_sales_price,
  r['ss_ext_discount_amt']::decimal(7,2) AS ss_ext_discount_amt,
  r['ss_ext_sales_price']::decimal(7,2) AS ss_ext_sales_price,
  r['ss_ext_wholesale_cost']::decimal(7,2) AS ss_ext_wholesale_cost,
  r['ss_ext_list_price']::decimal(7,2) AS ss_ext_list_price,
  r['ss_ext_tax']::decimal(7,2) AS ss_ext_tax,
  r['ss_coupon_amt']::decimal(7,2) AS ss_coupon_amt,
  r['ss_net_paid']::decimal(7,2) AS ss_net_paid,
  r['ss_net_paid_inc_tax']::decimal(7,2) AS ss_net_paid_inc_tax,
  r['ss_net_profit']::decimal(7,2) AS ss_net_profit FROM
read_parquet('/home/test/tpcds_tables100/store_sales.parquet', binary_as_string => true) r;