Uploaded image for project: 'Apache Drill'
  1. Apache Drill
  2. DRILL-7182

TPCDS query 64 degrades due to Statistics even when disabled

    XMLWordPrintableJSON

    Details

      Description

      TPCDS query 64 has slowed by 90% compared to Drill 1.15. The primary reason is due to hash join re-ordering. Here is the query:

      WITH cs_ui 
           AS (SELECT cs_item_sk, 
                      Sum(cs_ext_list_price) AS sale, 
                      Sum(cr_refunded_cash + cr_reversed_charge 
                          + cr_store_credit) AS refund 
               FROM   catalog_sales, 
                      catalog_returns 
               WHERE  cs_item_sk = cr_item_sk 
                      AND cs_order_number = cr_order_number 
               GROUP  BY cs_item_sk 
               HAVING Sum(cs_ext_list_price) > 2 * Sum( 
                      cr_refunded_cash + cr_reversed_charge 
                      + cr_store_credit)), 
           cross_sales 
           AS (SELECT i_product_name         product_name, 
                      i_item_sk              item_sk, 
                      s_store_name           store_name, 
                      s_zip                  store_zip, 
                      ad1.ca_street_number   b_street_number, 
                      ad1.ca_street_name     b_streen_name, 
                      ad1.ca_city            b_city, 
                      ad1.ca_zip             b_zip, 
                      ad2.ca_street_number   c_street_number, 
                      ad2.ca_street_name     c_street_name, 
                      ad2.ca_city            c_city, 
                      ad2.ca_zip             c_zip, 
                      d1.d_year              AS syear, 
                      d2.d_year              AS fsyear, 
                      d3.d_year              s2year, 
                      Count(*)               cnt, 
                      Sum(ss_wholesale_cost) s1, 
                      Sum(ss_list_price)     s2, 
                      Sum(ss_coupon_amt)     s3 
               FROM   store_sales, 
                      store_returns, 
                      cs_ui, 
                      date_dim d1, 
                      date_dim d2, 
                      date_dim d3, 
                      store, 
                      customer, 
                      customer_demographics cd1, 
                      customer_demographics cd2, 
                      promotion, 
                      household_demographics hd1, 
                      household_demographics hd2, 
                      customer_address ad1, 
                      customer_address ad2, 
                      income_band ib1, 
                      income_band ib2, 
                      item 
               WHERE  ss_store_sk = s_store_sk 
                      AND ss_sold_date_sk = d1.d_date_sk 
                      AND ss_customer_sk = c_customer_sk 
                      AND ss_cdemo_sk = cd1.cd_demo_sk 
                      AND ss_hdemo_sk = hd1.hd_demo_sk 
                      AND ss_addr_sk = ad1.ca_address_sk 
                      AND ss_item_sk = i_item_sk 
                      AND ss_item_sk = sr_item_sk 
                      AND ss_ticket_number = sr_ticket_number 
                      AND ss_item_sk = cs_ui.cs_item_sk 
                      AND c_current_cdemo_sk = cd2.cd_demo_sk 
                      AND c_current_hdemo_sk = hd2.hd_demo_sk 
                      AND c_current_addr_sk = ad2.ca_address_sk 
                      AND c_first_sales_date_sk = d2.d_date_sk 
                      AND c_first_shipto_date_sk = d3.d_date_sk 
                      AND ss_promo_sk = p_promo_sk 
                      AND hd1.hd_income_band_sk = ib1.ib_income_band_sk 
                      AND hd2.hd_income_band_sk = ib2.ib_income_band_sk 
                      AND cd1.cd_marital_status <> cd2.cd_marital_status 
                      AND i_color IN ( 'cyan', 'peach', 'blush', 'frosted', 
                                       'powder', 'orange' ) 
                      AND i_current_price BETWEEN 58 AND 58 + 10 
                      AND i_current_price BETWEEN 58 + 1 AND 58 + 15 
               GROUP  BY i_product_name, 
                         i_item_sk, 
                         s_store_name, 
                         s_zip, 
                         ad1.ca_street_number, 
                         ad1.ca_street_name, 
                         ad1.ca_city, 
                         ad1.ca_zip, 
                         ad2.ca_street_number, 
                         ad2.ca_street_name, 
                         ad2.ca_city, 
                         ad2.ca_zip, 
                         d1.d_year, 
                         d2.d_year, 
                         d3.d_year) 
      SELECT cs1.product_name, 
             cs1.store_name, 
             cs1.store_zip, 
             cs1.b_street_number, 
             cs1.b_streen_name, 
             cs1.b_city, 
             cs1.b_zip, 
             cs1.c_street_number, 
             cs1.c_street_name, 
             cs1.c_city, 
             cs1.c_zip, 
             cs1.syear, 
             cs1.cnt, 
             cs1.s1, 
             cs1.s2, 
             cs1.s3, 
             cs2.s1, 
             cs2.s2, 
             cs2.s3, 
             cs2.syear, 
             cs2.cnt 
      FROM   cross_sales cs1, 
             cross_sales cs2 
      WHERE  cs1.item_sk = cs2.item_sk 
             AND cs1.syear = 2001 
             AND cs2.syear = 2001 + 1 
             AND cs2.cnt <= cs1.cnt 
             AND cs1.store_name = cs2.store_name 
             AND cs1.store_zip = cs2.store_zip 
      ORDER  BY cs1.product_name, 
                cs1.store_name, 
                cs2.cnt; 
      

      Here is the original plan from Drill 1.15:

      00-00    Screen : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1086998270084973E11 rows, 2.1961609861354004E12 cpu, 8.0634270768E10 io, 9.274990858311476E14 network, 5.2478684959060406E11 memory}, id = 200364
      00-01      Project(product_name=[$0], store_name=[$1], store_zip=[$2], b_street_number=[$3], b_streen_name=[$4], b_city=[$5], b_zip=[$6], c_street_number=[$7], c_street_name=[$8], c_city=[$9], c_zip=[$10], syear=[$11], cnt=[$12], s1=[$13], s2=[$14], s3=[$15], s10=[$16], s20=[$17], s30=[$18], syear0=[$19], cnt0=[$20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1086926270384998E11 rows, 2.1961602661384006E12 cpu, 8.0634270768E10 io, 9.274990858311476E14 network, 5.2478684959060406E11 memory}, id = 200363
      00-02        SingleMergeExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1086206273385248E11 rows, 2.1960090667684531E12 cpu, 8.0634270768E10 io, 9.274990858311476E14 network, 5.2478684959060406E11 memory}, id = 200362
      01-01          OrderedMuxExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1085486276385498E11 rows, 2.195855795878005E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2478684959060406E11 memory}, id = 200361
      02-01            SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1084766279385748E11 rows, 2.1958485959080073E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2478684959060406E11 memory}, id = 200360
      02-02              Sort(sort0=[$0], sort1=[$1], sort2=[$20], dir0=[ASC], dir1=[ASC], dir2=[ASC]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1084046282385999E11 rows, 2.1958413959380098E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2478684959060406E11 memory}, id = 200359
      02-03                HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$20]]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1083326285386249E11 rows, 2.1938732502016333E12 cpu, 8.0634270768E10 io, 9.268797732118426E14 network, 5.2357725463102405E11 memory}, id = 200358
      03-01                  Project(product_name=[$0], store_name=[$2], store_zip=[$3], b_street_number=[$4], b_streen_name=[$5], b_city=[$6], b_zip=[$7], c_street_number=[$8], c_street_name=[$9], c_city=[$10], c_zip=[$11], syear=[$12], cnt=[$15], s1=[$16], s2=[$17], s3=[$18], s10=[$35], s20=[$36], s30=[$37], syear0=[$31], cnt0=[$34]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1082606288386499E11 rows, 2.19379645052166E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200357
      03-02                    SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.108188629138675E11 rows, 2.1936452511517124E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200356
      03-03                      Filter(condition=[<=($34, $15)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.1081166294387E11 rows, 2.1936380511817148E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200355
      03-04                        HashJoin(condition=[AND(AND(=($1, $20), =($2, $21)), =($3, $22))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {1.10797263003875E11 rows, 2.1935516515417449E12 cpu, 8.0634270768E10 io, 9.262604605925376E14 network, 5.2357725463102405E11 memory}, id = 200354
      03-05                          Project(product_name0=[$0], item_sk0=[$1], store_name0=[$2], store_zip0=[$3], b_street_number0=[$4], b_streen_name0=[$5], b_city0=[$6], b_zip0=[$7], c_street_number0=[$8], c_street_name0=[$9], c_city0=[$10], c_zip0=[$11], syear0=[$12], fsyear0=[$13], s2year0=[$14], cnt0=[$15], s10=[$16], s20=[$17], s30=[$18]) : rowType = RecordType(ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {5.539143153194E10 rows, 1.096480627000975E12 cpu, 4.0317135384E10 io, 4.631302302962688E14 network, 2.615351883716E11 memory}, id = 200353
      03-07                            HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.5377031591945E10 rows, 1.09620702814107E12 cpu, 4.0317135384E10 io, 4.631302302962688E14 network, 2.615351883716E11 memory}, id = 200352
      05-01                              HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.536263165195E10 rows, 1.0960534287811233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.615351883716E11 memory}, id = 200351
      05-02                                HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.5218632252E10 rows, 1.0718615295895233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.4126007285864E11 memory}, id = 200350
      07-01                                  HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.507463285205E10 rows, 1.07063273470995E12 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 2.4126007285864E11 memory}, id = 200349
      07-02                                    Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 8.2871374279395E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200348
      07-03                                      Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.219464485305E10 rows, 8.0279385080295E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200347
      07-04                                        HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.075465085355E10 rows, 7.2359418083045E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200346
      07-06                                          HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {4.929065685405E10 rows, 7.0615825283645E11 cpu, 4.0287135384E10 io, 4.496847520643891E14 network, 3.840331772904E10 memory}, id = 200342
      07-09                                            HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {4.783266285455E10 rows, 6.8875232484245E11 cpu, 4.0257135384E10 io, 4.485665440643891E14 network, 3.829771772904E10 memory}, id = 200339
      07-11                                              HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.639201823005E10 rows, 6.7146911747345E11 cpu, 4.0255935384E10 io, 4.485640280963891E14 network, 3.829742072904E10 memory}, id = 200334
      07-13                                                HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.495198819055E10 rows, 6.5418895169945E11 cpu, 4.0255920964E10 io, 4.485632229866291E14 network, 3.829729365704E10 memory}, id = 200328
      07-16                                                  HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.351196535105E10 rows, 6.3690880752545E11 cpu, 4.0255906544E10 io, 4.485624178768691E14 network, 3.829716658504E10 memory}, id = 200323
      07-18                                                    SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.207196685155E10 rows, 6.1962885403145E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200320
      07-19                                                      Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.063197285205E10 rows, 6.1818886003195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200319
      07-20                                                        Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$14], d_date_sk=[$12], d_year=[$13], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 6.0090893203795E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200318
      07-21                                                          HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.487199685405E10 rows, 5.0298934007195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200317
      07-23                                                            HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.6745613382195E11 cpu, 4.0179771248E10 io, 4.478184565078835E14 network, 3.804956278024E10 memory}, id = 200303
      16-01                                                              HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {2.902174711305E10 rows, 4.2137632583795E11 cpu, 4.0179771248E10 io, 1.882969779419955E14 network, 3.804956278024E10 memory}, id = 200302
      16-03                                                                HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.614175610805E10 rows, 3.8681645081195E11 cpu, 4.0179768242E10 io, 1.882968658975539E14 network, 3.804954514504E10 memory}, id = 200299
      16-05                                                                  HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.325600570905E10 rows, 3.5222202042395E11 cpu, 4.0175926642E10 io, 1.881536756357939E14 network, 3.801573906504E10 memory}, id = 200296
      16-07                                                                    HashJoin(condition=[=($1, $14)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.857943815691059E14 network, 3.0412545295440002E10 memory}, id = 200293
      16-09                                                                      HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {8.64014296705E9 rows, 1.1520018835835E11 cpu, 3.4560002086E10 io, 1.651508486544179E14 network, 192849.36000000002 memory}, id = 200282
      33-01                                                                        HashJoin(condition=[=($0, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {5.76015496805E9 rows, 6.912038037435E10 cpu, 3.4560002086E10 io, 8.1683976192E8 network, 192849.36000000002 memory}, id = 200281
      33-03                                                                          Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_sk`, `ss_item_sk`, `ss_customer_sk`, `ss_cdemo_sk`, `ss_hdemo_sk`, `ss_addr_sk`, `ss_store_sk`, `ss_promo_sk`, `ss_ticket_number`, `ss_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 200276
      33-02                                                                          BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 200280
      43-01                                                                            SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200279
      43-02                                                                              Filter(condition=[=($1, 2002)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200278
      43-03                                                                                Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200277
      16-08                                                                      Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200292
      16-10                                                                        SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200291
      16-11                                                                          Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200290
      16-12                                                                            HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200289
      16-13                                                                              Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200288
      16-14                                                                                HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200287
      16-16                                                                                  HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 200284
      34-01                                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 200283
      16-15                                                                                  HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 200286
      35-01                                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 200285
      16-06                                                                    HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 5.183995752E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 200295
      36-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 200294
      16-04                                                                  BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200298
      37-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200297
      16-02                                                                BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 200301
      38-01                                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 200300
      07-22                                                            Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200316
      07-24                                                              HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200315
      17-01                                                                HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 200314
      17-03                                                                  HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 200310
      17-06                                                                    HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 200307
      17-08                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 200304
      17-07                                                                      BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200306
      39-01                                                                        Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200305
      17-05                                                                    BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200309
      40-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200308
      17-02                                                                  Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200313
      17-04                                                                    BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200312
      41-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200311
      07-17                                                    BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 200322
      18-01                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 200321
      07-15                                                  BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200327
      19-01                                                    HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200326
      19-03                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200324
      19-02                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200325
      07-12                                                Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200333
      07-14                                                  BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200332
      20-01                                                    HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200331
      20-03                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200329
      20-02                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200330
      07-10                                              BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 200338
      21-01                                                SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200337
      21-02                                                  Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200336
      21-03                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200335
      07-08                                            BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200341
      22-01                                              Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200340
      07-05                                          Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200345
      07-07                                            BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200344
      23-01                                              Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200343
      03-06                          HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.5377031591945E10 rows, 1.09620702814107E12 cpu, 4.0317135384E10 io, 4.631302302962688E14 network, 2.615351883716E11 memory}, id = 200275
      04-01                            HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.536263165195E10 rows, 1.0960534287811233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.615351883716E11 memory}, id = 200274
      04-02                              HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.5218632252E10 rows, 1.0718615295895233E12 cpu, 4.0317135384E10 io, 4.6200956936609794E14 network, 2.4126007285864E11 memory}, id = 200273
      06-01                                HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.507463285205E10 rows, 1.07063273470995E12 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 2.4126007285864E11 memory}, id = 200272
      06-02                                  Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 8.2871374279395E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200271
      06-03                                    Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.219464485305E10 rows, 8.0279385080295E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200270
      06-04                                      HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.075465085355E10 rows, 7.2359418083045E11 cpu, 4.0317135384E10 io, 4.508029600643891E14 network, 3.850891772904E10 memory}, id = 200269
      06-06                                        HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {4.929065685405E10 rows, 7.0615825283645E11 cpu, 4.0287135384E10 io, 4.496847520643891E14 network, 3.840331772904E10 memory}, id = 200265
      06-09                                          HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {4.783266285455E10 rows, 6.8875232484245E11 cpu, 4.0257135384E10 io, 4.485665440643891E14 network, 3.829771772904E10 memory}, id = 200262
      06-11                                            HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.639201823005E10 rows, 6.7146911747345E11 cpu, 4.0255935384E10 io, 4.485640280963891E14 network, 3.829742072904E10 memory}, id = 200257
      06-13                                              HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.495198819055E10 rows, 6.5418895169945E11 cpu, 4.0255920964E10 io, 4.485632229866291E14 network, 3.829729365704E10 memory}, id = 200251
      06-16                                                HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.351196535105E10 rows, 6.3690880752545E11 cpu, 4.0255906544E10 io, 4.485624178768691E14 network, 3.829716658504E10 memory}, id = 200246
      06-18                                                  SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.207196685155E10 rows, 6.1962885403145E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200243
      06-19                                                    Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.063197285205E10 rows, 6.1818886003195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200242
      06-20                                                      Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$14], d_date_sk=[$12], d_year=[$13], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 6.0090893203795E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200241
      06-21                                                        HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.487199685405E10 rows, 5.0298934007195E11 cpu, 4.0255905044E10 io, 4.485623619664691E14 network, 3.829714018504E10 memory}, id = 200240
      06-23                                                          HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.6745613382195E11 cpu, 4.0179771248E10 io, 4.478184565078835E14 network, 3.804956278024E10 memory}, id = 200226
      08-01                                                            HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {2.902174711305E10 rows, 4.2137632583795E11 cpu, 4.0179771248E10 io, 1.882969779419955E14 network, 3.804956278024E10 memory}, id = 200225
      08-03                                                              HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.614175610805E10 rows, 3.8681645081195E11 cpu, 4.0179768242E10 io, 1.882968658975539E14 network, 3.804954514504E10 memory}, id = 200222
      08-05                                                                HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.325600570905E10 rows, 3.5222202042395E11 cpu, 4.0175926642E10 io, 1.881536756357939E14 network, 3.801573906504E10 memory}, id = 200219
      08-07                                                                  HashJoin(condition=[=($1, $14)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.857943815691059E14 network, 3.0412545295440002E10 memory}, id = 200216
      08-09                                                                    HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {8.64014296705E9 rows, 1.1520018835835E11 cpu, 3.4560002086E10 io, 1.651508486544179E14 network, 192849.36000000002 memory}, id = 200205
      24-01                                                                      HashJoin(condition=[=($0, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {5.76015496805E9 rows, 6.912038037435E10 cpu, 3.4560002086E10 io, 8.1683976192E8 network, 192849.36000000002 memory}, id = 200204
      24-03                                                                        Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_sk`, `ss_item_sk`, `ss_customer_sk`, `ss_cdemo_sk`, `ss_hdemo_sk`, `ss_addr_sk`, `ss_store_sk`, `ss_promo_sk`, `ss_ticket_number`, `ss_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 200199
      24-02                                                                        BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 200203
      42-01                                                                          SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200202
      42-02                                                                            Filter(condition=[=($1, 2001)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200201
      42-03                                                                              Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200200
      08-08                                                                    Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200215
      08-10                                                                      SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200214
      08-11                                                                        Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200213
      08-12                                                                          HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 200212
      08-13                                                                            Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200211
      08-14                                                                              HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 200210
      08-16                                                                                HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 200207
      25-01                                                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 200206
      08-15                                                                                HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 200209
      26-01                                                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 200208
      08-06                                                                  HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 5.183995752E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 200218
      27-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 200217
      08-04                                                                BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200221
      28-01                                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200220
      08-02                                                              BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 200224
      29-01                                                                Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 200223
      06-22                                                          Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200239
      06-24                                                            HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 200238
      09-01                                                              HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 200237
      09-03                                                                HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 200233
      09-06                                                                  HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 200230
      09-08                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 200227
      09-07                                                                    BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 200229
      30-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 200228
      09-05                                                                  BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200232
      31-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200231
      09-02                                                                Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200236
      09-04                                                                  BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 200235
      32-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 200234
      06-17                                                  BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 200245
      10-01                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 200244
      06-15                                                BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200250
      11-01                                                  HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200249
      11-03                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200247
      11-02                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200248
      06-12                                              Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200256
      06-14                                                BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 200255
      12-01                                                  HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 200254
      12-03                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 200252
      12-02                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 200253
      06-10                                            BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 200261
      13-01                                              SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200260
      13-02                                                Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200259
      13-03                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 200258
      06-08                                          BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200264
      14-01                                            Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200263
      06-05                                        Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200268
      06-07                                          BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 200267
      15-01                                            Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 200266
      

      Scanner (33-03) feeds the hash join (33-01) directly.

      With Drill 1.16, the plan changes. Scanner (42-01) is redistributed before joining with two other tables via hash join (31-03). Here is the new plan:

      00-00    Screen : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1662995869884973E11 rows, 2.2629766999994E12 cpu, 8.0634270768E10 io, 1.2342062877726515E15 network, 5.2478684959060406E11 memory}, id = 180266
      00-01      Project(product_name=[$0], store_name=[$1], store_zip=[$2], b_street_number=[$3], b_streen_name=[$4], b_city=[$5], b_zip=[$6], c_street_number=[$7], c_street_name=[$8], c_city=[$9], c_zip=[$10], syear=[$11], cnt=[$12], s1=[$13], s2=[$14], s3=[$15], s10=[$16], s20=[$17], s30=[$18], syear0=[$19], cnt0=[$20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1662923870184998E11 rows, 2.2629759800024004E12 cpu, 8.0634270768E10 io, 1.2342062877726515E15 network, 5.2478684959060406E11 memory}, id = 180265
      00-02        SingleMergeExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1662203873185248E11 rows, 2.262824780632453E12 cpu, 8.0634270768E10 io, 1.2342062877726515E15 network, 5.2478684959060406E11 memory}, id = 180264
      01-01          OrderedMuxExchange(sort0=[0], sort1=[1], sort2=[20]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1661483876185498E11 rows, 2.262671509742005E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2478684959060406E11 memory}, id = 180263
      02-01            SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1660763879185748E11 rows, 2.2626643097720073E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2478684959060406E11 memory}, id = 180262
      02-02              Sort(sort0=[$0], sort1=[$1], sort2=[$20], dir0=[ASC], dir1=[ASC], dir2=[ASC]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1660043882185999E11 rows, 2.26265710980201E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2478684959060406E11 memory}, id = 180261
      02-03                HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$20]]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1659323885186249E11 rows, 2.2606889640656333E12 cpu, 8.0634270768E10 io, 1.2335869751533465E15 network, 5.2357725463102405E11 memory}, id = 180260
      03-01                  Project(product_name=[$0], store_name=[$2], store_zip=[$3], b_street_number=[$4], b_streen_name=[$5], b_city=[$6], b_zip=[$7], c_street_number=[$8], c_street_name=[$9], c_city=[$10], c_zip=[$11], syear=[$12], cnt=[$15], s1=[$16], s2=[$17], s3=[$18], s10=[$35], s20=[$36], s30=[$37], syear0=[$31], cnt0=[$34]) : rowType = RecordType(ANY product_name, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY s10, ANY s20, ANY s30, ANY syear0, BIGINT cnt0): rowcount = 7199969.9975, cumulative cost = {1.1658603888186499E11 rows, 2.26061216438566E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180259
      03-02                    SelectionVectorRemover : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.165788389118675E11 rows, 2.260460965015713E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180258
      03-03                      Filter(condition=[<=($34, $15)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 7199969.9975, cumulative cost = {1.1657163894187E11 rows, 2.2604537650457153E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180257
      03-04                        HashJoin(condition=[AND(AND(=($1, $20), =($2, $21)), =($3, $22))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3, ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {1.16557239001875E11 rows, 2.260367365405745E12 cpu, 8.0634270768E10 io, 1.2329676625340415E15 network, 5.2357725463102405E11 memory}, id = 180256
      03-05                          Project(product_name0=[$0], item_sk0=[$1], store_name0=[$2], store_zip0=[$3], b_street_number0=[$4], b_streen_name0=[$5], b_city0=[$6], b_zip0=[$7], c_street_number0=[$8], c_street_name0=[$9], c_city0=[$10], c_zip0=[$11], syear0=[$12], fsyear0=[$13], s2year0=[$14], cnt0=[$15], s10=[$16], s20=[$17], s30=[$18]) : rowType = RecordType(ANY product_name0, ANY item_sk0, ANY store_name0, ANY store_zip0, ANY b_street_number0, ANY b_streen_name0, ANY b_city0, ANY b_zip0, ANY c_street_number0, ANY c_street_name0, ANY c_city0, ANY c_zip0, ANY syear0, ANY fsyear0, ANY s2year0, BIGINT cnt0, ANY s10, ANY s20, ANY s30): rowcount = 1.4399939995E7, cumulative cost = {5.827141953094E10 rows, 1.129888483932975E12 cpu, 4.0317135384E10 io, 6.164838312670208E14 network, 2.615351883716E11 memory}, id = 180255
      03-07                            HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.8257019590945E10 rows, 1.12961488507307E12 cpu, 4.0317135384E10 io, 6.164838312670208E14 network, 2.615351883716E11 memory}, id = 180254
      05-01                              HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.824261965095E10 rows, 1.1294612857131233E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.615351883716E11 memory}, id = 180253
      05-02                                HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.8098620251E10 rows, 1.1052693865215232E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.4126007285864E11 memory}, id = 180252
      07-01                                  HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.795462085105E10 rows, 1.10404059164195E12 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 2.4126007285864E11 memory}, id = 180251
      07-02                                    Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.651462685155E10 rows, 8.6212159972595E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180250
      07-03                                      Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.507463285205E10 rows, 8.3620170773495E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180249
      07-04                                        HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 7.5700203776245E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180248
      07-06                                          HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {5.217064485305E10 rows, 7.3956610976845E11 cpu, 4.0287135384E10 io, 6.030383530351411E14 network, 3.840331772904001E10 memory}, id = 180244
      07-09                                            HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.071265085355E10 rows, 7.2216018177445E11 cpu, 4.0257135384E10 io, 6.019201450351411E14 network, 3.829771772904001E10 memory}, id = 180241
      07-11                                              HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.927200622905E10 rows, 7.0487697440545E11 cpu, 4.0255935384E10 io, 6.019176290671411E14 network, 3.829742072904001E10 memory}, id = 180236
      07-13                                                HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.783197618955E10 rows, 6.8759680863145E11 cpu, 4.0255920964E10 io, 6.019168239573811E14 network, 3.829729365704001E10 memory}, id = 180230
      07-16                                                  HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.639195335005E10 rows, 6.7031666445745E11 cpu, 4.0255906544E10 io, 6.019160188476211E14 network, 3.829716658504001E10 memory}, id = 180225
      07-18                                                    SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.495195485055E10 rows, 6.5303671096345E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180222
      07-19                                                      Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.351196085105E10 rows, 6.5159671696395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180221
      07-20                                                        Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$12], d_date_sk=[$13], d_year=[$14], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {4.063197285205E10 rows, 6.3431678896995E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180220
      07-21                                                          HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 5.3639719700395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180219
      07-23                                                            HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.478172311105E10 rows, 5.0086399075395E11 cpu, 4.0179771248E10 io, 6.011720574786355E14 network, 3.8049562780240005E10 memory}, id = 180205
      16-01                                                              HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.5478418276995E11 cpu, 4.0179771248E10 io, 3.416505789127475E14 network, 3.8049562780240005E10 memory}, id = 180204
      16-03                                                                HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.902174410705E10 rows, 4.2022430774395E11 cpu, 4.0179768242E10 io, 3.416504668683059E14 network, 3.804954514504001E10 memory}, id = 180201
      16-05                                                                  HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.613599370805E10 rows, 3.8562987735595E11 cpu, 4.0175926642E10 io, 3.415072766065459E14 network, 3.801573906504001E10 memory}, id = 180198
      16-07                                                                    HashToRandomExchange(dist0=[[$1]], dist1=[[$8]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {2.239200641705E10 rows, 3.0787017245995E11 cpu, 3.9599927114E10 io, 3.391479825398579E14 network, 3.0412545295440006E10 memory}, id = 180195
      31-01                                                                      HashJoin(condition=[=($0, $13)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.622015198812979E14 network, 3.0412545295440006E10 memory}, id = 180194
      31-03                                                                        HashJoin(condition=[=($1, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.6631851449E10 rows, 2.387497920856E11 cpu, 3.9599781016E10 io, 1.62200703041536E14 network, 3.0412352446080006E10 memory}, id = 180189
      31-05                                                                          HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {5.759975998E9 rows, 8.0639663972E10 cpu, 3.4559855988E10 io, 1.41557170126848E14 network, 0.0 memory}, id = 180178
      42-01                                                                            Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_sk`, `ss_item_sk`, `ss_customer_sk`, `ss_cdemo_sk`, `ss_hdemo_sk`, `ss_addr_sk`, `ss_store_sk`, `ss_promo_sk`, `ss_ticket_number`, `ss_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 180177
      31-04                                                                          Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180188
      31-06                                                                            SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180187
      31-07                                                                              Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180186
      31-08                                                                                HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180185
      31-09                                                                                  Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180184
      31-10                                                                                    HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180183
      31-12                                                                                      HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 180180
      43-01                                                                                        Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 180179
      31-11                                                                                      HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 180182
      44-01                                                                                        Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 180181
      31-02                                                                        BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 180193
      45-01                                                                          SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180192
      45-02                                                                            Filter(condition=[=($1, 2002)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180191
      45-03                                                                              Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180190
      16-06                                                                    HashToRandomExchange(dist0=[[$0]], dist1=[[$1]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 4.031996696E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 180197
      32-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 180196
      16-04                                                                  BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180200
      33-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180199
      16-02                                                                BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 180203
      34-01                                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 180202
      07-22                                                            Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180218
      07-24                                                              HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180217
      17-01                                                                HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 180216
      17-03                                                                  HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 180212
      17-06                                                                    HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 180209
      17-08                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 180206
      17-07                                                                      BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180208
      35-01                                                                        Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180207
      17-05                                                                    BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180211
      36-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180210
      17-02                                                                  Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180215
      17-04                                                                    BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180214
      37-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180213
      07-17                                                    BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 180224
      18-01                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 180223
      07-15                                                  BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180229
      19-01                                                    HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180228
      19-03                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180226
      19-02                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180227
      07-12                                                Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180235
      07-14                                                  BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180234
      20-01                                                    HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180233
      20-03                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180231
      20-02                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180232
      07-10                                              BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 180240
      21-01                                                SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180239
      21-02                                                  Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180238
      21-03                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180237
      07-08                                            BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180243
      22-01                                              Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180242
      07-05                                          Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180247
      07-07                                            BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180246
      23-01                                              Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180245
      03-06                          HashToRandomExchange(dist0=[[$1]], dist1=[[$2]], dist2=[[$3]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.8257019590945E10 rows, 1.12961488507307E12 cpu, 4.0317135384E10 io, 6.164838312670208E14 network, 2.615351883716E11 memory}, id = 180176
      04-01                            HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[$SUM0($15)], s1=[SUM($16)], s2=[SUM($17)], s3=[SUM($18)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E7, cumulative cost = {5.824261965095E10 rows, 1.1294612857131233E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.615351883716E11 memory}, id = 180175
      04-02                              HashToRandomExchange(dist0=[[$0]], dist1=[[$1]], dist2=[[$2]], dist3=[[$3]], dist4=[[$4]], dist5=[[$5]], dist6=[[$6]], dist7=[[$7]], dist8=[[$8]], dist9=[[$9]], dist10=[[$10]], dist11=[[$11]], dist12=[[$12]], dist13=[[$13]], dist14=[[$14]]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.8098620251E10 rows, 1.1052693865215232E12 cpu, 4.0317135384E10 io, 6.153631703368499E14 network, 2.4126007285864E11 memory}, id = 180174
      06-01                                HashAgg(group=[{0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14}], cnt=[COUNT()], s1=[SUM($15)], s2=[SUM($16)], s3=[SUM($17)]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, BIGINT cnt, ANY s1, ANY s2, ANY s3): rowcount = 1.4399939995E8, cumulative cost = {5.795462085105E10 rows, 1.10404059164195E12 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 2.4126007285864E11 memory}, id = 180173
      06-02                                  Project(product_name=[$54], item_sk=[$51], store_name=[$22], store_zip=[$23], b_street_number=[$40], b_streen_name=[$41], b_city=[$42], b_zip=[$43], c_street_number=[$45], c_street_name=[$46], c_city=[$47], c_zip=[$48], syear=[$16], fsyear=[$18], s2year=[$20], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11]) : rowType = RecordType(ANY product_name, ANY item_sk, ANY store_name, ANY store_zip, ANY b_street_number, ANY b_streen_name, ANY b_city, ANY b_zip, ANY c_street_number, ANY c_street_name, ANY c_city, ANY c_zip, ANY syear, ANY fsyear, ANY s2year, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 1.4399939995E9, cumulative cost = {5.651462685155E10 rows, 8.6212159972595E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180172
      06-03                                    Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$12], sr_ticket_number=[$13], cs_item_sk=[$14], d_date_sk=[$15], d_year=[$16], d_date_sk0=[$17], d_year0=[$18], d_date_sk1=[$19], d_year1=[$20], s_store_sk=[$21], s_store_name=[$22], s_zip=[$23], c_customer_sk=[$24], c_current_cdemo_sk=[$25], c_current_hdemo_sk=[$26], c_current_addr_sk=[$27], c_first_shipto_date_sk=[$28], c_first_sales_date_sk=[$29], cd_demo_sk=[$30], cd_marital_status=[$31], cd_demo_sk0=[$32], cd_marital_status0=[$33], p_promo_sk=[$34], hd_demo_sk=[$35], hd_income_band_sk=[$36], hd_demo_sk0=[$38], hd_income_band_sk0=[$39], ca_address_sk=[$45], ca_street_number=[$46], ca_street_name=[$47], ca_city=[$48], ca_zip=[$49], ca_address_sk0=[$50], ca_street_number0=[$51], ca_street_name0=[$52], ca_city0=[$53], ca_zip0=[$54], ib_income_band_sk=[$37], ib_income_band_sk0=[$40], i_item_sk=[$41], i_current_price=[$42], i_color=[$43], i_product_name=[$44]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0, ANY ib_income_band_sk, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.507463285205E10 rows, 8.3620170773495E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180171
      06-04                                      HashJoin(condition=[=($27, $50)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip, ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 1.4399939995E9, cumulative cost = {5.363463885255E10 rows, 7.5700203776245E11 cpu, 4.0317135384E10 io, 6.041565610351411E14 network, 3.850891772904001E10 memory}, id = 180170
      06-06                                        HashJoin(condition=[=($5, $45)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name, ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 1.4399939995E9, cumulative cost = {5.217064485305E10 rows, 7.3956610976845E11 cpu, 4.0287135384E10 io, 6.030383530351411E14 network, 3.840331772904001E10 memory}, id = 180166
      06-09                                          HashJoin(condition=[=($1, $41)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0, ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 1.4399939995E9, cumulative cost = {5.071265085355E10 rows, 7.2216018177445E11 cpu, 4.0257135384E10 io, 6.019201450351411E14 network, 3.829771772904001E10 memory}, id = 180163
      06-11                                            HashJoin(condition=[=($26, $38)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk, ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 1.4399939995E9, cumulative cost = {4.927200622905E10 rows, 7.0487697440545E11 cpu, 4.0255935384E10 io, 6.019176290671411E14 network, 3.829742072904001E10 memory}, id = 180158
      06-13                                              HashJoin(condition=[=($4, $35)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk, ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 1.4399939995E9, cumulative cost = {4.783197618955E10 rows, 6.8759680863145E11 cpu, 4.0255920964E10 io, 6.019168239573811E14 network, 3.829729365704001E10 memory}, id = 180152
      06-16                                                HashJoin(condition=[=($7, $34)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0, ANY p_promo_sk): rowcount = 1.4399939995E9, cumulative cost = {4.639195335005E10 rows, 6.7031666445745E11 cpu, 4.0255906544E10 io, 6.019160188476211E14 network, 3.829716658504001E10 memory}, id = 180147
      06-18                                                  SelectionVectorRemover : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.495195485055E10 rows, 6.5303671096345E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180144
      06-19                                                    Filter(condition=[<>($31, $33)]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 1.4399939995E9, cumulative cost = {4.351196085105E10 rows, 6.5159671696395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180143
      06-20                                                      Project(ss_sold_date_sk=[$0], ss_item_sk=[$1], ss_customer_sk=[$2], ss_cdemo_sk=[$3], ss_hdemo_sk=[$4], ss_addr_sk=[$5], ss_store_sk=[$6], ss_promo_sk=[$7], ss_ticket_number=[$8], ss_wholesale_cost=[$9], ss_list_price=[$10], ss_coupon_amt=[$11], sr_item_sk=[$15], sr_ticket_number=[$16], cs_item_sk=[$12], d_date_sk=[$13], d_year=[$14], d_date_sk0=[$30], d_year0=[$31], d_date_sk1=[$32], d_year1=[$33], s_store_sk=[$19], s_store_name=[$20], s_zip=[$21], c_customer_sk=[$22], c_current_cdemo_sk=[$23], c_current_hdemo_sk=[$24], c_current_addr_sk=[$25], c_first_shipto_date_sk=[$26], c_first_sales_date_sk=[$27], cd_demo_sk=[$17], cd_marital_status=[$18], cd_demo_sk0=[$28], cd_marital_status0=[$29]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY sr_item_sk, ANY sr_ticket_number, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0, ANY d_date_sk1, ANY d_year1, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY cd_demo_sk0, ANY cd_marital_status0): rowcount = 2.879987999E9, cumulative cost = {4.063197285205E10 rows, 6.3431678896995E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180142
      06-21                                                        HashJoin(condition=[=($2, $22)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip, ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 2.879987999E9, cumulative cost = {3.775198485305E10 rows, 5.3639719700395E11 cpu, 4.0255905044E10 io, 6.019159629372211E14 network, 3.829714018504001E10 memory}, id = 180141
      06-23                                                          HashToRandomExchange(dist0=[[$2]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.478172311105E10 rows, 5.0086399075395E11 cpu, 4.0179771248E10 io, 6.011720574786355E14 network, 3.8049562780240005E10 memory}, id = 180127
      08-01                                                            HashJoin(condition=[=($6, $19)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status, ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 2.879987999E9, cumulative cost = {3.190173511205E10 rows, 4.5478418276995E11 cpu, 4.0179771248E10 io, 3.416505789127475E14 network, 3.8049562780240005E10 memory}, id = 180126
      08-03                                                              HashJoin(condition=[=($3, $17)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 2.879987999E9, cumulative cost = {2.902174410705E10 rows, 4.2022430774395E11 cpu, 4.0179768242E10 io, 3.416504668683059E14 network, 3.804954514504001E10 memory}, id = 180123
      08-05                                                                HashJoin(condition=[AND(=($1, $15), =($8, $16))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year, ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.879987999E9, cumulative cost = {2.613599370805E10 rows, 3.8562987735595E11 cpu, 4.0175926642E10 io, 3.415072766065459E14 network, 3.801573906504001E10 memory}, id = 180120
      08-07                                                                  HashToRandomExchange(dist0=[[$1]], dist1=[[$8]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {2.239200641705E10 rows, 3.0787017245995E11 cpu, 3.9599927114E10 io, 3.391479825398579E14 network, 3.0412545295440006E10 memory}, id = 180117
      24-01                                                                    HashJoin(condition=[=($0, $13)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk, ANY d_date_sk, ANY d_year): rowcount = 2.879987999E9, cumulative cost = {1.951201841805E10 rows, 2.7331031647195E11 cpu, 3.9599927114E10 io, 1.622015198812979E14 network, 3.0412545295440006E10 memory}, id = 180116
      24-03                                                                      HashJoin(condition=[=($1, $12)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt, ANY cs_item_sk): rowcount = 2.879987999E9, cumulative cost = {1.6631851449E10 rows, 2.387497920856E11 cpu, 3.9599781016E10 io, 1.62200703041536E14 network, 3.0412352446080006E10 memory}, id = 180111
      24-05                                                                        HashToRandomExchange(dist0=[[$1]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {5.759975998E9 rows, 8.0639663972E10 cpu, 3.4559855988E10 io, 1.41557170126848E14 network, 0.0 memory}, id = 180100
      38-01                                                                          Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_sales, numFiles=1, numRowGroups=1600, usedMetadataFile=false, columns=[`ss_sold_date_sk`, `ss_item_sk`, `ss_customer_sk`, `ss_cdemo_sk`, `ss_hdemo_sk`, `ss_addr_sk`, `ss_store_sk`, `ss_promo_sk`, `ss_ticket_number`, `ss_wholesale_cost`, `ss_list_price`, `ss_coupon_amt`]]]) : rowType = RecordType(ANY ss_sold_date_sk, ANY ss_item_sk, ANY ss_customer_sk, ANY ss_cdemo_sk, ANY ss_hdemo_sk, ANY ss_addr_sk, ANY ss_store_sk, ANY ss_promo_sk, ANY ss_ticket_number, ANY ss_wholesale_cost, ANY ss_list_price, ANY ss_coupon_amt): rowcount = 2.879987999E9, cumulative cost = {2.879987999E9 rows, 3.4559855988E10 cpu, 3.4559855988E10 io, 0.0 network, 0.0 memory}, id = 180099
      24-04                                                                        Project(cs_item_sk=[$0]) : rowType = RecordType(ANY cs_item_sk): rowcount = 7.19990208E7, cumulative cost = {7.919888431200001E9 rows, 1.2297427995920001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180110
      24-06                                                                          SelectionVectorRemover : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.847889410400001E9 rows, 1.2290228093840001E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180109
      24-07                                                                            Filter(condition=[>($1, *(2, $2))]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 7.19990208E7, cumulative cost = {7.7758903896E9 rows, 1.228302819176E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180108
      24-08                                                                              HashAgg(group=[{0}], sale=[SUM($1)], refund=[SUM($2)]) : rowType = RecordType(ANY cs_item_sk, ANY sale, ANY refund): rowcount = 1.439980416E8, cumulative cost = {7.631892348E9 rows, 1.21966293668E11 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 2.9145169680000004E10 memory}, id = 180107
      24-09                                                                                Project(cs_item_sk=[$0], cs_ext_list_price=[$2], $f2=[+(+($5, $6), $7)]) : rowType = RecordType(ANY cs_item_sk, ANY cs_ext_list_price, ANY $f2): rowcount = 1.439980416E9, cumulative cost = {6.191911932E9 rows, 7.5886920356E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180106
      24-10                                                                                  HashJoin(condition=[AND(=($0, $3), =($1, $4))], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price, ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.439980416E9, cumulative cost = {4.751931516E9 rows, 6.724703786E10 cpu, 5.039925028E9 io, 2.0643532914688E13 network, 3.8015143584E9 memory}, id = 180105
      24-12                                                                                    HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {2.879960832E9 rows, 2.7359627904E10 cpu, 4.319941248E9 io, 1.7694479351808E13 network, 0.0 memory}, id = 180102
      39-01                                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_sales]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_sales]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_sales, numFiles=1, numRowGroups=1200, usedMetadataFile=false, columns=[`cs_item_sk`, `cs_order_number`, `cs_ext_list_price`]]]) : rowType = RecordType(ANY cs_item_sk, ANY cs_order_number, ANY cs_ext_list_price): rowcount = 1.439980416E9, cumulative cost = {1.439980416E9 rows, 4.319941248E9 cpu, 4.319941248E9 io, 0.0 network, 0.0 memory}, id = 180101
      24-11                                                                                    HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {2.87993512E8 rows, 3.023931876E9 cpu, 7.1998378E8 io, 2.94905356288E12 network, 0.0 memory}, id = 180104
      40-01                                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/catalog_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/catalog_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/catalog_returns, numFiles=1, numRowGroups=100, usedMetadataFile=false, columns=[`cr_item_sk`, `cr_order_number`, `cr_refunded_cash`, `cr_reversed_charge`, `cr_store_credit`]]]) : rowType = RecordType(ANY cr_item_sk, ANY cr_order_number, ANY cr_refunded_cash, ANY cr_reversed_charge, ANY cr_store_credit): rowcount = 1.43996756E8, cumulative cost = {1.43996756E8 rows, 7.1998378E8 cpu, 7.1998378E8 io, 0.0 network, 0.0 memory}, id = 180103
      24-02                                                                      BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {168012.7 rows, 580739.55 cpu, 146098.0 io, 8.1683976192E8 network, 0.0 memory}, id = 180115
      41-01                                                                        SelectionVectorRemover : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {157055.35 rows, 493080.75 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180114
      41-02                                                                          Filter(condition=[=($1, 2001)]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 10957.35, cumulative cost = {146098.0 rows, 482123.4 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180113
      41-03                                                                            Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180112
      08-06                                                                  HashToRandomExchange(dist0=[[$0]], dist1=[[$1]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {5.75999528E8 rows, 4.031996696E9 cpu, 5.75999528E8 io, 2.359294066688E12 network, 0.0 memory}, id = 180119
      25-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/store_returns]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store_returns]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store_returns, numFiles=1, numRowGroups=200, usedMetadataFile=false, columns=[`sr_item_sk`, `sr_ticket_number`]]]) : rowType = RecordType(ANY sr_item_sk, ANY sr_ticket_number): rowcount = 2.87999764E8, cumulative cost = {2.87999764E8 rows, 5.75999528E8 cpu, 5.75999528E8 io, 0.0 network, 0.0 memory}, id = 180118
      08-04                                                                BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180122
      26-01                                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180121
      08-02                                                              BroadcastExchange : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {2004.0 rows, 11022.0 cpu, 3006.0 io, 1.120444416E8 network, 0.0 memory}, id = 180125
      27-01                                                                Scan(table=[[dfs, /tpcdsParquet10/SF1000/store]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/store]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/store, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`s_store_sk`, `s_store_name`, `s_zip`]]]) : rowType = RecordType(ANY s_store_sk, ANY s_store_name, ANY s_zip): rowcount = 1002.0, cumulative cost = {1002.0 rows, 3006.0 cpu, 3006.0 io, 0.0 network, 0.0 memory}, id = 180124
      06-22                                                          Project(c_customer_sk=[$0], c_current_cdemo_sk=[$1], c_current_hdemo_sk=[$2], c_current_addr_sk=[$3], c_first_shipto_date_sk=[$4], c_first_sales_date_sk=[$5], cd_demo_sk0=[$6], cd_marital_status0=[$7], d_date_sk0=[$8], d_year0=[$9], d_date_sk00=[$10], d_year00=[$11]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk0, ANY cd_marital_status0, ANY d_date_sk0, ANY d_year0, ANY d_date_sk00, ANY d_year00): rowcount = 1.2E7, cumulative cost = {7.8273743E7 rows, 8.77350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180140
      06-24                                                            HashToRandomExchange(dist0=[[$0]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {6.6273743E7 rows, 7.33350262E8 cpu, 7.6133796E7 io, 7.439054585856E11 network, 3.63774048E7 memory}, id = 180139
      09-01                                                              HashJoin(condition=[=($10, $4)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year, ANY d_date_sk0, ANY d_year0): rowcount = 1.2E7, cumulative cost = {5.4273743E7 rows, 5.41350262E8 cpu, 7.6133796E7 io, 1.5408145858559998E11 network, 3.63774048E7 memory}, id = 180138
      09-03                                                                HashJoin(condition=[=($8, $5)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status, ANY d_date_sk, ANY d_year): rowcount = 1.2E7, cumulative cost = {4.1981547E7 rows, 3.95889282E8 cpu, 7.5987698E7 io, 1.486358601728E11 network, 3.50917424E7 memory}, id = 180134
      09-06                                                                  HashJoin(condition=[=($1, $6)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk, ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1.2E7, cumulative cost = {2.97624E7 rows, 2.505744E8 cpu, 7.58416E7 io, 1.4319026176E11 network, 3.380608E7 memory}, id = 180131
      09-08                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer, numFiles=1, numRowGroups=6, usedMetadataFile=false, columns=[`c_customer_sk`, `c_current_cdemo_sk`, `c_current_hdemo_sk`, `c_current_addr_sk`, `c_first_shipto_date_sk`, `c_first_sales_date_sk`]]]) : rowType = RecordType(ANY c_customer_sk, ANY c_current_cdemo_sk, ANY c_current_hdemo_sk, ANY c_current_addr_sk, ANY c_first_shipto_date_sk, ANY c_first_sales_date_sk): rowcount = 1.2E7, cumulative cost = {1.2E7 rows, 7.2E7 cpu, 7.2E7 io, 0.0 network, 0.0 memory}, id = 180128
      09-07                                                                    BroadcastExchange : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {3841600.0 rows, 1.9208E7 cpu, 3841600.0 io, 1.4319026176E11 network, 0.0 memory}, id = 180130
      28-01                                                                      Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`cd_demo_sk`, `cd_marital_status`]]]) : rowType = RecordType(ANY cd_demo_sk, ANY cd_marital_status): rowcount = 1920800.0, cumulative cost = {1920800.0 rows, 3841600.0 cpu, 3841600.0 io, 0.0 network, 0.0 memory}, id = 180129
      09-05                                                                  BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180133
      29-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180132
      09-02                                                                Project(d_date_sk0=[$0], d_year0=[$1]) : rowType = RecordType(ANY d_date_sk0, ANY d_year0): rowcount = 73049.0, cumulative cost = {219147.0 rows, 876588.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180137
      09-04                                                                  BroadcastExchange : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {146098.0 rows, 730490.0 cpu, 146098.0 io, 5.4455984128E9 network, 0.0 memory}, id = 180136
      30-01                                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/date_dim]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/date_dim]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/date_dim, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`d_date_sk`, `d_year`]]]) : rowType = RecordType(ANY d_date_sk, ANY d_year): rowcount = 73049.0, cumulative cost = {73049.0 rows, 146098.0 cpu, 146098.0 io, 0.0 network, 0.0 memory}, id = 180135
      06-17                                                  BroadcastExchange : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {3000.0 rows, 13500.0 cpu, 1500.0 io, 5.59104E7 network, 0.0 memory}, id = 180146
      10-01                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/promotion]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/promotion]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/promotion, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`p_promo_sk`]]]) : rowType = RecordType(ANY p_promo_sk): rowcount = 1500.0, cumulative cost = {1500.0 rows, 1500.0 cpu, 1500.0 io, 0.0 network, 0.0 memory}, id = 180145
      06-15                                                BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180151
      11-01                                                  HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180150
      11-03                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180148
      11-02                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180149
      06-12                                              Project(hd_demo_sk0=[$0], hd_income_band_sk0=[$1], ib_income_band_sk0=[$2]) : rowType = RecordType(ANY hd_demo_sk0, ANY hd_income_band_sk0, ANY ib_income_band_sk0): rowcount = 7200.0, cumulative cost = {28840.0 rows, 180180.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180157
      06-14                                                BroadcastExchange : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {21640.0 rows, 158580.0 cpu, 14420.0 io, 8.0510976E8 network, 352.0 memory}, id = 180156
      12-01                                                  HashJoin(condition=[=($1, $2)], joinType=[inner], semi-join: =[false]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk, ANY ib_income_band_sk): rowcount = 7200.0, cumulative cost = {14440.0 rows, 100980.0 cpu, 14420.0 io, 0.0 network, 352.0 memory}, id = 180155
      12-03                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/household_demographics]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/household_demographics]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/household_demographics, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`hd_demo_sk`, `hd_income_band_sk`]]]) : rowType = RecordType(ANY hd_demo_sk, ANY hd_income_band_sk): rowcount = 7200.0, cumulative cost = {7200.0 rows, 14400.0 cpu, 14400.0 io, 0.0 network, 0.0 memory}, id = 180153
      12-02                                                    Scan(table=[[dfs, /tpcdsParquet10/SF1000/income_band]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/income_band]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/income_band, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`ib_income_band_sk`]]]) : rowType = RecordType(ANY ib_income_band_sk): rowcount = 20.0, cumulative cost = {20.0 rows, 20.0 cpu, 20.0 io, 0.0 network, 0.0 memory}, id = 180154
      06-10                                            BroadcastExchange : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {633750.0 rows, 3144375.0 cpu, 1200000.0 io, 2.515968E9 network, 0.0 memory}, id = 180162
      13-01                                              SelectionVectorRemover : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {616875.0 rows, 3009375.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180161
      13-02                                                Filter(condition=[AND(OR(=($2, 'cyan'), =($2, 'peach'), =($2, 'blush'), =($2, 'frosted'), =($2, 'powder'), =($2, 'orange')), <=($1, 68), >=($1, 59), IS NOT NULL($0))]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 16875.0, cumulative cost = {600000.0 rows, 2992500.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180160
      13-03                                                  Scan(table=[[dfs, /tpcdsParquet10/SF1000/item]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/item]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/item, numFiles=1, numRowGroups=1, usedMetadataFile=false, columns=[`i_item_sk`, `i_current_price`, `i_color`, `i_product_name`]]]) : rowType = RecordType(ANY i_item_sk, ANY i_current_price, ANY i_color, ANY i_product_name): rowcount = 300000.0, cumulative cost = {300000.0 rows, 1200000.0 cpu, 1200000.0 io, 0.0 network, 0.0 memory}, id = 180159
      06-08                                          BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180165
      14-01                                            Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180164
      06-05                                        Project(ca_address_sk0=[$0], ca_street_number0=[$1], ca_street_name0=[$2], ca_city0=[$3], ca_zip0=[$4]) : rowType = RecordType(ANY ca_address_sk0, ANY ca_street_number0, ANY ca_street_name0, ANY ca_city0, ANY ca_zip0): rowcount = 6000000.0, cumulative cost = {1.8E7 rows, 1.08E8 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180169
      06-07                                          BroadcastExchange : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {1.2E7 rows, 7.8E7 cpu, 3.0E7 io, 1.118208E12 network, 0.0 memory}, id = 180168
      15-01                                            Scan(table=[[dfs, /tpcdsParquet10/SF1000/customer_address]], groupscan=[ParquetGroupScan [entries=[ReadEntryWithPath [path=maprfs:///tpcdsParquet10/SF1000/customer_address]], selectionRoot=maprfs:/tpcdsParquet10/SF1000/customer_address, numFiles=1, numRowGroups=3, usedMetadataFile=false, columns=[`ca_address_sk`, `ca_street_number`, `ca_street_name`, `ca_city`, `ca_zip`]]]) : rowType = RecordType(ANY ca_address_sk, ANY ca_street_number, ANY ca_street_name, ANY ca_city, ANY ca_zip): rowcount = 6000000.0, cumulative cost = {6000000.0 rows, 3.0E7 cpu, 3.0E7 io, 0.0 network, 0.0 memory}, id = 180167
      

      I tested with commit be73250e68ffd836541223cf4aca395896362866, and it did not exhibit this problem.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                gparai Gautam Parai
                Reporter:
                rhou Robert Hou
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: