jprdonnelly/impala
1
0
Fork 0
mirror of https://github.com/apache/impala.git synced 2025-12-19 18:12:08 -05:00
Code Issues Projects Releases Wiki Activity
Files
master
impala/docker/quickstart_client/load_tpcds_parquet.sql
Riza Suminto 2f5aef64a5 IMPALA-13617: Rename c_last_review_date to c_last_review_date_sk 
TPC-DS v2.11.0, section 2.4.7, rename column customer.c_last_review_date
to customer.c_last_review_date_sk to align with other surrogate key
columns. impala-tpcds-kit has been modified to reflect this column name
change in
086d7113c8
However, the tpcds dataset schema in Impala test data remains unchanged.

This patch did such a rename to align closer to TPC-DS v2.11.0. This
patch contains no data type adjustment because such adjustment requires
larger changes.

customer_multiblock_page_index.parquet added by IMPALA-10310 is
regenerated to follow the new schema of table customer. The SQL used to
create the file is ordered more specifically over both
c_current_cdemo_sk and c_customer_sk columns. The associated test
assertion in parquet-page-index.test is also updated.

A workaround in test_file_parser.py added by IMPALA-13543 is now removed
after this change is applied.

Testing:
- Pass core tests.

Change-Id: Ie446b3c534cb8f6f54265cd9b2f705cad91dd4ac
Reviewed-on: http://gerrit.cloudera.org:8080/22223
Reviewed-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com>
Tested-by: Impala Public Jenkins <impala-public-jenkins@cloudera.com>
2024-12-20 06:20:37 +00:00

1249 lines
35 KiB
SQL
Raw Permalink Blame History

