Details
-
Bug
-
Status: Resolved
-
Blocker
-
Resolution: Fixed
-
1.16.0
Description
TPCDS query 64 has slowed by 90% compared to Drill 1.15. The primary reason is due to hash join re-ordering. Here is the query:
WITH cs_ui
AS (SELECT cs_item_sk,
Sum(cs_ext_list_price) AS sale,
Sum(cr_refunded_cash + cr_reversed_charge
+ cr_store_credit) AS refund
FROM catalog_sales,
catalog_returns
WHERE cs_item_sk = cr_item_sk
AND cs_order_number = cr_order_number
GROUP BY cs_item_sk
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_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
FROM store_sales,
store_returns,
cs_ui,
date_dim d1,
date_dim d2,
date_dim d3,
store,
customer,
customer_demographics cd1,
customer_demographics cd2,
promotion,
household_demographics hd1,
household_demographics hd2,
customer_address ad1,
customer_address ad2,
income_band ib1,
income_band ib2,
item
WHERE ss_store_sk = s_store_sk
AND ss_sold_date_sk = d1.d_date_sk
AND ss_customer_sk = c_customer_sk
AND ss_cdemo_sk = cd1.cd_demo_sk
AND ss_hdemo_sk = hd1.hd_demo_sk
AND ss_addr_sk = ad1.ca_address_sk
AND ss_item_sk = i_item_sk
AND ss_item_sk = sr_item_sk
AND ss_ticket_number = sr_ticket_number
AND ss_item_sk = cs_ui.cs_item_sk
AND c_current_cdemo_sk = cd2.cd_demo_sk
AND c_current_hdemo_sk = hd2.hd_demo_sk
AND c_current_addr_sk = ad2.ca_address_sk
AND c_first_sales_date_sk = d2.d_date_sk
AND c_first_shipto_date_sk = d3.d_date_sk
AND ss_promo_sk = p_promo_sk
AND hd1.hd_income_band_sk = ib1.ib_income_band_sk
AND hd2.hd_income_band_sk = ib2.ib_income_band_sk
AND cd1.cd_marital_status <> cd2.cd_marital_status
AND i_color IN ( 'cyan', 'peach', 'blush', 'frosted',
'powder', 'orange' )
AND i_current_price BETWEEN 58 AND 58 + 10
AND i_current_price BETWEEN 58 + 1 AND 58 + 15
GROUP BY i_product_name,
i_item_sk,
s_store_name,
s_zip,
ad1.ca_street_number,
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_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 = 2001
AND cs2.syear = 2001 + 1
AND cs2.cnt <= cs1.cnt
AND cs1.store_name = cs2.store_name
AND cs1.store_zip = cs2.store_zip
ORDER BY cs1.product_name,
cs1.store_name,
cs2.cnt;
Here is the original plan from Drill 1.15:
00-00 Screen : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1086998270084973E11 rows, 2.1961609861354004E12 cpu, 8.0634270768E10 io, 9.274990858311476E14 network, 5.2478684959060406E11 memory}, id = 200364
00-01 Project(product_name=[$0], store_name=[$1], store_zip=[$2], b_street_number=[$3], b_streen_name=[$4], b_city=[$5], b_zip=[$6], c_street_number=[$7], c_street_name=[$8], c_city=[$9], c_zip=[$10], syear=[$11], cnt=[$12], s1=[$13], s2=[$14], s3=[$15], s10=[$16], s20=[$17], s30=[$18], syear0=[$19], cnt0=[$20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1086926270384998E11 rows, 2.1961602661384006E12 cpu, 8.0634270768E10 io, 9.274990858311476E14 network, 5.2478684959060406E11 memory}, id = 200363
00-02 SingleMergeExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1086206273385248E11 rows, 2.1960090667684531E12 cpu, 8.0634270768E10 io, 9.274990858311476E14 network, 5.2478684959060406E11 memory}, id = 200362
01-01 OrderedMuxExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1085486276385498E11 rows, 2.195855795878005E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2478684959060406E11 memory}, id = 200361
02-01 SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1084766279385748E11 rows, 2.1958485959080073E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2478684959060406E11 memory}, id = 200360
02-02 Sort(sort0=[$0], sort1=[$1], sort2=[$20], dir0=[ASC], dir1=[ASC], dir2=[ASC]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1084046282385999E11 rows, 2.1958413959380098E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2478684959060406E11 memory}, id = 200359
02-03 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$20]]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1083326285386249E11 rows, 2.1938732502016333E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2357725463102405E11 memory}, id = 200358
03-01 Project(product_name=[$0], store_name=[$2], store_zip=[$3], b_street_number=[$4], b_streen_name=[$5], b_city=[$6], b_zip=[$7], c_street_number=[$8], c_street_name=[$9], c_city=[$10], c_zip=[$11], syear=[$12], cnt=[$15], s1=[$16], s2=[$17], s3=[$18], s10=[$35], s20=[$36], s30=[$37], syear0=[$31], cnt0=[$34]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1082606288386499E11 rows, 2.19379645052166E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200357
03-02 SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.108188629138675E11 rows, 2.1936452511517124E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200356
03-03 Filter(condition=[<=($34, $15)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.1081166294387E11 rows, 2.1936380511817148E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200355
03-04 HashJoin(condition=[AND(AND(=($1, $20), =($2, $21)), =($3, $22))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {1.10797263003875E11 rows, 2.1935516515417449E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200354
03-05 Project(product_name0=[$0], item_sk0=[$1], store_name0=[$2], store_zip0=[$3], b_street_number0=[$4], b_streen_name0=[$5], b_city0=[$6], b_zip0=[$7], c_street_number0=[$8], c_street_name0=[$9], c_city0=[$10], c_zip0=[$11], syear0=[$12], fsyear0=[$13], s2year0=[$14], cnt0=[$15], s10=[$16], s20=[$17], s30=[$18]) : rowType = RecordType(ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {5.539143153194E10 rows, 1.096480627000975E12 cpu, 4.0317135384E10 io, 4.631302302962688E14 network, 2.615351883716E11 memory}, id = 200353
03-07 HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.5377031591945E10 rows, 1.09620702814107E12 cpu, 4.0317135384E10 io, 4.631302302962688E14 network, 2.615351883716E11 memory}, id = 200352
05-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.536263165195E10 rows, 1.0960534287811233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.615351883716E11 memory}, id = 200351
05-02 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.5218632252E10 rows, 1.0718615295895233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.4126007285864E11 memory}, id = 200350
07-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.507463285205E10 rows, 1.07063273470995E12 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 2.4126007285864E11 memory}, id = 200349
07-02 Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 8.2871374279395E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200348
07-03 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.219464485305E10 rows, 8.0279385080295E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200347
07-04 HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.075465085355E10 rows, 7.2359418083045E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200346
07-06 HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {4.929065685405E10 rows, 7.0615825283645E11 cpu, 4.0287135384E10 io, 4.496847520643891E14 network, 3.840331772904E10 memory}, id = 200342
07-09 HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {4.783266285455E10 rows, 6.8875232484245E11 cpu, 4.0257135384E10 io, 4.485665440643891E14 network, 3.829771772904E10 memory}, id = 200339
07-11 HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.639201823005E10 rows, 6.7146911747345E11 cpu, 4.0255935384E10 io, 4.485640280963891E14 network, 3.829742072904E10 memory}, id = 200334
07-13 HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.495198819055E10 rows, 6.5418895169945E11 cpu, 4.0255920964E10 io, 4.485632229866291E14 network, 3.829729365704E10 memory}, id = 200328
07-16 HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.351196535105E10 rows, 6.3690880752545E11 cpu, 4.0255906544E10 io, 4.485624178768691E14 network, 3.829716658504E10 memory}, id = 200323
07-18 SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.207196685155E10 rows, 6.1962885403145E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200320
07-19 Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.063197285205E10 rows, 6.1818886003195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200319
07-20 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$14], d_date_sk=[$12], d_year=[$13], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 6.0090893203795E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200318
07-21 HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.487199685405E10 rows, 5.0298934007195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200317
07-23 HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.6745613382195E11 cpu, 4.0179771248E10 io, 4.478184565078835E14 network, 3.804956278024E10 memory}, id = 200303
16-01 HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {2.902174711305E10 rows, 4.2137632583795E11 cpu, 4.0179771248E10 io, 1.882969779419955E14 network, 3.804956278024E10 memory}, id = 200302
16-03 HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.614175610805E10 rows, 3.8681645081195E11 cpu, 4.0179768242E10 io, 1.882968658975539E14 network, 3.804954514504E10 memory}, id = 200299
16-05 HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.325600570905E10 rows, 3.5222202042395E11 cpu, 4.0175926642E10 io, 1.881536756357939E14 network, 3.801573906504E10 memory}, id = 200296
16-07 HashJoin(condition=[=($1, $14)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.857943815691059E14 network, 3.0412545295440002E10 memory}, id = 200293
16-09 HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {8.64014296705E9 rows, 1.1520018835835E11 cpu, 3.4560002086E10 io, 1.651508486544179E14 network, 192849.36000000002 memory}, id = 200282
33-01 HashJoin(condition=[=($0, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {5.76015496805E9 rows, 6.912038037435E10 cpu, 3.4560002086E10 io, 8.1683976192E8 network, 192849.36000000002 memory}, id = 200281
33-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_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_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 200276
33-02 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 200280
43-01 SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200279
43-02 Filter(condition=[=($1, 2002)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200278
43-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200277
16-08 Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200292
16-10 SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200291
16-11 Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200290
16-12 HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200289
16-13 Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200288
16-14 HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200287
16-16 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 200284
34-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 200283
16-15 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 200286
35-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 200285
16-06 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 5.183995752E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 200295
36-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 200294
16-04 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200298
37-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200297
16-02 BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 200301
38-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 200300
07-22 Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200316
07-24 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200315
17-01 HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 200314
17-03 HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 200310
17-06 HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 200307
17-08 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 200304
17-07 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200306
39-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200305
17-05 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200309
40-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200308
17-02 Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200313
17-04 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200312
41-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200311
07-17 BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 200322
18-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 200321
07-15 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200327
19-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200326
19-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200324
19-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200325
07-12 Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200333
07-14 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200332
20-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200331
20-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200329
20-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200330
07-10 BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 200338
21-01 SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200337
21-02 Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200336
21-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200335
07-08 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200341
22-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200340
07-05 Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200345
07-07 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200344
23-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200343
03-06 HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.5377031591945E10 rows, 1.09620702814107E12 cpu, 4.0317135384E10 io, 4.631302302962688E14 network, 2.615351883716E11 memory}, id = 200275
04-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.536263165195E10 rows, 1.0960534287811233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.615351883716E11 memory}, id = 200274
04-02 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.5218632252E10 rows, 1.0718615295895233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.4126007285864E11 memory}, id = 200273
06-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.507463285205E10 rows, 1.07063273470995E12 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 2.4126007285864E11 memory}, id = 200272
06-02 Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 8.2871374279395E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200271
06-03 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.219464485305E10 rows, 8.0279385080295E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200270
06-04 HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.075465085355E10 rows, 7.2359418083045E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200269
06-06 HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {4.929065685405E10 rows, 7.0615825283645E11 cpu, 4.0287135384E10 io, 4.496847520643891E14 network, 3.840331772904E10 memory}, id = 200265
06-09 HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {4.783266285455E10 rows, 6.8875232484245E11 cpu, 4.0257135384E10 io, 4.485665440643891E14 network, 3.829771772904E10 memory}, id = 200262
06-11 HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.639201823005E10 rows, 6.7146911747345E11 cpu, 4.0255935384E10 io, 4.485640280963891E14 network, 3.829742072904E10 memory}, id = 200257
06-13 HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.495198819055E10 rows, 6.5418895169945E11 cpu, 4.0255920964E10 io, 4.485632229866291E14 network, 3.829729365704E10 memory}, id = 200251
06-16 HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.351196535105E10 rows, 6.3690880752545E11 cpu, 4.0255906544E10 io, 4.485624178768691E14 network, 3.829716658504E10 memory}, id = 200246
06-18 SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.207196685155E10 rows, 6.1962885403145E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200243
06-19 Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.063197285205E10 rows, 6.1818886003195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200242
06-20 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$14], d_date_sk=[$12], d_year=[$13], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 6.0090893203795E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200241
06-21 HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.487199685405E10 rows, 5.0298934007195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200240
06-23 HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.6745613382195E11 cpu, 4.0179771248E10 io, 4.478184565078835E14 network, 3.804956278024E10 memory}, id = 200226
08-01 HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {2.902174711305E10 rows, 4.2137632583795E11 cpu, 4.0179771248E10 io, 1.882969779419955E14 network, 3.804956278024E10 memory}, id = 200225
08-03 HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.614175610805E10 rows, 3.8681645081195E11 cpu, 4.0179768242E10 io, 1.882968658975539E14 network, 3.804954514504E10 memory}, id = 200222
08-05 HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.325600570905E10 rows, 3.5222202042395E11 cpu, 4.0175926642E10 io, 1.881536756357939E14 network, 3.801573906504E10 memory}, id = 200219
08-07 HashJoin(condition=[=($1, $14)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.857943815691059E14 network, 3.0412545295440002E10 memory}, id = 200216
08-09 HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {8.64014296705E9 rows, 1.1520018835835E11 cpu, 3.4560002086E10 io, 1.651508486544179E14 network, 192849.36000000002 memory}, id = 200205
24-01 HashJoin(condition=[=($0, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {5.76015496805E9 rows, 6.912038037435E10 cpu, 3.4560002086E10 io, 8.1683976192E8 network, 192849.36000000002 memory}, id = 200204
24-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_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_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 200199
24-02 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 200203
42-01 SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200202
42-02 Filter(condition=[=($1, 2001)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200201
42-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200200
08-08 Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200215
08-10 SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200214
08-11 Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200213
08-12 HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200212
08-13 Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200211
08-14 HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200210
08-16 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 200207
25-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 200206
08-15 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 200209
26-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 200208
08-06 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 5.183995752E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 200218
27-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 200217
08-04 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200221
28-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200220
08-02 BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 200224
29-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 200223
06-22 Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200239
06-24 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200238
09-01 HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 200237
09-03 HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 200233
09-06 HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 200230
09-08 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 200227
09-07 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200229
30-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200228
09-05 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200232
31-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200231
09-02 Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200236
09-04 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200235
32-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200234
06-17 BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 200245
10-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 200244
06-15 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200250
11-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200249
11-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200247
11-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200248
06-12 Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200256
06-14 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200255
12-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200254
12-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200252
12-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200253
06-10 BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 200261
13-01 SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200260
13-02 Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200259
13-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200258
06-08 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200264
14-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200263
06-05 Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200268
06-07 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200267
15-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200266
Scanner (33-03) feeds the hash join (33-01) directly.
With Drill 1.16, the plan changes. Scanner (42-01) is redistributed before joining with two other tables via hash join (31-03). Here is the new plan:
00-00 Screen : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1662995869884973E11 rows, 2.2629766999994E12 cpu, 8.0634270768E10 io, 1.2342062877726515E15 network, 5.2478684959060406E11 memory}, id = 180266
00-01 Project(product_name=[$0], store_name=[$1], store_zip=[$2], b_street_number=[$3], b_streen_name=[$4], b_city=[$5], b_zip=[$6], c_street_number=[$7], c_street_name=[$8], c_city=[$9], c_zip=[$10], syear=[$11], cnt=[$12], s1=[$13], s2=[$14], s3=[$15], s10=[$16], s20=[$17], s30=[$18], syear0=[$19], cnt0=[$20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1662923870184998E11 rows, 2.2629759800024004E12 cpu, 8.0634270768E10 io, 1.2342062877726515E15 network, 5.2478684959060406E11 memory}, id = 180265
00-02 SingleMergeExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1662203873185248E11 rows, 2.262824780632453E12 cpu, 8.0634270768E10 io, 1.2342062877726515E15 network, 5.2478684959060406E11 memory}, id = 180264
01-01 OrderedMuxExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1661483876185498E11 rows, 2.262671509742005E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2478684959060406E11 memory}, id = 180263
02-01 SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1660763879185748E11 rows, 2.2626643097720073E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2478684959060406E11 memory}, id = 180262
02-02 Sort(sort0=[$0], sort1=[$1], sort2=[$20], dir0=[ASC], dir1=[ASC], dir2=[ASC]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1660043882185999E11 rows, 2.26265710980201E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2478684959060406E11 memory}, id = 180261
02-03 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$20]]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1659323885186249E11 rows, 2.2606889640656333E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2357725463102405E11 memory}, id = 180260
03-01 Project(product_name=[$0], store_name=[$2], store_zip=[$3], b_street_number=[$4], b_streen_name=[$5], b_city=[$6], b_zip=[$7], c_street_number=[$8], c_street_name=[$9], c_city=[$10], c_zip=[$11], syear=[$12], cnt=[$15], s1=[$16], s2=[$17], s3=[$18], s10=[$35], s20=[$36], s30=[$37], syear0=[$31], cnt0=[$34]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1658603888186499E11 rows, 2.26061216438566E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180259
03-02 SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.165788389118675E11 rows, 2.260460965015713E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180258
03-03 Filter(condition=[<=($34, $15)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.1657163894187E11 rows, 2.2604537650457153E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180257
03-04 HashJoin(condition=[AND(AND(=($1, $20), =($2, $21)), =($3, $22))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {1.16557239001875E11 rows, 2.260367365405745E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180256
03-05 Project(product_name0=[$0], item_sk0=[$1], store_name0=[$2], store_zip0=[$3], b_street_number0=[$4], b_streen_name0=[$5], b_city0=[$6], b_zip0=[$7], c_street_number0=[$8], c_street_name0=[$9], c_city0=[$10], c_zip0=[$11], syear0=[$12], fsyear0=[$13], s2year0=[$14], cnt0=[$15], s10=[$16], s20=[$17], s30=[$18]) : rowType = RecordType(ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {5.827141953094E10 rows, 1.129888483932975E12 cpu, 4.0317135384E10 io, 6.164838312670208E14 network, 2.615351883716E11 memory}, id = 180255
03-07 HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.8257019590945E10 rows, 1.12961488507307E12 cpu, 4.0317135384E10 io, 6.164838312670208E14 network, 2.615351883716E11 memory}, id = 180254
05-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.824261965095E10 rows, 1.1294612857131233E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.615351883716E11 memory}, id = 180253
05-02 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.8098620251E10 rows, 1.1052693865215232E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.4126007285864E11 memory}, id = 180252
07-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.795462085105E10 rows, 1.10404059164195E12 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 2.4126007285864E11 memory}, id = 180251
07-02 Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.651462685155E10 rows, 8.6212159972595E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180250
07-03 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.507463285205E10 rows, 8.3620170773495E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180249
07-04 HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 7.5700203776245E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180248
07-06 HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {5.217064485305E10 rows, 7.3956610976845E11 cpu, 4.0287135384E10 io, 6.030383530351411E14 network, 3.840331772904001E10 memory}, id = 180244
07-09 HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.071265085355E10 rows, 7.2216018177445E11 cpu, 4.0257135384E10 io, 6.019201450351411E14 network, 3.829771772904001E10 memory}, id = 180241
07-11 HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.927200622905E10 rows, 7.0487697440545E11 cpu, 4.0255935384E10 io, 6.019176290671411E14 network, 3.829742072904001E10 memory}, id = 180236
07-13 HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.783197618955E10 rows, 6.8759680863145E11 cpu, 4.0255920964E10 io, 6.019168239573811E14 network, 3.829729365704001E10 memory}, id = 180230
07-16 HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.639195335005E10 rows, 6.7031666445745E11 cpu, 4.0255906544E10 io, 6.019160188476211E14 network, 3.829716658504001E10 memory}, id = 180225
07-18 SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.495195485055E10 rows, 6.5303671096345E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180222
07-19 Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.351196085105E10 rows, 6.5159671696395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180221
07-20 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$12], d_date_sk=[$13], d_year=[$14], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {4.063197285205E10 rows, 6.3431678896995E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180220
07-21 HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 5.3639719700395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180219
07-23 HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.478172311105E10 rows, 5.0086399075395E11 cpu, 4.0179771248E10 io, 6.011720574786355E14 network, 3.8049562780240005E10 memory}, id = 180205
16-01 HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.5478418276995E11 cpu, 4.0179771248E10 io, 3.416505789127475E14 network, 3.8049562780240005E10 memory}, id = 180204
16-03 HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.902174410705E10 rows, 4.2022430774395E11 cpu, 4.0179768242E10 io, 3.416504668683059E14 network, 3.804954514504001E10 memory}, id = 180201
16-05 HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.613599370805E10 rows, 3.8562987735595E11 cpu, 4.0175926642E10 io, 3.415072766065459E14 network, 3.801573906504001E10 memory}, id = 180198
16-07 HashToRandomExchange(dist0=[[$1]], dist1=[[$8]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {2.239200641705E10 rows, 3.0787017245995E11 cpu, 3.9599927114E10 io, 3.391479825398579E14 network, 3.0412545295440006E10 memory}, id = 180195
31-01 HashJoin(condition=[=($0, $13)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.622015198812979E14 network, 3.0412545295440006E10 memory}, id = 180194
31-03 HashJoin(condition=[=($1, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.6631851449E10 rows, 2.387497920856E11 cpu, 3.9599781016E10 io, 1.62200703041536E14 network, 3.0412352446080006E10 memory}, id = 180189
31-05 HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {5.759975998E9 rows, 8.0639663972E10 cpu, 3.4559855988E10 io, 1.41557170126848E14 network, 0.0 memory}, id = 180178
42-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_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_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 180177
31-04 Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180188
31-06 SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180187
31-07 Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180186
31-08 HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180185
31-09 Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180184
31-10 HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180183
31-12 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 180180
43-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 180179
31-11 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 180182
44-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 180181
31-02 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 180193
45-01 SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180192
45-02 Filter(condition=[=($1, 2002)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180191
45-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180190
16-06 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 4.031996696E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 180197
32-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 180196
16-04 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180200
33-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180199
16-02 BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 180203
34-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 180202
07-22 Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180218
07-24 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180217
17-01 HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 180216
17-03 HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 180212
17-06 HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 180209
17-08 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 180206
17-07 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180208
35-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180207
17-05 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180211
36-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180210
17-02 Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180215
17-04 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180214
37-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180213
07-17 BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 180224
18-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 180223
07-15 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180229
19-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180228
19-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180226
19-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180227
07-12 Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180235
07-14 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180234
20-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180233
20-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180231
20-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180232
07-10 BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 180240
21-01 SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180239
21-02 Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180238
21-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180237
07-08 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180243
22-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180242
07-05 Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180247
07-07 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180246
23-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180245
03-06 HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.8257019590945E10 rows, 1.12961488507307E12 cpu, 4.0317135384E10 io, 6.164838312670208E14 network, 2.615351883716E11 memory}, id = 180176
04-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.824261965095E10 rows, 1.1294612857131233E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.615351883716E11 memory}, id = 180175
04-02 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.8098620251E10 rows, 1.1052693865215232E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.4126007285864E11 memory}, id = 180174
06-01 HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.795462085105E10 rows, 1.10404059164195E12 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 2.4126007285864E11 memory}, id = 180173
06-02 Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.651462685155E10 rows, 8.6212159972595E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180172
06-03 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.507463285205E10 rows, 8.3620170773495E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180171
06-04 HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 7.5700203776245E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180170
06-06 HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {5.217064485305E10 rows, 7.3956610976845E11 cpu, 4.0287135384E10 io, 6.030383530351411E14 network, 3.840331772904001E10 memory}, id = 180166
06-09 HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.071265085355E10 rows, 7.2216018177445E11 cpu, 4.0257135384E10 io, 6.019201450351411E14 network, 3.829771772904001E10 memory}, id = 180163
06-11 HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.927200622905E10 rows, 7.0487697440545E11 cpu, 4.0255935384E10 io, 6.019176290671411E14 network, 3.829742072904001E10 memory}, id = 180158
06-13 HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.783197618955E10 rows, 6.8759680863145E11 cpu, 4.0255920964E10 io, 6.019168239573811E14 network, 3.829729365704001E10 memory}, id = 180152
06-16 HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.639195335005E10 rows, 6.7031666445745E11 cpu, 4.0255906544E10 io, 6.019160188476211E14 network, 3.829716658504001E10 memory}, id = 180147
06-18 SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.495195485055E10 rows, 6.5303671096345E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180144
06-19 Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.351196085105E10 rows, 6.5159671696395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180143
06-20 Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$12], d_date_sk=[$13], d_year=[$14], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {4.063197285205E10 rows, 6.3431678896995E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180142
06-21 HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 5.3639719700395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180141
06-23 HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.478172311105E10 rows, 5.0086399075395E11 cpu, 4.0179771248E10 io, 6.011720574786355E14 network, 3.8049562780240005E10 memory}, id = 180127
08-01 HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.5478418276995E11 cpu, 4.0179771248E10 io, 3.416505789127475E14 network, 3.8049562780240005E10 memory}, id = 180126
08-03 HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.902174410705E10 rows, 4.2022430774395E11 cpu, 4.0179768242E10 io, 3.416504668683059E14 network, 3.804954514504001E10 memory}, id = 180123
08-05 HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.613599370805E10 rows, 3.8562987735595E11 cpu, 4.0175926642E10 io, 3.415072766065459E14 network, 3.801573906504001E10 memory}, id = 180120
08-07 HashToRandomExchange(dist0=[[$1]], dist1=[[$8]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {2.239200641705E10 rows, 3.0787017245995E11 cpu, 3.9599927114E10 io, 3.391479825398579E14 network, 3.0412545295440006E10 memory}, id = 180117
24-01 HashJoin(condition=[=($0, $13)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.622015198812979E14 network, 3.0412545295440006E10 memory}, id = 180116
24-03 HashJoin(condition=[=($1, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.6631851449E10 rows, 2.387497920856E11 cpu, 3.9599781016E10 io, 1.62200703041536E14 network, 3.0412352446080006E10 memory}, id = 180111
24-05 HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {5.759975998E9 rows, 8.0639663972E10 cpu, 3.4559855988E10 io, 1.41557170126848E14 network, 0.0 memory}, id = 180100
38-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_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_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 180099
24-04 Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180110
24-06 SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180109
24-07 Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180108
24-08 HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180107
24-09 Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180106
24-10 HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180105
24-12 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 180102
39-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 180101
24-11 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 180104
40-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 180103
24-02 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 180115
41-01 SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180114
41-02 Filter(condition=[=($1, 2001)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180113
41-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180112
08-06 HashToRandomExchange(dist0=[[$0]], dist1=[[$1]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 4.031996696E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 180119
25-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 180118
08-04 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180122
26-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180121
08-02 BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 180125
27-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 180124
06-22 Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180140
06-24 HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180139
09-01 HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 180138
09-03 HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 180134
09-06 HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 180131
09-08 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 180128
09-07 BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180130
28-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180129
09-05 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180133
29-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180132
09-02 Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180137
09-04 BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180136
30-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180135
06-17 BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 180146
10-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 180145
06-15 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180151
11-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180150
11-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180148
11-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180149
06-12 Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180157
06-14 BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180156
12-01 HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180155
12-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180153
12-02 Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180154
06-10 BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 180162
13-01 SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180161
13-02 Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180160
13-03 Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180159
06-08 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180165
14-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180164
06-05 Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180169
06-07 BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180168
15-01 Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180167
I tested with commit be73250e68ffd836541223cf4aca395896362866, and it did not exhibit this problem.
Attachments
Issue Links
- links to