Skip to content

queries for perf team #74

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Draft
FelixYBW wants to merge 1 commit into
base: tpc-queries-for-spark
Choose a base branch
from
+10 −55
Draft

queries for perf team #74

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
14 changes: 1 addition & 13 deletions benchmarks/tpc-ds/queries/q14b.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -37,19 +37,7 @@
select ws_quantity quantity, ws_list_price list_price
from web_sales, date_dim
where ws_sold_date_sk = d_date_sk and d_year between 1999 and 1999 + 2) x)
select this_year.channel ty_channel
,this_year.i_brand_id ty_brand
,this_year.i_class_id ty_class
,this_year.i_category_id ty_category
,this_year.sales ty_sales
,this_year.number_sales ty_number_sales
,last_year.channel ly_channel
,last_year.i_brand_id ly_brand
,last_year.i_class_id ly_class
,last_year.i_category_id ly_category
,last_year.sales ly_sales
,last_year.number_sales ly_number_sales
from
select * from
(select 'store' channel, i_brand_id,i_class_id,i_category_id
,sum(ss_quantity*ss_list_price) sales, count(*) number_sales
from store_sales, item, date_dim
Expand Down
12 changes: 2 additions & 10 deletions benchmarks/tpc-ds/queries/q39a.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,16 +12,8 @@
and d_year = 2001
group by w_warehouse_name,w_warehouse_sk,i_item_sk,d_moy) foo
where case mean when 0 then 0 else stdev/mean end > 1)
select inv1.w_warehouse_sk as inv1_w_warehouse_sk,
inv1.i_item_sk as inv1_i_item_sk,
inv1.d_moy as inv1_d_moy ,
inv1.mean as inv1_mean,
inv1.cov as inv1_cov,
inv2.w_warehouse_sk as inv2_w_warehouse_sk,
inv2.i_item_sk as inv2_i_item_sk,
inv2.d_moy as inv2_d_moy,
inv2.mean as inv2_mean,
inv2.cov as inv2_cov
select inv1.w_warehouse_sk,inv1.i_item_sk,inv1.d_moy,inv1.mean, inv1.cov
,inv2.w_warehouse_sk,inv2.i_item_sk,inv2.d_moy,inv2.mean, inv2.cov
from inv inv1,inv inv2
where inv1.i_item_sk = inv2.i_item_sk
and inv1.w_warehouse_sk = inv2.w_warehouse_sk
Expand Down
12 changes: 2 additions & 10 deletions benchmarks/tpc-ds/queries/q39b.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -12,16 +12,8 @@
and d_year = 2001
group by w_warehouse_name,w_warehouse_sk,i_item_sk,d_moy) foo
where case mean when 0 then 0 else stdev/mean end > 1)
select inv1.w_warehouse_sk as inv1_w_warehouse_sk,
inv1.i_item_sk as inv1_i_item_sk,
inv1.d_moy as inv1_d_moy ,
inv1.mean as inv1_mean,
inv1.cov as inv1_cov,
inv2.w_warehouse_sk as inv2_w_warehouse_sk,
inv2.i_item_sk as inv2_i_item_sk,
inv2.d_moy as inv2_d_moy,
inv2.mean as inv2_mean,
inv2.cov as inv2_cov
select inv1.w_warehouse_sk,inv1.i_item_sk,inv1.d_moy,inv1.mean, inv1.cov
,inv2.w_warehouse_sk,inv2.i_item_sk,inv2.d_moy,inv2.mean, inv2.cov
from inv inv1,inv inv2
where inv1.i_item_sk = inv2.i_item_sk
and inv1.w_warehouse_sk = inv2.w_warehouse_sk
Expand Down
27 changes: 5 additions & 22 deletions benchmarks/tpc-ds/queries/q64.sql
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@
having sum(cs_ext_list_price)>2*sum(cr_refunded_cash+cr_reversed_charge+cr_store_credit)),
cross_sales as
(select i_product_name product_name, i_item_sk item_sk, s_store_name store_name, s_zip store_zip,
ad1.ca_street_number b_street_number, ad1.ca_street_name b_street_name, ad1.ca_city b_city,
ad1.ca_street_number b_street_number, ad1.ca_street_name b_streen_name, ad1.ca_city b_city,
ad1.ca_zip b_zip, ad2.ca_street_number c_street_number, ad2.ca_street_name c_street_name,
ad2.ca_city c_city, ad2.ca_zip c_zip, d1.d_year as syear, d2.d_year as fsyear, d3.d_year s2year,
count(*) cnt, sum(ss_wholesale_cost) s1, sum(ss_list_price) s2, sum(ss_coupon_amt) s3
Expand Down Expand Up @@ -45,27 +45,10 @@
ad1.ca_street_name, ad1.ca_city, ad1.ca_zip, ad2.ca_street_number,
ad2.ca_street_name, ad2.ca_city, ad2.ca_zip, d1.d_year, d2.d_year, d3.d_year
)
select cs1.product_name
,cs1.store_name
,cs1.store_zip
,cs1.b_street_number
,cs1.b_street_name
,cs1.b_city
,cs1.b_zip
,cs1.c_street_number
,cs1.c_street_name
,cs1.c_city
,cs1.c_zip
,cs1.syear
,cs1.cnt
,cs1.s1 as s11
,cs1.s2 as s21
,cs1.s3 as s31
,cs2.s1 as s12
,cs2.s2 as s22
,cs2.s3 as s32
,cs2.syear as cs2_syear
,cs2.cnt as cs2_cnt
select cs1.product_name, cs1.store_name, cs1.store_zip, cs1.b_street_number,
cs1.b_streen_name, cs1.b_city, cs1.b_zip, cs1.c_street_number, cs1.c_street_name,
cs1.c_city, cs1.c_zip, cs1.syear, cs1.cnt, cs1.s1, cs1.s2, cs1.s3, cs2.s1,
cs2.s2, cs2.s3, cs2.syear, cs2.cnt
from cross_sales cs1,cross_sales cs2
where cs1.item_sk=cs2.item_sk and
cs1.syear = 1999 and
Expand Down