benchmark: add tpcds sf1000 velodb

benchmarks/tpcds/sf100/doris/benchmark.yaml

@@ -30,7 +30,7 @@ paths:
   ddl: "ddl/ddl.sql" # DDL setup file
   session_file: "${SESSION_FILE:-session/session.sql}" # Session setup file
   analyze_file: "${ANALYZE_FILE:-analyze/analyze.sql}" # Analyze statistics file
-  load_dir: "load/load_s3/" # Directory containing data loading scripts (local Stream Load)
+  load_dir: "${LOAD_DIR:-load/insert_into_trino/}" # Directory containing data loading SQL files
   query_dir: "${QUERY_DIR:-query/}" # Directory containing query SQL files
   query_mode: "file" # Query file format: "line" (each line is a query) or "file" (entire file is one query)
 storage:
@@ -39,3 +39,28 @@ storage:
   bucket: "${STORAGE_BUCKET:-bench-dataset}"
   access_key: "${STORAGE_ACCESS_KEY:-xxx}"
   secret_key: "${STORAGE_SECRET_KEY:-xxx}"
+tables:
+  customer_demographics: 1920800
+  reason: 55
+  warehouse: 15
+  date_dim: 73049
+  catalog_sales: 143997065
+  call_center: 30
+  inventory: 399330000
+  catalog_returns: 14404374
+  household_demographics: 7200
+  customer_address: 1000000
+  income_band: 20
+  catalog_page: 20400
+  item: 204000
+  web_returns: 7197670
+  web_site: 24
+  promotion: 1000
+  web_sales: 72001237
+  store: 402
+  web_page: 2040
+  time_dim: 86400
+  store_returns: 28795080
+  store_sales: 287997024
+  ship_mode: 20
+  customer: 2000000

benchmarks/tpcds/sf100/doris/ddl/ddl.sql

