You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@drill.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2019/04/17 05:32:00 UTC
[jira] [Commented] (DRILL-7182) TPCDS query 64 degrades due to
Statistics even when disabled
[ https://issues.apache.org/jira/browse/DRILL-7182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16819741#comment-16819741 ]
ASF GitHub Bot commented on DRILL-7182:
---------------------------------------
gparai commented on pull request #1752: DRILL-7182: Incorrect access specifier for Join DrillRelMdDistinctRowcount
URL: https://github.com/apache/drill/pull/1752
@amansinha100 can you please review this PR? Thanks!
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
> TPCDS query 64 degrades due to Statistics even when disabled
> ------------------------------------------------------------
>
> Key: DRILL-7182
> URL: https://issues.apache.org/jira/browse/DRILL-7182
> Project: Apache Drill
> Issue Type: Bug
> Components: Query Planning & Optimization
> Affects Versions: 1.16.0
> Reporter: Robert Hou
> Assignee: Gautam Parai
> Priority: Blocker
> Fix For: 1.16.0
>
>
> 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:
> {noformat}
> 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;
> {noformat}
> Here is the original plan from Drill 1.15:
> {noformat}
> 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
> {noformat}
> 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:
> {noformat}
> 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
> {noformat}
> I tested with commit be73250e68ffd836541223cf4aca395896362866, and it did not exhibit this problem.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)