Создание тестовых таблиц:

      COPY nation
    TO '/home/test/tpch_tables100/nation.parquet'
    (FORMAT 'parquet', COMPRESSION 'zstd');

    COPY region
    TO '/home/test/tpch_tables100/region.parquet'
    (FORMAT 'parquet', COMPRESSION 'zstd');

    COPY part
    TO '/home/test/tpch_tables100/part.parquet'
    (FORMAT 'parquet', COMPRESSION 'zstd');

    COPY supplierF
    TO '/home/test/tpch_tables100/supplier.parquet'
    (FORMAT 'parquet', COMPRESSION 'zstd');

    COPY partsupp
    TO '/home/test/tpch_tables100/partsupp.parquet'
    (FORMAT 'parquet', COMPRESSION 'zstd');

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

    COPY orders
    TO '/home/test/tpch_tables100/orders.parquet'
    (FORMAT 'parquet', COMPRESSION 'zstd');

    COPY lineitem
    TO '/home/test/tpch_tables100/lineitem.parquet'
    (FORMAT 'parquet', COMPRESSION 'zstd');

    CREATE VIEW nation_parquet AS SELECT
      r['n_nationkey']::integer AS n_nationkey,
      r['n_name']::text AS n_name,
      r['n_regionkey']::integer AS n_regionkey,
      r['n_comment']::text AS n_comment from
    read_parquet('/home/test/tpch_tables100/nation.parquet', binary_as_string => true) r;
    CREATE VIEW region_parquet AS SELECT
      r['r_regionkey']::integer AS r_regionkey,
      r['r_name']::text AS r_name,
      r['r_comment']::text AS r_comment from
    read_parquet('/home/test/tpch_tables100/region.parquet', binary_as_string => true) r;
    CREATE VIEW part_parquet AS SELECT
      r['p_partkey']::integer AS p_partkey,
      r['p_name']::text AS p_name,
      r['p_mfgr']::text AS p_mfgr,
      r['p_brand']::text AS p_brand,
      r['p_type']::text AS p_type,
      r['p_size']::integer AS p_size,
      r['p_container']::text AS p_container,
      r['p_retailprice']::decimal(15,2) AS p_retailprice,
      r['p_comment']::text AS p_comment from
    read_parquet('/home/test/tpch_tables100/part.parquet', binary_as_string => true) r;
    CREATE VIEW supplier_parquet AS SELECT
      r['s_suppkey']::integer AS s_suppkey,
      r['s_name']::text AS s_name,
      r['s_address']::text AS s_address,
      r['s_nationkey']::integer AS s_nationkey,
      r['s_phone']::text AS s_phone,
      r['s_acctbal']::decimal(15,2) AS s_acctbal,
      r['s_comment']::text AS s_comment from
    read_parquet('/home/test/tpch_tables100/supplier.parquet', binary_as_string => true) r;
    CREATE VIEW nation_parquet AS SELECT
      r['n_nationkey']::integer AS n_nationkey,
      r['n_name']::text AS n_name,
      r['n_regionkey']::integer AS n_regionkey,
      r['n_comment']::text AS n_comment from
    read_parquet('/home/test/tpch_tables100/nation.parquet', binary_as_string => true) r;
    CREATE VIEW region_parquet AS SELECT
      r['r_regionkey']::integer AS r_regionkey,
      r['r_name']::text AS r_name,
      r['r_comment']::text AS r_comment from
    read_parquet('/home/test/tpch_tables100/region.parquet', binary_as_string => true) r;
    CREATE VIEW part_parquet AS SELECT
      r['p_partkey']::integer AS p_partkey,
      r['p_name']::text AS p_name,
      r['p_mfgr']::text AS p_mfgr,
      r['p_brand']::text AS p_brand,
      r['p_type']::text AS p_type,
      r['p_size']::integer AS p_size,
      r['p_container']::text AS p_container,
      r['p_retailprice']::decimal(15,2) AS p_retailprice,
      r['p_comment']::text AS p_comment from
    read_parquet('/home/test/tpch_tables100/part.parquet', binary_as_string => true) r;
    CREATE VIEW supplier_parquet AS SELECT
      r['s_suppkey']::integer AS s_suppkey,
      r['s_name']::text AS s_name,
      r['s_address']::text AS s_address,
      r['s_nationkey']::integer AS s_nationkey,
      r['s_phone']::text AS s_phone,
      r['s_acctbal']::decimal(15,2) AS s_acctbal,
      r['s_comment']::text AS s_comment from
    read_parquet('/home/test/tpch_tables100/supplier.parquet', binary_as_string => true) r;
    CREATE VIEW lineitem_parquet AS SELECT
      r['l_orderkey']::integer AS l_orderkey,
      r['l_partkey']::integer AS l_partkey,
      r['l_suppkey']::integer AS l_suppkey,
      r['l_linenumber']::integer AS l_linenumber,
      r['l_quantity']::decimal(15,2) AS l_quantity,
      r['l_extendedprice']::decimal(15,2) AS l_extendedprice,
      r['l_discount']::decimal(15,2) AS l_discount,
      r['l_tax']::decimal(15,2) AS l_tax,
      r['l_returnflag']::text AS l_returnflag,
      r['l_linestatus']::text AS l_linestatus,
      r['l_shipdate']::date AS l_shipdate,
      r['l_commitdate']::date AS l_commitdate,
      r['l_receiptdate']::date AS l_receiptdate,
      r['l_shipinstruct']::text AS l_shipinstruct,
      r['l_shipmode']::text AS l_shipmode,
      r['l_comment']::text AS l_comment from
    read_parquet('/home/test/tpch_tables100/lineitem.parquet', binary_as_string => true) r;
  
 

Создание тестовых таблиц:

      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_sk,
      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;
  
 

На основании выполненных тестов производительности можно сделать следующие выводы:

Эти выводы можно использовать для изначального планирования ресурсов. За более подробной информацией обратитесь к разделу Планирование ресурсов. Можно утверждать, что в тестах производительности результаты времени практически линейно зависят от коэффициента масштабирования.