@@ -1,3 +1,11 @@
+DROP CATALOG IF EXISTS `tpcds`;
+
+CREATE CATALOG IF NOT EXISTS `tpcds` PROPERTIES(
+    "type" = "trino-connector",
+    "trino.connector.name" = "tpcds",
+    "trino.tpcds.split-count" = "128"
+);
+
 create table call_center
 (
     cc_call_center_sk         integer               not null,

benchmarks/tpcds/sf100/doris/load/insert_into_trino/call_center.sql

@@ -0,0 +1 @@
+INSERT INTO call_center (cc_call_center_sk, cc_call_center_id, cc_rec_start_date, cc_rec_end_date, cc_closed_date_sk, cc_open_date_sk, cc_name, cc_class, cc_employees, cc_sq_ft, cc_hours, cc_manager, cc_mkt_id, cc_mkt_class, cc_mkt_desc, cc_market_manager, cc_division, cc_division_name, cc_company, cc_company_name, cc_street_number, cc_street_name, cc_street_type, cc_suite_number, cc_city, cc_county, cc_state, cc_zip, cc_country, cc_gmt_offset, cc_tax_percentage) SELECT cc_call_center_sk, cc_call_center_id, cc_rec_start_date, cc_rec_end_date, cc_closed_date_sk, cc_open_date_sk, cc_name, cc_class, cc_employees, cc_sq_ft, cc_hours, cc_manager, cc_mkt_id, cc_mkt_class, cc_mkt_desc, cc_market_manager, cc_division, cc_division_name, cc_company, cc_company_name, cc_street_number, cc_street_name, cc_street_type, cc_suite_number, cc_city, cc_county, cc_state, cc_zip, cc_country, cc_gmt_offset, cc_tax_percentage FROM tpcds.sf100.call_center;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/catalog_page.sql

@@ -0,0 +1 @@
+INSERT INTO catalog_page (cp_catalog_page_sk, cp_catalog_page_id, cp_start_date_sk, cp_end_date_sk, cp_department, cp_catalog_number, cp_catalog_page_number, cp_description, cp_type) SELECT cp_catalog_page_sk, cp_catalog_page_id, cp_start_date_sk, cp_end_date_sk, cp_department, cp_catalog_number, cp_catalog_page_number, cp_description, cp_type FROM tpcds.sf100.catalog_page;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/catalog_returns.sql

@@ -0,0 +1 @@
+INSERT INTO catalog_returns (cr_returned_date_sk, cr_returned_time_sk, cr_item_sk, cr_refunded_customer_sk, cr_refunded_cdemo_sk, cr_refunded_hdemo_sk, cr_refunded_addr_sk, cr_returning_customer_sk, cr_returning_cdemo_sk, cr_returning_hdemo_sk, cr_returning_addr_sk, cr_call_center_sk, cr_catalog_page_sk, cr_ship_mode_sk, cr_warehouse_sk, cr_reason_sk, cr_order_number, cr_return_quantity, cr_return_amount, cr_return_tax, cr_return_amt_inc_tax, cr_fee, cr_return_ship_cost, cr_refunded_cash, cr_reversed_charge, cr_store_credit, cr_net_loss) SELECT cr_returned_date_sk, cr_returned_time_sk, cr_item_sk, cr_refunded_customer_sk, cr_refunded_cdemo_sk, cr_refunded_hdemo_sk, cr_refunded_addr_sk, cr_returning_customer_sk, cr_returning_cdemo_sk, cr_returning_hdemo_sk, cr_returning_addr_sk, cr_call_center_sk, cr_catalog_page_sk, cr_ship_mode_sk, cr_warehouse_sk, cr_reason_sk, cr_order_number, cr_return_quantity, cr_return_amount, cr_return_tax, cr_return_amt_inc_tax, cr_fee, cr_return_ship_cost, cr_refunded_cash, cr_reversed_charge, cr_store_credit, cr_net_loss FROM tpcds.sf100.catalog_returns;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/catalog_sales.sql

@@ -0,0 +1 @@
+INSERT INTO catalog_sales (cs_sold_date_sk, cs_sold_time_sk, cs_ship_date_sk, cs_bill_customer_sk, cs_bill_cdemo_sk, cs_bill_hdemo_sk, cs_bill_addr_sk, cs_ship_customer_sk, cs_ship_cdemo_sk, cs_ship_hdemo_sk, cs_ship_addr_sk, cs_call_center_sk, cs_catalog_page_sk, cs_ship_mode_sk, cs_warehouse_sk, cs_item_sk, cs_promo_sk, cs_order_number, cs_quantity, cs_wholesale_cost, cs_list_price, cs_sales_price, cs_ext_discount_amt, cs_ext_sales_price, cs_ext_wholesale_cost, cs_ext_list_price, cs_ext_tax, cs_coupon_amt, cs_ext_ship_cost, cs_net_paid, cs_net_paid_inc_tax, cs_net_paid_inc_ship, cs_net_paid_inc_ship_tax, cs_net_profit) SELECT cs_sold_date_sk, cs_sold_time_sk, cs_ship_date_sk, cs_bill_customer_sk, cs_bill_cdemo_sk, cs_bill_hdemo_sk, cs_bill_addr_sk, cs_ship_customer_sk, cs_ship_cdemo_sk, cs_ship_hdemo_sk, cs_ship_addr_sk, cs_call_center_sk, cs_catalog_page_sk, cs_ship_mode_sk, cs_warehouse_sk, cs_item_sk, cs_promo_sk, cs_order_number, cs_quantity, cs_wholesale_cost, cs_list_price, cs_sales_price, cs_ext_discount_amt, cs_ext_sales_price, cs_ext_wholesale_cost, cs_ext_list_price, cs_ext_tax, cs_coupon_amt, cs_ext_ship_cost, cs_net_paid, cs_net_paid_inc_tax, cs_net_paid_inc_ship, cs_net_paid_inc_ship_tax, cs_net_profit FROM tpcds.sf100.catalog_sales;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/customer.sql

@@ -0,0 +1 @@
+INSERT INTO customer (c_customer_sk, c_customer_id, c_current_cdemo_sk, c_current_hdemo_sk, c_current_addr_sk, c_first_shipto_date_sk, c_first_sales_date_sk, c_salutation, c_first_name, c_last_name, c_preferred_cust_flag, c_birth_day, c_birth_month, c_birth_year, c_birth_country, c_login, c_email_address, c_last_review_date_sk) SELECT c_customer_sk, c_customer_id, c_current_cdemo_sk, c_current_hdemo_sk, c_current_addr_sk, c_first_shipto_date_sk, c_first_sales_date_sk, c_salutation, c_first_name, c_last_name, c_preferred_cust_flag, c_birth_day, c_birth_month, c_birth_year, c_birth_country, c_login, c_email_address, c_last_review_date_sk FROM tpcds.sf100.customer;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/customer_address.sql

@@ -0,0 +1 @@
+INSERT INTO customer_address (ca_address_sk, ca_address_id, ca_street_number, ca_street_name, ca_street_type, ca_suite_number, ca_city, ca_county, ca_state, ca_zip, ca_country, ca_gmt_offset, ca_location_type) SELECT ca_address_sk, ca_address_id, ca_street_number, ca_street_name, ca_street_type, ca_suite_number, ca_city, ca_county, ca_state, ca_zip, ca_country, ca_gmt_offset, ca_location_type FROM tpcds.sf100.customer_address;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/customer_demographics.sql

@@ -0,0 +1 @@
+INSERT INTO customer_demographics (cd_demo_sk, cd_gender, cd_marital_status, cd_education_status, cd_purchase_estimate, cd_credit_rating, cd_dep_count, cd_dep_employed_count, cd_dep_college_count) SELECT cd_demo_sk, cd_gender, cd_marital_status, cd_education_status, cd_purchase_estimate, cd_credit_rating, cd_dep_count, cd_dep_employed_count, cd_dep_college_count FROM tpcds.sf100.customer_demographics;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/date_dim.sql

@@ -0,0 +1 @@
+INSERT INTO date_dim (d_date_sk, d_date_id, d_date, d_month_seq, d_week_seq, d_quarter_seq, d_year, d_dow, d_moy, d_dom, d_qoy, d_fy_year, d_fy_quarter_seq, d_fy_week_seq, d_day_name, d_quarter_name, d_holiday, d_weekend, d_following_holiday, d_first_dom, d_last_dom, d_same_day_ly, d_same_day_lq, d_current_day, d_current_week, d_current_month, d_current_quarter, d_current_year) SELECT d_date_sk, d_date_id, d_date, d_month_seq, d_week_seq, d_quarter_seq, d_year, d_dow, d_moy, d_dom, d_qoy, d_fy_year, d_fy_quarter_seq, d_fy_week_seq, d_day_name, d_quarter_name, d_holiday, d_weekend, d_following_holiday, d_first_dom, d_last_dom, d_same_day_ly, d_same_day_lq, d_current_day, d_current_week, d_current_month, d_current_quarter, d_current_year FROM tpcds.sf100.date_dim;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/household_demographics.sql

@@ -0,0 +1 @@
+INSERT INTO household_demographics (hd_demo_sk, hd_income_band_sk, hd_buy_potential, hd_dep_count, hd_vehicle_count) SELECT hd_demo_sk, hd_income_band_sk, hd_buy_potential, hd_dep_count, hd_vehicle_count FROM tpcds.sf100.household_demographics;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/income_band.sql

@@ -0,0 +1 @@
+INSERT INTO income_band (ib_income_band_sk, ib_lower_bound, ib_upper_bound) SELECT ib_income_band_sk, ib_lower_bound, ib_upper_bound FROM tpcds.sf100.income_band;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/inventory.sql

@@ -0,0 +1 @@
+INSERT INTO inventory (inv_date_sk, inv_item_sk, inv_warehouse_sk, inv_quantity_on_hand) SELECT inv_date_sk, inv_item_sk, inv_warehouse_sk, inv_quantity_on_hand FROM tpcds.sf100.inventory;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/item.sql

@@ -0,0 +1 @@
+INSERT INTO item (i_item_sk, i_item_id, i_rec_start_date, i_rec_end_date, i_item_desc, i_current_price, i_wholesale_cost, i_brand_id, i_brand, i_class_id, i_class, i_category_id, i_category, i_manufact_id, i_manufact, i_size, i_formulation, i_color, i_units, i_container, i_manager_id, i_product_name) SELECT i_item_sk, i_item_id, i_rec_start_date, i_rec_end_date, i_item_desc, i_current_price, i_wholesale_cost, i_brand_id, i_brand, i_class_id, i_class, i_category_id, i_category, i_manufact_id, i_manufact, i_size, i_formulation, i_color, i_units, i_container, i_manager_id, i_product_name FROM tpcds.sf100.item;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/promotion.sql

@@ -0,0 +1 @@
+INSERT INTO promotion (p_promo_sk, p_promo_id, p_start_date_sk, p_end_date_sk, p_item_sk, p_cost, p_response_target, p_promo_name, p_channel_dmail, p_channel_email, p_channel_catalog, p_channel_tv, p_channel_radio, p_channel_press, p_channel_event, p_channel_demo, p_channel_details, p_purpose, p_discount_active) SELECT p_promo_sk, p_promo_id, p_start_date_sk, p_end_date_sk, p_item_sk, p_cost, p_response_targe, p_promo_name, p_channel_dmail, p_channel_email, p_channel_catalog, p_channel_tv, p_channel_radio, p_channel_press, p_channel_event, p_channel_demo, p_channel_details, p_purpose, p_discount_active FROM tpcds.sf100.promotion;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/reason.sql

@@ -0,0 +1 @@
+INSERT INTO reason (r_reason_sk, r_reason_id, r_reason_desc) SELECT r_reason_sk, r_reason_id, r_reason_desc FROM tpcds.sf100.reason;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/ship_mode.sql

@@ -0,0 +1 @@
+INSERT INTO ship_mode (sm_ship_mode_sk, sm_ship_mode_id, sm_type, sm_code, sm_carrier, sm_contract) SELECT sm_ship_mode_sk, sm_ship_mode_id, sm_type, sm_code, sm_carrier, sm_contract FROM tpcds.sf100.ship_mode;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/store.sql

@@ -0,0 +1 @@
+INSERT INTO store (s_store_sk, s_store_id, s_rec_start_date, s_rec_end_date, s_closed_date_sk, s_store_name, s_number_employees, s_floor_space, s_hours, s_manager, s_market_id, s_geography_class, s_market_desc, s_market_manager, s_division_id, s_division_name, s_company_id, s_company_name, s_street_number, s_street_name, s_street_type, s_suite_number, s_city, s_county, s_state, s_zip, s_country, s_gmt_offset, s_tax_precentage) SELECT s_store_sk, s_store_id, s_rec_start_date, s_rec_end_date, s_closed_date_sk, s_store_name, s_number_employees, s_floor_space, s_hours, s_manager, s_market_id, s_geography_class, s_market_desc, s_market_manager, s_division_id, s_division_name, s_company_id, s_company_name, s_street_number, s_street_name, s_street_type, s_suite_number, s_city, s_county, s_state, s_zip, s_country, s_gmt_offset, s_tax_precentage FROM tpcds.sf100.store;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/store_returns.sql

@@ -0,0 +1 @@
+INSERT INTO store_returns (sr_returned_date_sk, sr_return_time_sk, sr_item_sk, sr_customer_sk, sr_cdemo_sk, sr_hdemo_sk, sr_addr_sk, sr_store_sk, sr_reason_sk, sr_ticket_number, sr_return_quantity, sr_return_amt, sr_return_tax, sr_return_amt_inc_tax, sr_fee, sr_return_ship_cost, sr_refunded_cash, sr_reversed_charge, sr_store_credit, sr_net_loss) SELECT sr_returned_date_sk, sr_return_time_sk, sr_item_sk, sr_customer_sk, sr_cdemo_sk, sr_hdemo_sk, sr_addr_sk, sr_store_sk, sr_reason_sk, sr_ticket_number, sr_return_quantity, sr_return_amt, sr_return_tax, sr_return_amt_inc_tax, sr_fee, sr_return_ship_cost, sr_refunded_cash, sr_reversed_charge, sr_store_credit, sr_net_loss FROM tpcds.sf100.store_returns;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/store_sales.sql

@@ -0,0 +1 @@
+INSERT INTO store_sales (ss_sold_date_sk, ss_sold_time_sk, ss_item_sk, ss_customer_sk, ss_cdemo_sk, ss_hdemo_sk, ss_addr_sk, ss_store_sk, ss_promo_sk, ss_ticket_number, ss_quantity, ss_wholesale_cost, ss_list_price, ss_sales_price, ss_ext_discount_amt, ss_ext_sales_price, ss_ext_wholesale_cost, ss_ext_list_price, ss_ext_tax, ss_coupon_amt, ss_net_paid, ss_net_paid_inc_tax, ss_net_profit) SELECT ss_sold_date_sk, ss_sold_time_sk, ss_item_sk, ss_customer_sk, ss_cdemo_sk, ss_hdemo_sk, ss_addr_sk, ss_store_sk, ss_promo_sk, ss_ticket_number, ss_quantity, ss_wholesale_cost, ss_list_price, ss_sales_price, ss_ext_discount_amt, ss_ext_sales_price, ss_ext_wholesale_cost, ss_ext_list_price, ss_ext_tax, ss_coupon_amt, ss_net_paid, ss_net_paid_inc_tax, ss_net_profit FROM tpcds.sf100.store_sales;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/time_dim.sql

@@ -0,0 +1 @@
+INSERT INTO time_dim (t_time_sk, t_time_id, t_time, t_hour, t_minute, t_second, t_am_pm, t_shift, t_sub_shift, t_meal_time) SELECT t_time_sk, t_time_id, t_time, t_hour, t_minute, t_second, t_am_pm, t_shift, t_sub_shift, t_meal_time FROM tpcds.sf100.time_dim;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/warehouse.sql

@@ -0,0 +1 @@
+INSERT INTO warehouse (w_warehouse_sk, w_warehouse_id, w_warehouse_name, w_warehouse_sq_ft, w_street_number, w_street_name, w_street_type, w_suite_number, w_city, w_county, w_state, w_zip, w_country, w_gmt_offset) SELECT w_warehouse_sk, w_warehouse_id, w_warehouse_name, w_warehouse_sq_ft, w_street_number, w_street_name, w_street_type, w_suite_number, w_city, w_county, w_state, w_zip, w_country, w_gmt_offset FROM tpcds.sf100.warehouse;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/web_page.sql

@@ -0,0 +1 @@
+INSERT INTO web_page (wp_web_page_sk, wp_web_page_id, wp_rec_start_date, wp_rec_end_date, wp_creation_date_sk, wp_access_date_sk, wp_autogen_flag, wp_customer_sk, wp_url, wp_type, wp_char_count, wp_link_count, wp_image_count, wp_max_ad_count) SELECT wp_web_page_sk, wp_web_page_id, wp_rec_start_date, wp_rec_end_date, wp_creation_date_sk, wp_access_date_sk, wp_autogen_flag, wp_customer_sk, wp_url, wp_type, wp_char_count, wp_link_count, wp_image_count, wp_max_ad_count FROM tpcds.sf100.web_page;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/web_returns.sql

@@ -0,0 +1 @@
+INSERT INTO web_returns (wr_returned_date_sk, wr_returned_time_sk, wr_item_sk, wr_refunded_customer_sk, wr_refunded_cdemo_sk, wr_refunded_hdemo_sk, wr_refunded_addr_sk, wr_returning_customer_sk, wr_returning_cdemo_sk, wr_returning_hdemo_sk, wr_returning_addr_sk, wr_web_page_sk, wr_reason_sk, wr_order_number, wr_return_quantity, wr_return_amt, wr_return_tax, wr_return_amt_inc_tax, wr_fee, wr_return_ship_cost, wr_refunded_cash, wr_reversed_charge, wr_account_credit, wr_net_loss) SELECT wr_returned_date_sk, wr_returned_time_sk, wr_item_sk, wr_refunded_customer_sk, wr_refunded_cdemo_sk, wr_refunded_hdemo_sk, wr_refunded_addr_sk, wr_returning_customer_sk, wr_returning_cdemo_sk, wr_returning_hdemo_sk, wr_returning_addr_sk, wr_web_page_sk, wr_reason_sk, wr_order_number, wr_return_quantity, wr_return_amt, wr_return_tax, wr_return_amt_inc_tax, wr_fee, wr_return_ship_cost, wr_refunded_cash, wr_reversed_charge, wr_account_credit, wr_net_loss FROM tpcds.sf100.web_returns;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/web_sales.sql

@@ -0,0 +1 @@
+INSERT INTO web_sales (ws_sold_date_sk, ws_sold_time_sk, ws_ship_date_sk, ws_item_sk, ws_bill_customer_sk, ws_bill_cdemo_sk, ws_bill_hdemo_sk, ws_bill_addr_sk, ws_ship_customer_sk, ws_ship_cdemo_sk, ws_ship_hdemo_sk, ws_ship_addr_sk, ws_web_page_sk, ws_web_site_sk, ws_ship_mode_sk, ws_warehouse_sk, ws_promo_sk, ws_order_number, ws_quantity, ws_wholesale_cost, ws_list_price, ws_sales_price, ws_ext_discount_amt, ws_ext_sales_price, ws_ext_wholesale_cost, ws_ext_list_price, ws_ext_tax, ws_coupon_amt, ws_ext_ship_cost, ws_net_paid, ws_net_paid_inc_tax, ws_net_paid_inc_ship, ws_net_paid_inc_ship_tax, ws_net_profit) SELECT ws_sold_date_sk, ws_sold_time_sk, ws_ship_date_sk, ws_item_sk, ws_bill_customer_sk, ws_bill_cdemo_sk, ws_bill_hdemo_sk, ws_bill_addr_sk, ws_ship_customer_sk, ws_ship_cdemo_sk, ws_ship_hdemo_sk, ws_ship_addr_sk, ws_web_page_sk, ws_web_site_sk, ws_ship_mode_sk, ws_warehouse_sk, ws_promo_sk, ws_order_number, ws_quantity, ws_wholesale_cost, ws_list_price, ws_sales_price, ws_ext_discount_amt, ws_ext_sales_price, ws_ext_wholesale_cost, ws_ext_list_price, ws_ext_tax, ws_coupon_amt, ws_ext_ship_cost, ws_net_paid, ws_net_paid_inc_tax, ws_net_paid_inc_ship, ws_net_paid_inc_ship_tax, ws_net_profit FROM tpcds.sf100.web_sales;

benchmarks/tpcds/sf100/doris/load/insert_into_trino/web_site.sql

@@ -0,0 +1 @@
+INSERT INTO web_site (web_site_sk, web_site_id, web_rec_start_date, web_rec_end_date, web_name, web_open_date_sk, web_close_date_sk, web_class, web_manager, web_mkt_id, web_mkt_class, web_mkt_desc, web_market_manager, web_company_id, web_company_name, web_street_number, web_street_name, web_street_type, web_suite_number, web_city, web_county, web_state, web_zip, web_country, web_gmt_offset, web_tax_percentage) SELECT web_site_sk, web_site_id, web_rec_start_date, web_rec_end_date, web_name, web_open_date_sk, web_close_date_sk, web_class, web_manager, web_mkt_id, web_mkt_class, web_mkt_desc, web_market_manager, web_company_id, web_company_name, web_street_number, web_street_name, web_street_type, web_suite_number, web_city, web_county, web_state, web_zip, web_country, web_gmt_offset, web_tax_percentage FROM tpcds.sf100.web_site;

benchmarks/tpcds/sf100/velodb/analyze/analyze.sql

@@ -0,0 +1,50 @@
+set global enable_auto_analyze=false;
+SELECT sleep(60);
+DROP STATS call_center;
+DROP STATS catalog_page;
+DROP STATS catalog_returns;
+DROP STATS catalog_sales;
+DROP STATS customer_address;
+DROP STATS customer_demographics;
+DROP STATS customer;
+DROP STATS date_dim;
+DROP STATS household_demographics;
+DROP STATS income_band;
+DROP STATS inventory;
+DROP STATS item;
+DROP STATS promotion;
+DROP STATS reason;
+DROP STATS ship_mode;
+DROP STATS store_returns;
+DROP STATS store_sales;
+DROP STATS store;
+DROP STATS time_dim;
+DROP STATS warehouse;
+DROP STATS web_page;
+DROP STATS web_returns;
+DROP STATS web_sales;
+DROP STATS web_site;
+ANALYZE TABLE call_center WITH SYNC;
+ANALYZE TABLE catalog_page WITH SYNC;
+ANALYZE TABLE catalog_returns WITH SYNC;
+ANALYZE TABLE catalog_sales WITH SYNC;
+ANALYZE TABLE customer_address WITH SYNC;
+ANALYZE TABLE customer_demographics WITH SYNC;
+ANALYZE TABLE customer WITH SYNC;
+ANALYZE TABLE date_dim WITH SYNC;
+ANALYZE TABLE household_demographics WITH SYNC;
+ANALYZE TABLE income_band WITH SYNC;
+ANALYZE TABLE inventory WITH SYNC;
+ANALYZE TABLE item WITH SYNC;
+ANALYZE TABLE promotion WITH SYNC;
+ANALYZE TABLE reason WITH SYNC;
+ANALYZE TABLE ship_mode WITH SYNC;
+ANALYZE TABLE store_returns WITH SYNC;
+ANALYZE TABLE store_sales WITH SYNC;
+ANALYZE TABLE store WITH SYNC;
+ANALYZE TABLE time_dim WITH SYNC;
+ANALYZE TABLE warehouse WITH SYNC;
+ANALYZE TABLE web_page WITH SYNC;
+ANALYZE TABLE web_returns WITH SYNC;
+ANALYZE TABLE web_sales WITH SYNC;
+ANALYZE TABLE web_site WITH SYNC;

benchmarks/tpcds/sf100/velodb/analyze/analyze_full.sql

@@ -0,0 +1,50 @@
+set global enable_auto_analyze=false;
+SELECT sleep(60);
+DROP STATS call_center;
+DROP STATS catalog_page;
+DROP STATS catalog_returns;
+DROP STATS catalog_sales;
+DROP STATS customer_address;
+DROP STATS customer_demographics;
+DROP STATS customer;
+DROP STATS date_dim;
+DROP STATS household_demographics;
+DROP STATS income_band;
+DROP STATS inventory;
+DROP STATS item;
+DROP STATS promotion;
+DROP STATS reason;
+DROP STATS ship_mode;
+DROP STATS store_returns;
+DROP STATS store_sales;
+DROP STATS store;
+DROP STATS time_dim;
+DROP STATS warehouse;
+DROP STATS web_page;
+DROP STATS web_returns;
+DROP STATS web_sales;
+DROP STATS web_site;
+ANALYZE TABLE call_center WITH SYNC;
+ANALYZE TABLE catalog_page WITH SYNC;
+ANALYZE TABLE catalog_returns WITH SYNC;
+ANALYZE TABLE catalog_sales WITH SYNC;
+ANALYZE TABLE customer_address WITH SYNC;
+ANALYZE TABLE customer_demographics WITH SYNC;
+ANALYZE TABLE customer WITH SYNC;
+ANALYZE TABLE date_dim WITH SYNC;
+ANALYZE TABLE household_demographics WITH SYNC;
+ANALYZE TABLE income_band WITH SYNC;
+ANALYZE TABLE inventory WITH SYNC;
+ANALYZE TABLE item WITH SYNC;
+ANALYZE TABLE promotion WITH SYNC;
+ANALYZE TABLE reason WITH SYNC;
+ANALYZE TABLE ship_mode WITH SYNC;
+ANALYZE TABLE store_returns WITH SYNC;
+ANALYZE TABLE store_sales WITH SYNC;
+ANALYZE TABLE store WITH SYNC;
+ANALYZE TABLE time_dim WITH SYNC;
+ANALYZE TABLE warehouse WITH SYNC;
+ANALYZE TABLE web_page WITH SYNC;
+ANALYZE TABLE web_returns WITH SYNC;
+ANALYZE TABLE web_sales WITH SYNC;
+ANALYZE TABLE web_site WITH SYNC;