---- Licensed to the Apache Software Foundation (ASF) under one
---- or more contributor license agreements. See the NOTICE file
---- distributed with this work for additional information
---- regarding copyright ownership. The ASF licenses this file
---- to you under the Apache License, Version 2.0 (the
---- "License"); you may not use this file except in compliance
---- with the License. You may obtain a copy of the License at
----
---- http://www.apache.org/licenses/LICENSE-2.0
----
---- Unless required by applicable law or agreed to in writing,
---- software distributed under the License is distributed on an
---- "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
---- KIND, either express or implied. See the License for the
---- specific language governing permissions and limitations
---- under the License.
-- Create text tables on top of raw text data.
CREATE DATABASE IF NOT EXISTS tpcds_raw;
DROP TABLE IF EXISTS tpcds_raw.call_center;
DROP TABLE IF EXISTS tpcds_raw.catalog_page;
DROP TABLE IF EXISTS tpcds_raw.catalog_returns;
DROP TABLE IF EXISTS tpcds_raw.catalog_sales;
DROP TABLE IF EXISTS tpcds_raw.customer;
DROP TABLE IF EXISTS tpcds_raw.customer_address;
DROP TABLE IF EXISTS tpcds_raw.customer_demographics;
DROP TABLE IF EXISTS tpcds_raw.date_dim;
DROP TABLE IF EXISTS tpcds_raw.household_demographics;
DROP TABLE IF EXISTS tpcds_raw.income_band;
DROP TABLE IF EXISTS tpcds_raw.inventory;
DROP TABLE IF EXISTS tpcds_raw.item;
DROP TABLE IF EXISTS tpcds_raw.promotion;
DROP TABLE IF EXISTS tpcds_raw.ship_mode;
DROP TABLE IF EXISTS tpcds_raw.store;
DROP TABLE IF EXISTS tpcds_raw.store_returns;
DROP TABLE IF EXISTS tpcds_raw.store_sales;
DROP TABLE IF EXISTS tpcds_raw.time_dim;
DROP TABLE IF EXISTS tpcds_raw.warehouse;
DROP TABLE IF EXISTS tpcds_raw.web_page;
DROP TABLE IF EXISTS tpcds_raw.web_returns;
DROP TABLE IF EXISTS tpcds_raw.web_sales;
DROP TABLE IF EXISTS tpcds_raw.web_site;
CREATE EXTERNAL TABLE tpcds_raw.call_center (
cc_call_center_sk INT,
cc_call_center_id STRING,
cc_rec_start_date STRING,
cc_rec_end_date STRING,
cc_closed_date_sk INT,
cc_open_date_sk INT,
cc_name STRING,
cc_class STRING,
cc_employees INT,
cc_sq_ft INT,
cc_hours STRING,
cc_manager STRING,
cc_mkt_id INT,
cc_mkt_class STRING,
cc_mkt_desc STRING,
cc_market_manager STRING,
cc_division INT,
cc_division_name STRING,
cc_company INT,
cc_company_name STRING,
cc_street_number STRING,
cc_street_name STRING,
cc_street_type STRING,
cc_suite_number STRING,
cc_city STRING,
cc_county STRING,
cc_state STRING,
cc_zip STRING,
cc_country STRING,
cc_gmt_offset DECIMAL(5,2),
cc_tax_percentage DECIMAL(5,2)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/call_center'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.catalog_page (
cp_catalog_page_sk INT,
cp_catalog_page_id STRING,
cp_start_date_sk INT,
cp_end_date_sk INT,
cp_department STRING,
cp_catalog_number INT,
cp_catalog_page_number INT,
cp_description STRING,
cp_type STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/catalog_page'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.catalog_returns (
cr_returned_date_sk INT,
cr_returned_time_sk INT,
cr_item_sk BIGINT,
cr_refunded_customer_sk INT,
cr_refunded_cdemo_sk INT,
cr_refunded_hdemo_sk INT,
cr_refunded_addr_sk INT,
cr_returning_customer_sk INT,
cr_returning_cdemo_sk INT,
cr_returning_hdemo_sk INT,
cr_returning_addr_sk INT,
cr_call_center_sk INT,
cr_catalog_page_sk INT,
cr_ship_mode_sk INT,
cr_warehouse_sk INT,
cr_reason_sk INT,
cr_order_number BIGINT,
cr_return_quantity INT,
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)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/catalog_returns'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.catalog_sales (
cs_sold_date_sk INT,
cs_sold_time_sk INT,
cs_ship_date_sk INT,
cs_bill_customer_sk INT,
cs_bill_cdemo_sk INT,
cs_bill_hdemo_sk INT,
cs_bill_addr_sk INT,
cs_ship_customer_sk INT,
cs_ship_cdemo_sk INT,
cs_ship_hdemo_sk INT,
cs_ship_addr_sk INT,
cs_call_center_sk INT,
cs_catalog_page_sk INT,
cs_ship_mode_sk INT,
cs_warehouse_sk INT,
cs_item_sk BIGINT,
cs_promo_sk INT,
cs_order_number BIGINT,
cs_quantity INT,
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)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/catalog_sales'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.customer (
c_customer_sk INT,
c_customer_id STRING,
c_current_cdemo_sk INT,
c_current_hdemo_sk INT,
c_current_addr_sk INT,
c_first_shipto_date_sk INT,
c_first_sales_date_sk INT,
c_salutation STRING,
c_first_name STRING,
c_last_name STRING,
c_preferred_cust_flag STRING,
c_birth_day INT,
c_birth_month INT,
c_birth_year INT,
c_birth_country STRING,
c_login STRING,
c_email_address STRING,
c_last_review_date_sk STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/customer'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.customer_address (
ca_address_sk INT,
ca_address_id STRING,
ca_street_number STRING,
ca_street_name STRING,
ca_street_type STRING,
ca_suite_number STRING,
ca_city STRING,
ca_county STRING,
ca_state STRING,
ca_zip STRING,
ca_country STRING,
ca_gmt_offset DECIMAL(5,2),
ca_location_type STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/customer_address'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.customer_demographics (
cd_demo_sk INT,
cd_gender STRING,
cd_marital_status STRING,
cd_education_status STRING,
cd_purchase_estimate INT,
cd_credit_rating STRING,
cd_dep_count INT,
cd_dep_employed_count INT,
cd_dep_college_count INT
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/customer_demographics'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.date_dim (
d_date_sk INT,
d_date_id STRING,
d_date STRING,
d_month_seq INT,
d_week_seq INT,
d_quarter_seq INT,
d_year INT,
d_dow INT,
d_moy INT,
d_dom INT,
d_qoy INT,
d_fy_year INT,
d_fy_quarter_seq INT,
d_fy_week_seq INT,
d_day_name STRING,
d_quarter_name STRING,
d_holiday STRING,
d_weekend STRING,
d_following_holiday STRING,
d_first_dom INT,
d_last_dom INT,
d_same_day_ly INT,
d_same_day_lq INT,
d_current_day STRING,
d_current_week STRING,
d_current_month STRING,
d_current_quarter STRING,
d_current_year STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/date_dim'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.household_demographics (
hd_demo_sk INT,
hd_income_band_sk INT,
hd_buy_potential STRING,
hd_dep_count INT,
hd_vehicle_count INT
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/household_demographics'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.income_band (
ib_income_band_sk INT,
ib_lower_bound INT,
ib_upper_bound INT
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/income_band'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.inventory (
inv_date_sk INT,
inv_item_sk BIGINT,
inv_warehouse_sk INT,
inv_quantity_on_hand INT
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/inventory'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.item (
i_item_sk BIGINT,
i_item_id STRING,
i_rec_start_date STRING,
i_rec_end_date STRING,
i_item_desc STRING,
i_current_price DECIMAL(7,2),
i_wholesale_cost DECIMAL(7,2),
i_brand_id INT,
i_brand STRING,
i_class_id INT,
i_class STRING,
i_category_id INT,
i_category STRING,
i_manufact_id INT,
i_manufact STRING,
i_size STRING,
i_formulation STRING,
i_color STRING,
i_units STRING,
i_container STRING,
i_manager_id INT,
i_product_name STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/item'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.promotion (
p_promo_sk INT,
p_promo_id STRING,
p_start_date_sk INT,
p_end_date_sk INT,
p_item_sk BIGINT,
p_cost DECIMAL(15,2),
p_response_target INT,
p_promo_name STRING,
p_channel_dmail STRING,
p_channel_email STRING,
p_channel_catalog STRING,
p_channel_tv STRING,
p_channel_radio STRING,
p_channel_press STRING,
p_channel_event STRING,
p_channel_demo STRING,
p_channel_details STRING,
p_purpose STRING,
p_discount_active STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/promotion'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.ship_mode (
sm_ship_mode_sk INT,
sm_ship_mode_id STRING,
sm_type STRING,
sm_code STRING,
sm_carrier STRING,
sm_contract STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/ship_mode'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.store (
s_store_sk INT,
s_store_id STRING,
s_rec_start_date STRING,
s_rec_end_date STRING,
s_closed_date_sk INT,
s_store_name STRING,
s_number_employees INT,
s_floor_space INT,
s_hours STRING,
s_manager STRING,
s_market_id INT,
s_geography_class STRING,
s_market_desc STRING,
s_market_manager STRING,
s_division_id INT,
s_division_name STRING,
s_company_id INT,
s_company_name STRING,
s_street_number STRING,
s_street_name STRING,
s_street_type STRING,
s_suite_number STRING,
s_city STRING,
s_county STRING,
s_state STRING,
s_zip STRING,
s_country STRING,
s_gmt_offset DECIMAL(5,2),
s_tax_precentage DECIMAL(5,2)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/store'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.store_returns (
sr_returned_date_sk INT,
sr_return_time_sk INT,
sr_item_sk BIGINT,
sr_customer_sk INT,
sr_cdemo_sk INT,
sr_hdemo_sk INT,
sr_addr_sk INT,
sr_store_sk INT,
sr_reason_sk INT,
sr_ticket_number BIGINT,
sr_return_quantity INT,
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)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/store_returns'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.store_sales (
ss_sold_date_sk INT,
ss_sold_time_sk INT,
ss_item_sk BIGINT,
ss_customer_sk INT,
ss_cdemo_sk INT,
ss_hdemo_sk INT,
ss_addr_sk INT,
ss_store_sk INT,
ss_promo_sk INT,
ss_ticket_number BIGINT,
ss_quantity INT,
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)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/store_sales'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.time_dim (
t_time_sk INT,
t_time_id STRING,
t_time INT,
t_hour INT,
t_minute INT,
t_second INT,
t_am_pm STRING,
t_shift STRING,
t_sub_shift STRING,
t_meal_time STRING
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/time_dim'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.warehouse (
w_warehouse_sk INT,
w_warehouse_id STRING,
w_warehouse_name STRING,
w_warehouse_sq_ft INT,
w_street_number STRING,
w_street_name STRING,
w_street_type STRING,
w_suite_number STRING,
w_city STRING,
w_county STRING,
w_state STRING,
w_zip STRING,
w_country STRING,
w_gmt_offset DECIMAL(5,2)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/warehouse'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.web_page (
wp_web_page_sk INT,
wp_web_page_id STRING,
wp_rec_start_date STRING,
wp_rec_end_date STRING,
wp_creation_date_sk INT,
wp_access_date_sk INT,
wp_autogen_flag STRING,
wp_customer_sk INT,
wp_url STRING,
wp_type STRING,
wp_char_count INT,
wp_link_count INT,
wp_image_count INT,
wp_max_ad_count INT
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/web_page'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.web_returns (
wr_returned_date_sk INT,
wr_returned_time_sk INT,
wr_item_sk BIGINT,
wr_refunded_customer_sk INT,
wr_refunded_cdemo_sk INT,
wr_refunded_hdemo_sk INT,
wr_refunded_addr_sk INT,
wr_returning_customer_sk INT,
wr_returning_cdemo_sk INT,
wr_returning_hdemo_sk INT,
wr_returning_addr_sk INT,
wr_web_page_sk INT,
wr_reason_sk INT,
wr_order_number BIGINT,
wr_return_quantity INT,
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)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/web_returns'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.web_sales (
ws_sold_date_sk INT,
ws_sold_time_sk INT,
ws_ship_date_sk INT,
ws_item_sk BIGINT,
ws_bill_customer_sk INT,
ws_bill_cdemo_sk INT,
ws_bill_hdemo_sk INT,
ws_bill_addr_sk INT,
ws_ship_customer_sk INT,
ws_ship_cdemo_sk INT,
ws_ship_hdemo_sk INT,
ws_ship_addr_sk INT,
ws_web_page_sk INT,
ws_web_site_sk INT,
ws_ship_mode_sk INT,
ws_warehouse_sk INT,
ws_promo_sk INT,
ws_order_number BIGINT,
ws_quantity INT,
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)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/web_sales'
TBLPROPERTIES('serialization.null.format'='');
CREATE EXTERNAL TABLE tpcds_raw.web_site (
web_site_sk INT,
web_site_id STRING,
web_rec_start_date STRING,
web_rec_end_date STRING,
web_name STRING,
web_open_date_sk INT,
web_close_date_sk INT,
web_class STRING,
web_manager STRING,
web_mkt_id INT,
web_mkt_class STRING,
web_mkt_desc STRING,
web_market_manager STRING,
web_company_id INT,
web_company_name STRING,
web_street_number STRING,
web_street_name STRING,
web_street_type STRING,
web_suite_number STRING,
web_city STRING,
web_county STRING,
web_state STRING,
web_zip STRING,
web_country STRING,
web_gmt_offset DECIMAL(5,2),
web_tax_percentage DECIMAL(5,2)
)
ROW FORMAT DELIMITED FIELDS TERMINATED BY '|'
WITH SERDEPROPERTIES ('field.delim'='|', 'serialization.format'='|')
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/external/tpcds_raw/web_site'
TBLPROPERTIES('serialization.null.format'='');
-- Compute stats on all the tables for optimal performance.
COMPUTE STATS tpcds_raw.call_center;
COMPUTE STATS tpcds_raw.catalog_page;
COMPUTE STATS tpcds_raw.catalog_returns;
COMPUTE STATS tpcds_raw.catalog_sales;
COMPUTE STATS tpcds_raw.customer;
COMPUTE STATS tpcds_raw.customer_address;
COMPUTE STATS tpcds_raw.customer_demographics;
COMPUTE STATS tpcds_raw.date_dim;
COMPUTE STATS tpcds_raw.household_demographics;
COMPUTE STATS tpcds_raw.income_band;
COMPUTE STATS tpcds_raw.inventory;
COMPUTE STATS tpcds_raw.item;
COMPUTE STATS tpcds_raw.promotion;
COMPUTE STATS tpcds_raw.ship_mode;
COMPUTE STATS tpcds_raw.store;
COMPUTE STATS tpcds_raw.store_returns;
COMPUTE STATS tpcds_raw.store_sales;
COMPUTE STATS tpcds_raw.time_dim;
COMPUTE STATS tpcds_raw.warehouse;
COMPUTE STATS tpcds_raw.web_page;
COMPUTE STATS tpcds_raw.web_returns;
COMPUTE STATS tpcds_raw.web_sales;
COMPUTE STATS tpcds_raw.web_site;
-- Create Parquet tables based on text tables.
CREATE DATABASE IF NOT EXISTS tpcds_parquet;
DROP TABLE IF EXISTS tpcds_parquet.call_center;
DROP TABLE IF EXISTS tpcds_parquet.catalog_page;
DROP TABLE IF EXISTS tpcds_parquet.catalog_returns;
DROP TABLE IF EXISTS tpcds_parquet.catalog_sales;
DROP TABLE IF EXISTS tpcds_parquet.customer;
DROP TABLE IF EXISTS tpcds_parquet.customer_address;
DROP TABLE IF EXISTS tpcds_parquet.customer_demographics;
DROP TABLE IF EXISTS tpcds_parquet.date_dim;
DROP TABLE IF EXISTS tpcds_parquet.household_demographics;
DROP TABLE IF EXISTS tpcds_parquet.income_band;
DROP TABLE IF EXISTS tpcds_parquet.inventory;
DROP TABLE IF EXISTS tpcds_parquet.item;
DROP TABLE IF EXISTS tpcds_parquet.promotion;
DROP TABLE IF EXISTS tpcds_parquet.ship_mode;
DROP TABLE IF EXISTS tpcds_parquet.store;
DROP TABLE IF EXISTS tpcds_parquet.store_returns;
DROP TABLE IF EXISTS tpcds_parquet.store_sales;
DROP TABLE IF EXISTS tpcds_parquet.time_dim;
DROP TABLE IF EXISTS tpcds_parquet.warehouse;
DROP TABLE IF EXISTS tpcds_parquet.web_page;
DROP TABLE IF EXISTS tpcds_parquet.web_returns;
DROP TABLE IF EXISTS tpcds_parquet.web_sales;
DROP TABLE IF EXISTS tpcds_parquet.web_site;
-- TODO: add sort by hints for better clustering.
CREATE TABLE tpcds_parquet.call_center (
cc_call_center_sk INT,
cc_call_center_id STRING,
cc_rec_start_date STRING,
cc_rec_end_date STRING,
cc_closed_date_sk INT,
cc_open_date_sk INT,
cc_name STRING,
cc_class STRING,
cc_employees INT,
cc_sq_ft INT,
cc_hours STRING,
cc_manager STRING,
cc_mkt_id INT,
cc_mkt_class STRING,
cc_mkt_desc STRING,
cc_market_manager STRING,
cc_division INT,
cc_division_name STRING,
cc_company INT,
cc_company_name STRING,
cc_street_number STRING,
cc_street_name STRING,
cc_street_type STRING,
cc_suite_number STRING,
cc_city STRING,
cc_county STRING,
cc_state STRING,
cc_zip STRING,
cc_country STRING,
cc_gmt_offset DECIMAL(5,2),
cc_tax_percentage DECIMAL(5,2)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.catalog_page (
cp_catalog_page_sk INT,
cp_catalog_page_id STRING,
cp_start_date_sk INT,
cp_end_date_sk INT,
cp_department STRING,
cp_catalog_number INT,
cp_catalog_page_number INT,
cp_description STRING,
cp_type STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.catalog_returns (
cr_returned_date_sk INT,
cr_returned_time_sk INT,
cr_item_sk BIGINT,
cr_refunded_customer_sk INT,
cr_refunded_cdemo_sk INT,
cr_refunded_hdemo_sk INT,
cr_refunded_addr_sk INT,
cr_returning_customer_sk INT,
cr_returning_cdemo_sk INT,
cr_returning_hdemo_sk INT,
cr_returning_addr_sk INT,
cr_call_center_sk INT,
cr_catalog_page_sk INT,
cr_ship_mode_sk INT,
cr_warehouse_sk INT,
cr_reason_sk INT,
cr_order_number BIGINT,
cr_return_quantity INT,
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)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.catalog_sales (
cs_sold_date_sk INT,
cs_sold_time_sk INT,
cs_ship_date_sk INT,
cs_bill_customer_sk INT,
cs_bill_cdemo_sk INT,
cs_bill_hdemo_sk INT,
cs_bill_addr_sk INT,
cs_ship_customer_sk INT,
cs_ship_cdemo_sk INT,
cs_ship_hdemo_sk INT,
cs_ship_addr_sk INT,
cs_call_center_sk INT,
cs_catalog_page_sk INT,
cs_ship_mode_sk INT,
cs_warehouse_sk INT,
cs_item_sk BIGINT,
cs_promo_sk INT,
cs_order_number BIGINT,
cs_quantity INT,
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)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.customer (
c_customer_sk INT,
c_customer_id STRING,
c_current_cdemo_sk INT,
c_current_hdemo_sk INT,
c_current_addr_sk INT,
c_first_shipto_date_sk INT,
c_first_sales_date_sk INT,
c_salutation STRING,
c_first_name STRING,
c_last_name STRING,
c_preferred_cust_flag STRING,
c_birth_day INT,
c_birth_month INT,
c_birth_year INT,
c_birth_country STRING,
c_login STRING,
c_email_address STRING,
c_last_review_date_sk STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.customer_address (
ca_address_sk INT,
ca_address_id STRING,
ca_street_number STRING,
ca_street_name STRING,
ca_street_type STRING,
ca_suite_number STRING,
ca_city STRING,
ca_county STRING,
ca_state STRING,
ca_zip STRING,
ca_country STRING,
ca_gmt_offset DECIMAL(5,2),
ca_location_type STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.customer_demographics (
cd_demo_sk INT,
cd_gender STRING,
cd_marital_status STRING,
cd_education_status STRING,
cd_purchase_estimate INT,
cd_credit_rating STRING,
cd_dep_count INT,
cd_dep_employed_count INT,
cd_dep_college_count INT
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.date_dim (
d_date_sk INT,
d_date_id STRING,
d_date STRING,
d_month_seq INT,
d_week_seq INT,
d_quarter_seq INT,
d_year INT,
d_dow INT,
d_moy INT,
d_dom INT,
d_qoy INT,
d_fy_year INT,
d_fy_quarter_seq INT,
d_fy_week_seq INT,
d_day_name STRING,
d_quarter_name STRING,
d_holiday STRING,
d_weekend STRING,
d_following_holiday STRING,
d_first_dom INT,
d_last_dom INT,
d_same_day_ly INT,
d_same_day_lq INT,
d_current_day STRING,
d_current_week STRING,
d_current_month STRING,
d_current_quarter STRING,
d_current_year STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.household_demographics (
hd_demo_sk INT,
hd_income_band_sk INT,
hd_buy_potential STRING,
hd_dep_count INT,
hd_vehicle_count INT
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.income_band (
ib_income_band_sk INT,
ib_lower_bound INT,
ib_upper_bound INT
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.inventory (
inv_date_sk INT,
inv_item_sk BIGINT,
inv_warehouse_sk INT,
inv_quantity_on_hand INT
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.item (
i_item_sk BIGINT,
i_item_id STRING,
i_rec_start_date STRING,
i_rec_end_date STRING,
i_item_desc STRING,
i_current_price DECIMAL(7,2),
i_wholesale_cost DECIMAL(7,2),
i_brand_id INT,
i_brand STRING,
i_class_id INT,
i_class STRING,
i_category_id INT,
i_category STRING,
i_manufact_id INT,
i_manufact STRING,
i_size STRING,
i_formulation STRING,
i_color STRING,
i_units STRING,
i_container STRING,
i_manager_id INT,
i_product_name STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.promotion (
p_promo_sk INT,
p_promo_id STRING,
p_start_date_sk INT,
p_end_date_sk INT,
p_item_sk BIGINT,
p_cost DECIMAL(15,2),
p_response_target INT,
p_promo_name STRING,
p_channel_dmail STRING,
p_channel_email STRING,
p_channel_catalog STRING,
p_channel_tv STRING,
p_channel_radio STRING,
p_channel_press STRING,
p_channel_event STRING,
p_channel_demo STRING,
p_channel_details STRING,
p_purpose STRING,
p_discount_active STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.ship_mode (
sm_ship_mode_sk INT,
sm_ship_mode_id STRING,
sm_type STRING,
sm_code STRING,
sm_carrier STRING,
sm_contract STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.store (
s_store_sk INT,
s_store_id STRING,
s_rec_start_date STRING,
s_rec_end_date STRING,
s_closed_date_sk INT,
s_store_name STRING,
s_number_employees INT,
s_floor_space INT,
s_hours STRING,
s_manager STRING,
s_market_id INT,
s_geography_class STRING,
s_market_desc STRING,
s_market_manager STRING,
s_division_id INT,
s_division_name STRING,
s_company_id INT,
s_company_name STRING,
s_street_number STRING,
s_street_name STRING,
s_street_type STRING,
s_suite_number STRING,
s_city STRING,
s_county STRING,
s_state STRING,
s_zip STRING,
s_country STRING,
s_gmt_offset DECIMAL(5,2),
s_tax_precentage DECIMAL(5,2)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.store_returns (
sr_returned_date_sk INT,
sr_return_time_sk INT,
sr_item_sk BIGINT,
sr_customer_sk INT,
sr_cdemo_sk INT,
sr_hdemo_sk INT,
sr_addr_sk INT,
sr_store_sk INT,
sr_reason_sk INT,
sr_ticket_number BIGINT,
sr_return_quantity INT,
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)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.store_sales (
ss_sold_time_sk INT,
ss_item_sk BIGINT,
ss_customer_sk INT,
ss_cdemo_sk INT,
ss_hdemo_sk INT,
ss_addr_sk INT,
ss_store_sk INT,
ss_promo_sk INT,
ss_ticket_number BIGINT,
ss_quantity INT,
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)
)
PARTITIONED BY (
ss_sold_date_sk INT
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.time_dim (
t_time_sk INT,
t_time_id STRING,
t_time INT,
t_hour INT,
t_minute INT,
t_second INT,
t_am_pm STRING,
t_shift STRING,
t_sub_shift STRING,
t_meal_time STRING
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.warehouse (
w_warehouse_sk INT,
w_warehouse_id STRING,
w_warehouse_name STRING,
w_warehouse_sq_ft INT,
w_street_number STRING,
w_street_name STRING,
w_street_type STRING,
w_suite_number STRING,
w_city STRING,
w_county STRING,
w_state STRING,
w_zip STRING,
w_country STRING,
w_gmt_offset DECIMAL(5,2)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.web_page (
wp_web_page_sk INT,
wp_web_page_id STRING,
wp_rec_start_date STRING,
wp_rec_end_date STRING,
wp_creation_date_sk INT,
wp_access_date_sk INT,
wp_autogen_flag STRING,
wp_customer_sk INT,
wp_url STRING,
wp_type STRING,
wp_char_count INT,
wp_link_count INT,
wp_image_count INT,
wp_max_ad_count INT
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.web_returns (
wr_returned_date_sk INT,
wr_returned_time_sk INT,
wr_item_sk BIGINT,
wr_refunded_customer_sk INT,
wr_refunded_cdemo_sk INT,
wr_refunded_hdemo_sk INT,
wr_refunded_addr_sk INT,
wr_returning_customer_sk INT,
wr_returning_cdemo_sk INT,
wr_returning_hdemo_sk INT,
wr_returning_addr_sk INT,
wr_web_page_sk INT,
wr_reason_sk INT,
wr_order_number BIGINT,
wr_return_quantity INT,
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)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.web_sales (
ws_sold_date_sk INT,
ws_sold_time_sk INT,
ws_ship_date_sk INT,
ws_item_sk BIGINT,
ws_bill_customer_sk INT,
ws_bill_cdemo_sk INT,
ws_bill_hdemo_sk INT,
ws_bill_addr_sk INT,
ws_ship_customer_sk INT,
ws_ship_cdemo_sk INT,
ws_ship_hdemo_sk INT,
ws_ship_addr_sk INT,
ws_web_page_sk INT,
ws_web_site_sk INT,
ws_ship_mode_sk INT,
ws_warehouse_sk INT,
ws_promo_sk INT,
ws_order_number BIGINT,
ws_quantity INT,
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)
)
STORED AS PARQUET;
CREATE TABLE tpcds_parquet.web_site (
web_site_sk INT,
web_site_id STRING,
web_rec_start_date STRING,
web_rec_end_date STRING,
web_name STRING,
web_open_date_sk INT,
web_close_date_sk INT,
web_class STRING,
web_manager STRING,
web_mkt_id INT,
web_mkt_class STRING,
web_mkt_desc STRING,
web_market_manager STRING,
web_company_id INT,
web_company_name STRING,
web_street_number STRING,
web_street_name STRING,
web_street_type STRING,
web_suite_number STRING,
web_city STRING,
web_county STRING,
web_state STRING,
web_zip STRING,
web_country STRING,
web_gmt_offset DECIMAL(5,2),
web_tax_percentage DECIMAL(5,2)
)
STORED AS PARQUET;
INSERT INTO tpcds_parquet.call_center SELECT * FROM tpcds_raw.call_center;
INSERT INTO tpcds_parquet.catalog_page SELECT * FROM tpcds_raw.catalog_page;
INSERT INTO tpcds_parquet.catalog_returns SELECT * FROM tpcds_raw.catalog_returns;
INSERT INTO tpcds_parquet.catalog_sales SELECT * FROM tpcds_raw.catalog_sales;
INSERT INTO tpcds_parquet.customer SELECT * FROM tpcds_raw.customer;
INSERT INTO tpcds_parquet.customer_address SELECT * FROM tpcds_raw.customer_address;
INSERT INTO tpcds_parquet.customer_demographics SELECT * FROM tpcds_raw.customer_demographics;
INSERT INTO tpcds_parquet.date_dim SELECT * FROM tpcds_raw.date_dim;
INSERT INTO tpcds_parquet.household_demographics SELECT * FROM tpcds_raw.household_demographics;
INSERT INTO tpcds_parquet.income_band SELECT * FROM tpcds_raw.income_band;
INSERT INTO tpcds_parquet.inventory SELECT * FROM tpcds_raw.inventory;
INSERT INTO tpcds_parquet.item SELECT * FROM tpcds_raw.item;
INSERT INTO tpcds_parquet.promotion SELECT * FROM tpcds_raw.promotion;
INSERT INTO tpcds_parquet.ship_mode SELECT * FROM tpcds_raw.ship_mode;
INSERT INTO tpcds_parquet.store SELECT * FROM tpcds_raw.store;
INSERT INTO tpcds_parquet.store_returns SELECT * FROM tpcds_raw.store_returns;
INSERT INTO tpcds_parquet.time_dim SELECT * FROM tpcds_raw.time_dim;
INSERT INTO tpcds_parquet.warehouse SELECT * FROM tpcds_raw.warehouse;
INSERT INTO tpcds_parquet.web_page SELECT * FROM tpcds_raw.web_page;
INSERT INTO tpcds_parquet.web_returns SELECT * FROM tpcds_raw.web_returns;
INSERT INTO tpcds_parquet.web_sales SELECT * FROM tpcds_raw.web_sales;
INSERT INTO tpcds_parquet.web_site SELECT * FROM tpcds_raw.web_site;
INSERT INTO tpcds_parquet.store_sales PARTITION(ss_sold_date_sk)
SELECT 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,
ss_sold_date_sk
FROM tpcds_raw.store_sales;
-- Compute stats on all the tables for optimal performance.
COMPUTE STATS tpcds_parquet.call_center;
COMPUTE STATS tpcds_parquet.catalog_page;
COMPUTE STATS tpcds_parquet.catalog_returns;
COMPUTE STATS tpcds_parquet.catalog_sales;
COMPUTE STATS tpcds_parquet.customer;
COMPUTE STATS tpcds_parquet.customer_address;
COMPUTE STATS tpcds_parquet.customer_demographics;
COMPUTE STATS tpcds_parquet.date_dim;
COMPUTE STATS tpcds_parquet.household_demographics;
COMPUTE STATS tpcds_parquet.income_band;
COMPUTE STATS tpcds_parquet.inventory;
COMPUTE STATS tpcds_parquet.item;
COMPUTE STATS tpcds_parquet.promotion;
COMPUTE STATS tpcds_parquet.ship_mode;
COMPUTE STATS tpcds_parquet.store;
COMPUTE STATS tpcds_parquet.store_returns;
COMPUTE STATS tpcds_parquet.store_sales;
COMPUTE STATS tpcds_parquet.time_dim;
COMPUTE STATS tpcds_parquet.warehouse;
COMPUTE STATS tpcds_parquet.web_page;
COMPUTE STATS tpcds_parquet.web_returns;
COMPUTE STATS tpcds_parquet.web_sales;
COMPUTE STATS tpcds_parquet.web_site;
Reference in New Issue View Git Blame Copy Permalink