testdata/workloads/functional-planner/queries/PlannerTest/tpcds/tpcds-q75.test

# TPCDS-Q75
WITH all_sales AS
  ( SELECT d_year ,
           i_brand_id ,
           i_class_id ,
           i_category_id ,
           i_manufact_id ,
           SUM(sales_cnt) AS sales_cnt ,
           SUM(sales_amt) AS sales_amt
   FROM
     (SELECT d_year ,
             i_brand_id ,
             i_class_id ,
             i_category_id ,
             i_manufact_id ,
             cs_quantity - COALESCE(cr_return_quantity,0) AS sales_cnt ,
             cs_ext_sales_price - COALESCE(cr_return_amount,0.0) AS sales_amt
      FROM catalog_sales
      JOIN item ON i_item_sk=cs_item_sk
      JOIN date_dim ON d_date_sk=cs_sold_date_sk
      LEFT JOIN catalog_returns ON (cs_order_number=cr_order_number
                                    AND cs_item_sk=cr_item_sk)
      WHERE i_category='Books'
      UNION SELECT d_year ,
                   i_brand_id ,
                   i_class_id ,
                   i_category_id ,
                   i_manufact_id ,
                   ss_quantity - COALESCE(sr_return_quantity,0) AS sales_cnt ,
                   ss_ext_sales_price - COALESCE(sr_return_amt,0.0) AS sales_amt
      FROM store_sales
      JOIN item ON i_item_sk=ss_item_sk
      JOIN date_dim ON d_date_sk=ss_sold_date_sk
      LEFT JOIN store_returns ON (ss_ticket_number=sr_ticket_number
                                  AND ss_item_sk=sr_item_sk)
      WHERE i_category='Books'
      UNION SELECT d_year ,
                   i_brand_id ,
                   i_class_id ,
                   i_category_id ,
                   i_manufact_id ,
                   ws_quantity - COALESCE(wr_return_quantity,0) AS sales_cnt ,
                   ws_ext_sales_price - COALESCE(wr_return_amt,0.0) AS sales_amt
      FROM web_sales
      JOIN item ON i_item_sk=ws_item_sk
      JOIN date_dim ON d_date_sk=ws_sold_date_sk
      LEFT JOIN web_returns ON (ws_order_number=wr_order_number
                                AND ws_item_sk=wr_item_sk)
      WHERE i_category='Books') sales_detail
   GROUP BY d_year,
            i_brand_id,
            i_class_id,
            i_category_id,
            i_manufact_id)
SELECT prev_yr.d_year AS prev_year ,
       curr_yr.d_year AS year_ ,
       curr_yr.i_brand_id ,
       curr_yr.i_class_id ,
       curr_yr.i_category_id ,
       curr_yr.i_manufact_id ,
       prev_yr.sales_cnt AS prev_yr_cnt ,
       curr_yr.sales_cnt AS curr_yr_cnt ,
       curr_yr.sales_cnt-prev_yr.sales_cnt AS sales_cnt_diff ,
       curr_yr.sales_amt-prev_yr.sales_amt AS sales_amt_diff
FROM all_sales curr_yr,
     all_sales prev_yr
WHERE curr_yr.i_brand_id=prev_yr.i_brand_id
  AND curr_yr.i_class_id=prev_yr.i_class_id
  AND curr_yr.i_category_id=prev_yr.i_category_id
  AND curr_yr.i_manufact_id=prev_yr.i_manufact_id
  AND curr_yr.d_year=2002
  AND prev_yr.d_year=2002-1
  AND CAST(curr_yr.sales_cnt AS DECIMAL(17,2))/CAST(prev_yr.sales_cnt AS DECIMAL(17,2))<0.9
ORDER BY sales_cnt_diff,
         sales_amt_diff
LIMIT 100;

---- PLAN
Max Per-Host Resource Reservation: Memory=60.75MB Threads=9
Per-Host Resource Estimates: Memory=966MB
F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=965.75MB mem-reservation=60.75MB thread-reservation=9 runtime-filters-memory=10.00MB
PLAN-ROOT SINK
|  output exprs: d_year, d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_cnt, sales_cnt - sales_cnt, sales_amt - sales_amt
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
49:TOP-N [LIMIT=100]
|  order by: sales_cnt - sales_cnt ASC, sales_amt - sales_amt ASC
|  mem-estimate=7.03KB mem-reservation=0B thread-reservation=0
|  tuple-ids=32 row-size=72B cardinality=100
|  in pipelines: 49(GETNEXT), 23(OPEN)
|
48:HASH JOIN [INNER JOIN]
|  hash predicates: i_brand_id = i_brand_id, i_category_id = i_category_id, i_class_id = i_class_id, i_manufact_id = i_manufact_id
|  fk/pk conjuncts: assumed fk/pk
|  other predicates: CAST(sum(sales_cnt) AS DECIMAL(17,2)) / CAST(sum(sales_cnt) AS DECIMAL(17,2)) < CAST(0.9 AS DECIMAL(1,1))
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=14,30 row-size=88B cardinality=175
|  in pipelines: 23(GETNEXT), 47(OPEN)
|
|--47:AGGREGATE [FINALIZE]
|  |  output: sum(sales_cnt), sum(sales_amt)
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  |  having: d_year = CAST(2001 AS INT)
|  |  mem-estimate=10.00MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=175
|  |  in pipelines: 47(GETNEXT), 46(OPEN)
|  |
|  46:AGGREGATE [FINALIZE]
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  |  mem-estimate=10.00MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 46(GETNEXT), 28(OPEN), 35(OPEN), 42(OPEN)
|  |
|  24:UNION
|  |  mem-estimate=0B mem-reservation=0B thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 28(GETNEXT), 35(GETNEXT), 42(GETNEXT)
|  |
|  |--45:HASH JOIN [RIGHT OUTER JOIN]
|  |  |  hash predicates: wr_item_sk = ws_item_sk, wr_order_number = ws_order_number
|  |  |  fk/pk conjuncts: wr_item_sk = ws_item_sk, wr_order_number = ws_order_number
|  |  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  |  tuple-ids=27N,24,25,26 row-size=102B cardinality=14.80K
|  |  |  in pipelines: 42(GETNEXT), 39(OPEN)
|  |  |
|  |  |--44:HASH JOIN [INNER JOIN]
|  |  |  |  hash predicates: ws_sold_date_sk = d_date_sk
|  |  |  |  fk/pk conjuncts: ws_sold_date_sk = d_date_sk
|  |  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |  tuple-ids=24,25,26 row-size=78B cardinality=14.80K
|  |  |  |  in pipelines: 39(GETNEXT), 41(OPEN)
|  |  |  |
|  |  |  |--41:SCAN HDFS [tpcds_parquet.date_dim]
|  |  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |  |     stored statistics:
|  |  |  |       table: rows=73.05K size=2.15MB
|  |  |  |       columns: all
|  |  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |  |     tuple-ids=26 row-size=8B cardinality=373
|  |  |  |     in pipelines: 41(GETNEXT)
|  |  |  |
|  |  |  43:HASH JOIN [INNER JOIN]
|  |  |  |  hash predicates: ws_item_sk = i_item_sk
|  |  |  |  fk/pk conjuncts: ws_item_sk = i_item_sk
|  |  |  |  runtime filters: RF054[bloom] <- i_item_sk
|  |  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |  tuple-ids=24,25 row-size=70B cardinality=71.94K
|  |  |  |  in pipelines: 39(GETNEXT), 40(OPEN)
|  |  |  |
|  |  |  |--40:SCAN HDFS [tpcds_parquet.item]
|  |  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |  |     predicates: i_category = 'Books'
|  |  |  |     stored statistics:
|  |  |  |       table: rows=18.00K size=1.73MB
|  |  |  |       columns: all
|  |  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |  |     tuple-ids=25 row-size=42B cardinality=1.80K
|  |  |  |     in pipelines: 40(GETNEXT)
|  |  |  |
|  |  |  39:SCAN HDFS [tpcds_parquet.web_sales]
|  |  |     HDFS partitions=1/1 files=2 size=45.09MB
|  |  |     runtime filters: RF054[bloom] -> ws_item_sk
|  |  |     stored statistics:
|  |  |       table: rows=719.38K size=45.09MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=644.77K
|  |  |     mem-estimate=160.00MB mem-reservation=8.00MB thread-reservation=1
|  |  |     tuple-ids=24 row-size=28B cardinality=719.38K
|  |  |     in pipelines: 39(GETNEXT)
|  |  |
|  |  42:SCAN HDFS [tpcds_parquet.web_returns]
|  |     HDFS partitions=1/1 files=1 size=5.66MB
|  |     stored statistics:
|  |       table: rows=71.76K size=5.66MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=71.76K
|  |     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=27 row-size=24B cardinality=71.76K
|  |     in pipelines: 42(GETNEXT)
|  |
|  |--38:HASH JOIN [RIGHT OUTER JOIN]
|  |  |  hash predicates: sr_item_sk = ss_item_sk, sr_ticket_number = ss_ticket_number
|  |  |  fk/pk conjuncts: sr_item_sk = ss_item_sk, sr_ticket_number = ss_ticket_number
|  |  |  mem-estimate=8.50MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  |  |  tuple-ids=23N,20,21,22 row-size=102B cardinality=58.90K
|  |  |  in pipelines: 35(GETNEXT), 32(OPEN)
|  |  |
|  |  |--37:HASH JOIN [INNER JOIN]
|  |  |  |  hash predicates: ss_sold_date_sk = d_date_sk
|  |  |  |  fk/pk conjuncts: ss_sold_date_sk = d_date_sk
|  |  |  |  runtime filters: RF044[bloom] <- d_date_sk
|  |  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |  tuple-ids=20,21,22 row-size=78B cardinality=58.90K
|  |  |  |  in pipelines: 32(GETNEXT), 34(OPEN)
|  |  |  |
|  |  |  |--34:SCAN HDFS [tpcds_parquet.date_dim]
|  |  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |  |     stored statistics:
|  |  |  |       table: rows=73.05K size=2.15MB
|  |  |  |       columns: all
|  |  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |  |     tuple-ids=22 row-size=8B cardinality=373
|  |  |  |     in pipelines: 34(GETNEXT)
|  |  |  |
|  |  |  36:HASH JOIN [INNER JOIN]
|  |  |  |  hash predicates: ss_item_sk = i_item_sk
|  |  |  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  |  |  runtime filters: RF046[bloom] <- i_item_sk
|  |  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |  tuple-ids=20,21 row-size=70B cardinality=288.04K
|  |  |  |  in pipelines: 32(GETNEXT), 33(OPEN)
|  |  |  |
|  |  |  |--33:SCAN HDFS [tpcds_parquet.item]
|  |  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |  |     predicates: i_category = 'Books'
|  |  |  |     stored statistics:
|  |  |  |       table: rows=18.00K size=1.73MB
|  |  |  |       columns: all
|  |  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |  |     tuple-ids=21 row-size=42B cardinality=1.80K
|  |  |  |     in pipelines: 33(GETNEXT)
|  |  |  |
|  |  |  32:SCAN HDFS [tpcds_parquet.store_sales]
|  |  |     HDFS partitions=1824/1824 files=1824 size=201.02MB
|  |  |     runtime filters: RF046[bloom] -> ss_item_sk, RF044[bloom] -> ss_sold_date_sk
|  |  |     stored statistics:
|  |  |       table: rows=2.88M size=201.02MB
|  |  |       partitions: 1824/1824 rows=2.88M
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=130.09K
|  |  |     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|  |  |     tuple-ids=20 row-size=28B cardinality=2.88M
|  |  |     in pipelines: 32(GETNEXT)
|  |  |
|  |  35:SCAN HDFS [tpcds_parquet.store_returns]
|  |     HDFS partitions=1/1 files=1 size=15.43MB
|  |     stored statistics:
|  |       table: rows=287.51K size=15.43MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=287.51K
|  |     mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
|  |     tuple-ids=23 row-size=24B cardinality=287.51K
|  |     in pipelines: 35(GETNEXT)
|  |
|  31:HASH JOIN [RIGHT OUTER JOIN]
|  |  hash predicates: cr_item_sk = cs_item_sk, cr_order_number = cs_order_number
|  |  fk/pk conjuncts: cr_item_sk = cs_item_sk, cr_order_number = cs_order_number
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=19N,16,17,18 row-size=102B cardinality=29.46K
|  |  in pipelines: 28(GETNEXT), 25(OPEN)
|  |
|  |--30:HASH JOIN [INNER JOIN]
|  |  |  hash predicates: cs_sold_date_sk = d_date_sk
|  |  |  fk/pk conjuncts: cs_sold_date_sk = d_date_sk
|  |  |  runtime filters: RF036[bloom] <- d_date_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=16,17,18 row-size=78B cardinality=29.46K
|  |  |  in pipelines: 25(GETNEXT), 27(OPEN)
|  |  |
|  |  |--27:SCAN HDFS [tpcds_parquet.date_dim]
|  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     stored statistics:
|  |  |       table: rows=73.05K size=2.15MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |     tuple-ids=18 row-size=8B cardinality=373
|  |  |     in pipelines: 27(GETNEXT)
|  |  |
|  |  29:HASH JOIN [INNER JOIN]
|  |  |  hash predicates: cs_item_sk = i_item_sk
|  |  |  fk/pk conjuncts: cs_item_sk = i_item_sk
|  |  |  runtime filters: RF038[bloom] <- i_item_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=16,17 row-size=70B cardinality=144.16K
|  |  |  in pipelines: 25(GETNEXT), 26(OPEN)
|  |  |
|  |  |--26:SCAN HDFS [tpcds_parquet.item]
|  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |     predicates: i_category = 'Books'
|  |  |     stored statistics:
|  |  |       table: rows=18.00K size=1.73MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |     tuple-ids=17 row-size=42B cardinality=1.80K
|  |  |     in pipelines: 26(GETNEXT)
|  |  |
|  |  25:SCAN HDFS [tpcds_parquet.catalog_sales]
|  |     HDFS partitions=1/1 files=3 size=96.62MB
|  |     runtime filters: RF038[bloom] -> cs_item_sk, RF036[bloom] -> cs_sold_date_sk
|  |     stored statistics:
|  |       table: rows=1.44M size=96.62MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=650.14K
|  |     mem-estimate=240.00MB mem-reservation=8.00MB thread-reservation=1
|  |     tuple-ids=16 row-size=28B cardinality=1.44M
|  |     in pipelines: 25(GETNEXT)
|  |
|  28:SCAN HDFS [tpcds_parquet.catalog_returns]
|     HDFS partitions=1/1 files=1 size=10.62MB
|     stored statistics:
|       table: rows=144.07K size=10.62MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=144.07K
|     mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=19 row-size=24B cardinality=144.07K
|     in pipelines: 28(GETNEXT)
|
23:AGGREGATE [FINALIZE]
|  output: sum(sales_cnt), sum(sales_amt)
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  having: d_year = CAST(2002 AS INT)
|  mem-estimate=10.00MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=175
|  in pipelines: 23(GETNEXT), 22(OPEN)
|
22:AGGREGATE [FINALIZE]
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  mem-estimate=10.00MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 22(GETNEXT), 04(OPEN), 11(OPEN), 18(OPEN)
|
00:UNION
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 04(GETNEXT), 11(GETNEXT), 18(GETNEXT)
|
|--21:HASH JOIN [RIGHT OUTER JOIN]
|  |  hash predicates: wr_item_sk = ws_item_sk, wr_order_number = ws_order_number
|  |  fk/pk conjuncts: wr_item_sk = ws_item_sk, wr_order_number = ws_order_number
|  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=11N,8,9,10 row-size=102B cardinality=14.80K
|  |  in pipelines: 18(GETNEXT), 15(OPEN)
|  |
|  |--20:HASH JOIN [INNER JOIN]
|  |  |  hash predicates: ws_sold_date_sk = d_date_sk
|  |  |  fk/pk conjuncts: ws_sold_date_sk = d_date_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=8,9,10 row-size=78B cardinality=14.80K
|  |  |  in pipelines: 15(GETNEXT), 17(OPEN)
|  |  |
|  |  |--17:SCAN HDFS [tpcds_parquet.date_dim]
|  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |  |     stored statistics:
|  |  |       table: rows=73.05K size=2.15MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |     tuple-ids=10 row-size=8B cardinality=373
|  |  |     in pipelines: 17(GETNEXT)
|  |  |
|  |  19:HASH JOIN [INNER JOIN]
|  |  |  hash predicates: ws_item_sk = i_item_sk
|  |  |  fk/pk conjuncts: ws_item_sk = i_item_sk
|  |  |  runtime filters: RF030[bloom] <- i_item_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=8,9 row-size=70B cardinality=71.94K
|  |  |  in pipelines: 15(GETNEXT), 16(OPEN)
|  |  |
|  |  |--16:SCAN HDFS [tpcds_parquet.item]
|  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |     predicates: i_category = 'Books'
|  |  |     stored statistics:
|  |  |       table: rows=18.00K size=1.73MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |     tuple-ids=9 row-size=42B cardinality=1.80K
|  |  |     in pipelines: 16(GETNEXT)
|  |  |
|  |  15:SCAN HDFS [tpcds_parquet.web_sales]
|  |     HDFS partitions=1/1 files=2 size=45.09MB
|  |     runtime filters: RF030[bloom] -> ws_item_sk
|  |     stored statistics:
|  |       table: rows=719.38K size=45.09MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=644.77K
|  |     mem-estimate=160.00MB mem-reservation=8.00MB thread-reservation=1
|  |     tuple-ids=8 row-size=28B cardinality=719.38K
|  |     in pipelines: 15(GETNEXT)
|  |
|  18:SCAN HDFS [tpcds_parquet.web_returns]
|     HDFS partitions=1/1 files=1 size=5.66MB
|     stored statistics:
|       table: rows=71.76K size=5.66MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=71.76K
|     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|     tuple-ids=11 row-size=24B cardinality=71.76K
|     in pipelines: 18(GETNEXT)
|
|--14:HASH JOIN [RIGHT OUTER JOIN]
|  |  hash predicates: sr_item_sk = ss_item_sk, sr_ticket_number = ss_ticket_number
|  |  fk/pk conjuncts: sr_item_sk = ss_item_sk, sr_ticket_number = ss_ticket_number
|  |  mem-estimate=8.50MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  |  tuple-ids=7N,4,5,6 row-size=102B cardinality=58.90K
|  |  in pipelines: 11(GETNEXT), 08(OPEN)
|  |
|  |--13:HASH JOIN [INNER JOIN]
|  |  |  hash predicates: ss_sold_date_sk = d_date_sk
|  |  |  fk/pk conjuncts: ss_sold_date_sk = d_date_sk
|  |  |  runtime filters: RF020[bloom] <- d_date_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=4,5,6 row-size=78B cardinality=58.90K
|  |  |  in pipelines: 08(GETNEXT), 10(OPEN)
|  |  |
|  |  |--10:SCAN HDFS [tpcds_parquet.date_dim]
|  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |  |     stored statistics:
|  |  |       table: rows=73.05K size=2.15MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |     tuple-ids=6 row-size=8B cardinality=373
|  |  |     in pipelines: 10(GETNEXT)
|  |  |
|  |  12:HASH JOIN [INNER JOIN]
|  |  |  hash predicates: ss_item_sk = i_item_sk
|  |  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  |  runtime filters: RF022[bloom] <- i_item_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=4,5 row-size=70B cardinality=288.04K
|  |  |  in pipelines: 08(GETNEXT), 09(OPEN)
|  |  |
|  |  |--09:SCAN HDFS [tpcds_parquet.item]
|  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |     predicates: i_category = 'Books'
|  |  |     stored statistics:
|  |  |       table: rows=18.00K size=1.73MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |     tuple-ids=5 row-size=42B cardinality=1.80K
|  |  |     in pipelines: 09(GETNEXT)
|  |  |
|  |  08:SCAN HDFS [tpcds_parquet.store_sales]
|  |     HDFS partitions=1824/1824 files=1824 size=201.02MB
|  |     runtime filters: RF022[bloom] -> ss_item_sk, RF020[bloom] -> ss_sold_date_sk
|  |     stored statistics:
|  |       table: rows=2.88M size=201.02MB
|  |       partitions: 1824/1824 rows=2.88M
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=130.09K
|  |     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=4 row-size=28B cardinality=2.88M
|  |     in pipelines: 08(GETNEXT)
|  |
|  11:SCAN HDFS [tpcds_parquet.store_returns]
|     HDFS partitions=1/1 files=1 size=15.43MB
|     stored statistics:
|       table: rows=287.51K size=15.43MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=287.51K
|     mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=7 row-size=24B cardinality=287.51K
|     in pipelines: 11(GETNEXT)
|
07:HASH JOIN [RIGHT OUTER JOIN]
|  hash predicates: cr_item_sk = cs_item_sk, cr_order_number = cs_order_number
|  fk/pk conjuncts: cr_item_sk = cs_item_sk, cr_order_number = cs_order_number
|  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  tuple-ids=3N,0,1,2 row-size=102B cardinality=29.46K
|  in pipelines: 04(GETNEXT), 01(OPEN)
|
|--06:HASH JOIN [INNER JOIN]
|  |  hash predicates: cs_sold_date_sk = d_date_sk
|  |  fk/pk conjuncts: cs_sold_date_sk = d_date_sk
|  |  runtime filters: RF012[bloom] <- d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=0,1,2 row-size=78B cardinality=29.46K
|  |  in pipelines: 01(GETNEXT), 03(OPEN)
|  |
|  |--03:SCAN HDFS [tpcds_parquet.date_dim]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     stored statistics:
|  |       table: rows=73.05K size=2.15MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |     tuple-ids=2 row-size=8B cardinality=373
|  |     in pipelines: 03(GETNEXT)
|  |
|  05:HASH JOIN [INNER JOIN]
|  |  hash predicates: cs_item_sk = i_item_sk
|  |  fk/pk conjuncts: cs_item_sk = i_item_sk
|  |  runtime filters: RF014[bloom] <- i_item_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=0,1 row-size=70B cardinality=144.16K
|  |  in pipelines: 01(GETNEXT), 02(OPEN)
|  |
|  |--02:SCAN HDFS [tpcds_parquet.item]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     predicates: i_category = 'Books'
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     parquet statistics predicates: i_category = 'Books'
|  |     parquet dictionary predicates: i_category = 'Books'
|  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |     tuple-ids=1 row-size=42B cardinality=1.80K
|  |     in pipelines: 02(GETNEXT)
|  |
|  01:SCAN HDFS [tpcds_parquet.catalog_sales]
|     HDFS partitions=1/1 files=3 size=96.62MB
|     runtime filters: RF014[bloom] -> cs_item_sk, RF012[bloom] -> cs_sold_date_sk
|     stored statistics:
|       table: rows=1.44M size=96.62MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=650.14K
|     mem-estimate=240.00MB mem-reservation=8.00MB thread-reservation=1
|     tuple-ids=0 row-size=28B cardinality=1.44M
|     in pipelines: 01(GETNEXT)
|
04:SCAN HDFS [tpcds_parquet.catalog_returns]
   HDFS partitions=1/1 files=1 size=10.62MB
   stored statistics:
     table: rows=144.07K size=10.62MB
     columns: all
   extrapolated-rows=disabled max-scan-range-rows=144.07K
   mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
   tuple-ids=3 row-size=24B cardinality=144.07K
   in pipelines: 04(GETNEXT)
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=136.44MB Threads=56
Per-Host Resource Estimates: Memory=2.30GB
F37:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=24.61KB mem-reservation=0B thread-reservation=1
PLAN-ROOT SINK
|  output exprs: d_year, d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_cnt, sales_cnt - sales_cnt, sales_amt - sales_amt
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
84:MERGING-EXCHANGE [UNPARTITIONED]
|  order by: sales_cnt - sales_cnt ASC, sales_amt - sales_amt ASC
|  limit: 100
|  mem-estimate=24.61KB mem-reservation=0B thread-reservation=0
|  tuple-ids=32 row-size=72B cardinality=100
|  in pipelines: 49(GETNEXT)
|
F36:PLAN FRAGMENT [HASH(i_brand_id,i_category_id,i_class_id,i_manufact_id)] hosts=3 instances=3
Per-Host Resources: mem-estimate=1.99MB mem-reservation=1.94MB thread-reservation=1
49:TOP-N [LIMIT=100]
|  order by: sales_cnt - sales_cnt ASC, sales_amt - sales_amt ASC
|  mem-estimate=7.03KB mem-reservation=0B thread-reservation=0
|  tuple-ids=32 row-size=72B cardinality=100
|  in pipelines: 49(GETNEXT), 65(OPEN)
|
48:HASH JOIN [INNER JOIN, PARTITIONED]
|  hash predicates: i_brand_id = i_brand_id, i_category_id = i_category_id, i_class_id = i_class_id, i_manufact_id = i_manufact_id
|  fk/pk conjuncts: assumed fk/pk
|  other predicates: CAST(sum(sales_cnt) AS DECIMAL(17,2)) / CAST(sum(sales_cnt) AS DECIMAL(17,2)) < CAST(0.9 AS DECIMAL(1,1))
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=14,30 row-size=88B cardinality=175
|  in pipelines: 65(GETNEXT), 81(OPEN)
|
|--83:EXCHANGE [HASH(i_brand_id,i_category_id,i_class_id,i_manufact_id)]
|  |  mem-estimate=27.12KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=175
|  |  in pipelines: 81(GETNEXT)
|  |
|  F35:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=11.58MB mem-reservation=4.75MB thread-reservation=1
|  81:AGGREGATE [FINALIZE]
|  |  output: sum:merge(sales_cnt), sum:merge(sales_amt)
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  |  having: d_year = CAST(2001 AS INT)
|  |  mem-estimate=10.00MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=175
|  |  in pipelines: 81(GETNEXT), 79(OPEN)
|  |
|  80:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)]
|  |  mem-estimate=1.58MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=103.17K
|  |  in pipelines: 79(GETNEXT)
|  |
|  F34:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=21.15MB mem-reservation=7.88MB thread-reservation=1
|  47:AGGREGATE [STREAMING]
|  |  output: sum(sales_cnt), sum(sales_amt)
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  |  mem-estimate=10.00MB mem-reservation=5.00MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=103.17K
|  |  in pipelines: 79(GETNEXT)
|  |
|  79:AGGREGATE [FINALIZE]
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  |  mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 79(GETNEXT), 25(OPEN), 32(OPEN), 39(OPEN)
|  |
|  78:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)]
|  |  mem-estimate=1.15MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 25(GETNEXT), 32(GETNEXT), 39(GETNEXT)
|  |
|  F33:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=23.08MB mem-reservation=7.75MB thread-reservation=1
|  46:AGGREGATE [STREAMING]
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  |  mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 25(GETNEXT), 32(GETNEXT), 39(GETNEXT)
|  |
|  24:UNION
|  |  mem-estimate=0B mem-reservation=0B thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 25(GETNEXT), 32(GETNEXT), 39(GETNEXT)
|  |
|  |--45:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  |  hash predicates: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  |  fk/pk conjuncts: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=24,25,26,27N row-size=102B cardinality=14.80K
|  |  |  in pipelines: 39(GETNEXT), 42(OPEN)
|  |  |
|  |  |--77:EXCHANGE [HASH(wr_item_sk,wr_order_number)]
|  |  |  |  mem-estimate=1.67MB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=27 row-size=24B cardinality=71.76K
|  |  |  |  in pipelines: 42(GETNEXT)
|  |  |  |
|  |  |  F31:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Host Resources: mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=2
|  |  |  42:SCAN HDFS [tpcds_parquet.web_returns, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=5.66MB
|  |  |     stored statistics:
|  |  |       table: rows=71.76K size=5.66MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=71.76K
|  |  |     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|  |  |     tuple-ids=27 row-size=24B cardinality=71.76K
|  |  |     in pipelines: 42(GETNEXT)
|  |  |
|  |  76:EXCHANGE [HASH(ws_item_sk,ws_order_number)]
|  |  |  mem-estimate=742.74KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=24,25,26 row-size=78B cardinality=14.80K
|  |  |  in pipelines: 39(GETNEXT)
|  |  |
|  |  F28:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  |  Per-Host Resources: mem-estimate=165.01MB mem-reservation=12.88MB thread-reservation=2 runtime-filters-memory=1.00MB
|  |  44:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash predicates: ws_sold_date_sk = d_date_sk
|  |  |  fk/pk conjuncts: ws_sold_date_sk = d_date_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=24,25,26 row-size=78B cardinality=14.80K
|  |  |  in pipelines: 39(GETNEXT), 41(OPEN)
|  |  |
|  |  |--75:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=26 row-size=8B cardinality=373
|  |  |  |  in pipelines: 41(GETNEXT)
|  |  |  |
|  |  |  F30:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2
|  |  |  41:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     stored statistics:
|  |  |       table: rows=73.05K size=2.15MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |     tuple-ids=26 row-size=8B cardinality=373
|  |  |     in pipelines: 41(GETNEXT)
|  |  |
|  |  43:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash predicates: ws_item_sk = i_item_sk
|  |  |  fk/pk conjuncts: ws_item_sk = i_item_sk
|  |  |  runtime filters: RF030[bloom] <- i_item_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=24,25 row-size=70B cardinality=71.94K
|  |  |  in pipelines: 39(GETNEXT), 40(OPEN)
|  |  |
|  |  |--74:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=25 row-size=42B cardinality=1.80K
|  |  |  |  in pipelines: 40(GETNEXT)
|  |  |  |
|  |  |  F29:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=2
|  |  |  40:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |     predicates: i_category = 'Books'
|  |  |     stored statistics:
|  |  |       table: rows=18.00K size=1.73MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |     tuple-ids=25 row-size=42B cardinality=1.80K
|  |  |     in pipelines: 40(GETNEXT)
|  |  |
|  |  39:SCAN HDFS [tpcds_parquet.web_sales, RANDOM]
|  |     HDFS partitions=1/1 files=2 size=45.09MB
|  |     runtime filters: RF030[bloom] -> ws_item_sk
|  |     stored statistics:
|  |       table: rows=719.38K size=45.09MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=644.77K
|  |     mem-estimate=160.00MB mem-reservation=8.00MB thread-reservation=1
|  |     tuple-ids=24 row-size=28B cardinality=719.38K
|  |     in pipelines: 39(GETNEXT)
|  |
|  |--38:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  |  hash predicates: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  |  fk/pk conjuncts: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  |  tuple-ids=20,21,22,23N row-size=102B cardinality=58.90K
|  |  |  in pipelines: 32(GETNEXT), 35(OPEN)
|  |  |
|  |  |--73:EXCHANGE [HASH(sr_item_sk,sr_ticket_number)]
|  |  |  |  mem-estimate=6.61MB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=23 row-size=24B cardinality=287.51K
|  |  |  |  in pipelines: 35(GETNEXT)
|  |  |  |
|  |  |  F26:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=2
|  |  |  35:SCAN HDFS [tpcds_parquet.store_returns, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=15.43MB
|  |  |     stored statistics:
|  |  |       table: rows=287.51K size=15.43MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=287.51K
|  |  |     mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
|  |  |     tuple-ids=23 row-size=24B cardinality=287.51K
|  |  |     in pipelines: 35(GETNEXT)
|  |  |
|  |  72:EXCHANGE [HASH(ss_item_sk,ss_ticket_number)]
|  |  |  mem-estimate=1.72MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=20,21,22 row-size=78B cardinality=58.90K
|  |  |  in pipelines: 32(GETNEXT)
|  |  |
|  |  F23:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  Per-Host Resources: mem-estimate=70.01MB mem-reservation=7.88MB thread-reservation=2 runtime-filters-memory=2.00MB
|  |  37:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash predicates: ss_sold_date_sk = d_date_sk
|  |  |  fk/pk conjuncts: ss_sold_date_sk = d_date_sk
|  |  |  runtime filters: RF024[bloom] <- d_date_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=20,21,22 row-size=78B cardinality=58.90K
|  |  |  in pipelines: 32(GETNEXT), 34(OPEN)
|  |  |
|  |  |--71:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=22 row-size=8B cardinality=373
|  |  |  |  in pipelines: 34(GETNEXT)
|  |  |  |
|  |  |  F25:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2
|  |  |  34:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     stored statistics:
|  |  |       table: rows=73.05K size=2.15MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |     tuple-ids=22 row-size=8B cardinality=373
|  |  |     in pipelines: 34(GETNEXT)
|  |  |
|  |  36:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash predicates: ss_item_sk = i_item_sk
|  |  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  |  runtime filters: RF026[bloom] <- i_item_sk
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=20,21 row-size=70B cardinality=288.04K
|  |  |  in pipelines: 32(GETNEXT), 33(OPEN)
|  |  |
|  |  |--70:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=21 row-size=42B cardinality=1.80K
|  |  |  |  in pipelines: 33(GETNEXT)
|  |  |  |
|  |  |  F24:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=2
|  |  |  33:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |     predicates: i_category = 'Books'
|  |  |     stored statistics:
|  |  |       table: rows=18.00K size=1.73MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |     tuple-ids=21 row-size=42B cardinality=1.80K
|  |  |     in pipelines: 33(GETNEXT)
|  |  |
|  |  32:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
|  |     HDFS partitions=1824/1824 files=1824 size=201.02MB
|  |     runtime filters: RF026[bloom] -> ss_item_sk, RF024[bloom] -> ss_sold_date_sk
|  |     stored statistics:
|  |       table: rows=2.88M size=201.02MB
|  |       partitions: 1824/1824 rows=2.88M
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=130.09K
|  |     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=20 row-size=28B cardinality=2.88M
|  |     in pipelines: 32(GETNEXT)
|  |
|  31:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  hash predicates: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  |  fk/pk conjuncts: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=16,17,18,19N row-size=102B cardinality=29.46K
|  |  in pipelines: 25(GETNEXT), 28(OPEN)
|  |
|  |--69:EXCHANGE [HASH(cr_item_sk,cr_order_number)]
|  |  |  mem-estimate=3.32MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=19 row-size=24B cardinality=144.07K
|  |  |  in pipelines: 28(GETNEXT)
|  |  |
|  |  F21:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=2
|  |  28:SCAN HDFS [tpcds_parquet.catalog_returns, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=10.62MB
|  |     stored statistics:
|  |       table: rows=144.07K size=10.62MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=144.07K
|  |     mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
|  |     tuple-ids=19 row-size=24B cardinality=144.07K
|  |     in pipelines: 28(GETNEXT)
|  |
|  68:EXCHANGE [HASH(cs_item_sk,cs_order_number)]
|  |  mem-estimate=1016.76KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=16,17,18 row-size=78B cardinality=29.46K
|  |  in pipelines: 25(GETNEXT)
|  |
|  F18:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=246.01MB mem-reservation=13.88MB thread-reservation=2 runtime-filters-memory=2.00MB
|  30:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: cs_sold_date_sk = d_date_sk
|  |  fk/pk conjuncts: cs_sold_date_sk = d_date_sk
|  |  runtime filters: RF020[bloom] <- d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=16,17,18 row-size=78B cardinality=29.46K
|  |  in pipelines: 25(GETNEXT), 27(OPEN)
|  |
|  |--67:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=18 row-size=8B cardinality=373
|  |  |  in pipelines: 27(GETNEXT)
|  |  |
|  |  F20:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2
|  |  27:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |     stored statistics:
|  |       table: rows=73.05K size=2.15MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |     tuple-ids=18 row-size=8B cardinality=373
|  |     in pipelines: 27(GETNEXT)
|  |
|  29:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: cs_item_sk = i_item_sk
|  |  fk/pk conjuncts: cs_item_sk = i_item_sk
|  |  runtime filters: RF022[bloom] <- i_item_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=16,17 row-size=70B cardinality=144.16K
|  |  in pipelines: 25(GETNEXT), 26(OPEN)
|  |
|  |--66:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=17 row-size=42B cardinality=1.80K
|  |  |  in pipelines: 26(GETNEXT)
|  |  |
|  |  F19:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=2
|  |  26:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     predicates: i_category = 'Books'
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     parquet statistics predicates: i_category = 'Books'
|  |     parquet dictionary predicates: i_category = 'Books'
|  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |     tuple-ids=17 row-size=42B cardinality=1.80K
|  |     in pipelines: 26(GETNEXT)
|  |
|  25:SCAN HDFS [tpcds_parquet.catalog_sales, RANDOM]
|     HDFS partitions=1/1 files=3 size=96.62MB
|     runtime filters: RF022[bloom] -> cs_item_sk, RF020[bloom] -> cs_sold_date_sk
|     stored statistics:
|       table: rows=1.44M size=96.62MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=650.14K
|     mem-estimate=240.00MB mem-reservation=8.00MB thread-reservation=1
|     tuple-ids=16 row-size=28B cardinality=1.44M
|     in pipelines: 25(GETNEXT)
|
82:EXCHANGE [HASH(i_brand_id,i_category_id,i_class_id,i_manufact_id)]
|  mem-estimate=27.12KB mem-reservation=0B thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=175
|  in pipelines: 65(GETNEXT)
|
F17:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)] hosts=3 instances=3
Per-Host Resources: mem-estimate=11.58MB mem-reservation=4.75MB thread-reservation=1
65:AGGREGATE [FINALIZE]
|  output: sum:merge(sales_cnt), sum:merge(sales_amt)
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  having: d_year = CAST(2002 AS INT)
|  mem-estimate=10.00MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=175
|  in pipelines: 65(GETNEXT), 63(OPEN)
|
64:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)]
|  mem-estimate=1.58MB mem-reservation=0B thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=103.17K
|  in pipelines: 63(GETNEXT)
|
F16:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)] hosts=3 instances=3
Per-Host Resources: mem-estimate=21.15MB mem-reservation=7.88MB thread-reservation=1
23:AGGREGATE [STREAMING]
|  output: sum(sales_cnt), sum(sales_amt)
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  mem-estimate=10.00MB mem-reservation=5.00MB spill-buffer=256.00KB thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=103.17K
|  in pipelines: 63(GETNEXT)
|
63:AGGREGATE [FINALIZE]
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 63(GETNEXT), 01(OPEN), 08(OPEN), 15(OPEN)
|
62:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)]
|  mem-estimate=1.15MB mem-reservation=0B thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 01(GETNEXT), 08(GETNEXT), 15(GETNEXT)
|
F15:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
Per-Host Resources: mem-estimate=23.08MB mem-reservation=7.75MB thread-reservation=1
22:AGGREGATE [STREAMING]
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 01(GETNEXT), 08(GETNEXT), 15(GETNEXT)
|
00:UNION
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 01(GETNEXT), 08(GETNEXT), 15(GETNEXT)
|
|--21:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  hash predicates: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  fk/pk conjuncts: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=8,9,10,11N row-size=102B cardinality=14.80K
|  |  in pipelines: 15(GETNEXT), 18(OPEN)
|  |
|  |--61:EXCHANGE [HASH(wr_item_sk,wr_order_number)]
|  |  |  mem-estimate=1.67MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=11 row-size=24B cardinality=71.76K
|  |  |  in pipelines: 18(GETNEXT)
|  |  |
|  |  F13:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=2
|  |  18:SCAN HDFS [tpcds_parquet.web_returns, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=5.66MB
|  |     stored statistics:
|  |       table: rows=71.76K size=5.66MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=71.76K
|  |     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=11 row-size=24B cardinality=71.76K
|  |     in pipelines: 18(GETNEXT)
|  |
|  60:EXCHANGE [HASH(ws_item_sk,ws_order_number)]
|  |  mem-estimate=742.74KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=8,9,10 row-size=78B cardinality=14.80K
|  |  in pipelines: 15(GETNEXT)
|  |
|  F10:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  Per-Host Resources: mem-estimate=165.01MB mem-reservation=12.88MB thread-reservation=2 runtime-filters-memory=1.00MB
|  20:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: ws_sold_date_sk = d_date_sk
|  |  fk/pk conjuncts: ws_sold_date_sk = d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=8,9,10 row-size=78B cardinality=14.80K
|  |  in pipelines: 15(GETNEXT), 17(OPEN)
|  |
|  |--59:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=10 row-size=8B cardinality=373
|  |  |  in pipelines: 17(GETNEXT)
|  |  |
|  |  F12:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2
|  |  17:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     stored statistics:
|  |       table: rows=73.05K size=2.15MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |     tuple-ids=10 row-size=8B cardinality=373
|  |     in pipelines: 17(GETNEXT)
|  |
|  19:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: ws_item_sk = i_item_sk
|  |  fk/pk conjuncts: ws_item_sk = i_item_sk
|  |  runtime filters: RF018[bloom] <- i_item_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=8,9 row-size=70B cardinality=71.94K
|  |  in pipelines: 15(GETNEXT), 16(OPEN)
|  |
|  |--58:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=9 row-size=42B cardinality=1.80K
|  |  |  in pipelines: 16(GETNEXT)
|  |  |
|  |  F11:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=2
|  |  16:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     predicates: i_category = 'Books'
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     parquet statistics predicates: i_category = 'Books'
|  |     parquet dictionary predicates: i_category = 'Books'
|  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |     tuple-ids=9 row-size=42B cardinality=1.80K
|  |     in pipelines: 16(GETNEXT)
|  |
|  15:SCAN HDFS [tpcds_parquet.web_sales, RANDOM]
|     HDFS partitions=1/1 files=2 size=45.09MB
|     runtime filters: RF018[bloom] -> ws_item_sk
|     stored statistics:
|       table: rows=719.38K size=45.09MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=644.77K
|     mem-estimate=160.00MB mem-reservation=8.00MB thread-reservation=1
|     tuple-ids=8 row-size=28B cardinality=719.38K
|     in pipelines: 15(GETNEXT)
|
|--14:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  hash predicates: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  fk/pk conjuncts: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=4,5,6,7N row-size=102B cardinality=58.90K
|  |  in pipelines: 08(GETNEXT), 11(OPEN)
|  |
|  |--57:EXCHANGE [HASH(sr_item_sk,sr_ticket_number)]
|  |  |  mem-estimate=6.61MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=7 row-size=24B cardinality=287.51K
|  |  |  in pipelines: 11(GETNEXT)
|  |  |
|  |  F08:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=2
|  |  11:SCAN HDFS [tpcds_parquet.store_returns, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=15.43MB
|  |     stored statistics:
|  |       table: rows=287.51K size=15.43MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=287.51K
|  |     mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
|  |     tuple-ids=7 row-size=24B cardinality=287.51K
|  |     in pipelines: 11(GETNEXT)
|  |
|  56:EXCHANGE [HASH(ss_item_sk,ss_ticket_number)]
|  |  mem-estimate=1.72MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=4,5,6 row-size=78B cardinality=58.90K
|  |  in pipelines: 08(GETNEXT)
|  |
|  F05:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=70.01MB mem-reservation=7.88MB thread-reservation=2 runtime-filters-memory=2.00MB
|  13:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: ss_sold_date_sk = d_date_sk
|  |  fk/pk conjuncts: ss_sold_date_sk = d_date_sk
|  |  runtime filters: RF012[bloom] <- d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=4,5,6 row-size=78B cardinality=58.90K
|  |  in pipelines: 08(GETNEXT), 10(OPEN)
|  |
|  |--55:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=6 row-size=8B cardinality=373
|  |  |  in pipelines: 10(GETNEXT)
|  |  |
|  |  F07:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2
|  |  10:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     stored statistics:
|  |       table: rows=73.05K size=2.15MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|  |     tuple-ids=6 row-size=8B cardinality=373
|  |     in pipelines: 10(GETNEXT)
|  |
|  12:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: ss_item_sk = i_item_sk
|  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  runtime filters: RF014[bloom] <- i_item_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=4,5 row-size=70B cardinality=288.04K
|  |  in pipelines: 08(GETNEXT), 09(OPEN)
|  |
|  |--54:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=5 row-size=42B cardinality=1.80K
|  |  |  in pipelines: 09(GETNEXT)
|  |  |
|  |  F06:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=2
|  |  09:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     predicates: i_category = 'Books'
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     parquet statistics predicates: i_category = 'Books'
|  |     parquet dictionary predicates: i_category = 'Books'
|  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |     tuple-ids=5 row-size=42B cardinality=1.80K
|  |     in pipelines: 09(GETNEXT)
|  |
|  08:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
|     HDFS partitions=1824/1824 files=1824 size=201.02MB
|     runtime filters: RF014[bloom] -> ss_item_sk, RF012[bloom] -> ss_sold_date_sk
|     stored statistics:
|       table: rows=2.88M size=201.02MB
|       partitions: 1824/1824 rows=2.88M
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=130.09K
|     mem-estimate=64.00MB mem-reservation=2.00MB thread-reservation=1
|     tuple-ids=4 row-size=28B cardinality=2.88M
|     in pipelines: 08(GETNEXT)
|
07:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  hash predicates: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  fk/pk conjuncts: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=0,1,2,3N row-size=102B cardinality=29.46K
|  in pipelines: 01(GETNEXT), 04(OPEN)
|
|--53:EXCHANGE [HASH(cr_item_sk,cr_order_number)]
|  |  mem-estimate=3.32MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=3 row-size=24B cardinality=144.07K
|  |  in pipelines: 04(GETNEXT)
|  |
|  F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=2
|  04:SCAN HDFS [tpcds_parquet.catalog_returns, RANDOM]
|     HDFS partitions=1/1 files=1 size=10.62MB
|     stored statistics:
|       table: rows=144.07K size=10.62MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=144.07K
|     mem-estimate=96.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=3 row-size=24B cardinality=144.07K
|     in pipelines: 04(GETNEXT)
|
52:EXCHANGE [HASH(cs_item_sk,cs_order_number)]
|  mem-estimate=1016.76KB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,1,2 row-size=78B cardinality=29.46K
|  in pipelines: 01(GETNEXT)
|
F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
Per-Host Resources: mem-estimate=246.01MB mem-reservation=13.88MB thread-reservation=2 runtime-filters-memory=2.00MB
06:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: cs_sold_date_sk = d_date_sk
|  fk/pk conjuncts: cs_sold_date_sk = d_date_sk
|  runtime filters: RF008[bloom] <- d_date_sk
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,1,2 row-size=78B cardinality=29.46K
|  in pipelines: 01(GETNEXT), 03(OPEN)
|
|--51:EXCHANGE [BROADCAST]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=2 row-size=8B cardinality=373
|  |  in pipelines: 03(GETNEXT)
|  |
|  F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2
|  03:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|     HDFS partitions=1/1 files=1 size=2.15MB
|     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|     stored statistics:
|       table: rows=73.05K size=2.15MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=73.05K
|     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|     mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1
|     tuple-ids=2 row-size=8B cardinality=373
|     in pipelines: 03(GETNEXT)
|
05:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: cs_item_sk = i_item_sk
|  fk/pk conjuncts: cs_item_sk = i_item_sk
|  runtime filters: RF010[bloom] <- i_item_sk
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,1 row-size=70B cardinality=144.16K
|  in pipelines: 01(GETNEXT), 02(OPEN)
|
|--50:EXCHANGE [BROADCAST]
|  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=1 row-size=42B cardinality=1.80K
|  |  in pipelines: 02(GETNEXT)
|  |
|  F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=2
|  02:SCAN HDFS [tpcds_parquet.item, RANDOM]
|     HDFS partitions=1/1 files=1 size=1.73MB
|     predicates: i_category = 'Books'
|     stored statistics:
|       table: rows=18.00K size=1.73MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=18.00K
|     parquet statistics predicates: i_category = 'Books'
|     parquet dictionary predicates: i_category = 'Books'
|     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|     tuple-ids=1 row-size=42B cardinality=1.80K
|     in pipelines: 02(GETNEXT)
|
01:SCAN HDFS [tpcds_parquet.catalog_sales, RANDOM]
   HDFS partitions=1/1 files=3 size=96.62MB
   runtime filters: RF010[bloom] -> cs_item_sk, RF008[bloom] -> cs_sold_date_sk
   stored statistics:
     table: rows=1.44M size=96.62MB
     columns: all
   extrapolated-rows=disabled max-scan-range-rows=650.14K
   mem-estimate=240.00MB mem-reservation=8.00MB thread-reservation=1
   tuple-ids=0 row-size=28B cardinality=1.44M
   in pipelines: 01(GETNEXT)
---- PARALLELPLANS
Max Per-Host Resource Reservation: Memory=201.12MB Threads=67
Per-Host Resource Estimates: Memory=869MB
F37:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=46.88KB mem-reservation=0B thread-reservation=1
PLAN-ROOT SINK
|  output exprs: d_year, d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_cnt, sales_cnt - sales_cnt, sales_amt - sales_amt
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
84:MERGING-EXCHANGE [UNPARTITIONED]
|  order by: sales_cnt - sales_cnt ASC, sales_amt - sales_amt ASC
|  limit: 100
|  mem-estimate=46.88KB mem-reservation=0B thread-reservation=0
|  tuple-ids=32 row-size=72B cardinality=100
|  in pipelines: 49(GETNEXT)
|
F36:PLAN FRAGMENT [HASH(i_brand_id,i_category_id,i_class_id,i_manufact_id)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=58.76KB mem-reservation=0B thread-reservation=1
49:TOP-N [LIMIT=100]
|  order by: sales_cnt - sales_cnt ASC, sales_amt - sales_amt ASC
|  mem-estimate=7.03KB mem-reservation=0B thread-reservation=0
|  tuple-ids=32 row-size=72B cardinality=100
|  in pipelines: 49(GETNEXT), 65(OPEN)
|
48:HASH JOIN [INNER JOIN, PARTITIONED]
|  hash-table-id=00
|  hash predicates: i_brand_id = i_brand_id, i_category_id = i_category_id, i_class_id = i_class_id, i_manufact_id = i_manufact_id
|  fk/pk conjuncts: assumed fk/pk
|  other predicates: CAST(sum(sales_cnt) AS DECIMAL(17,2)) / CAST(sum(sales_cnt) AS DECIMAL(17,2)) < CAST(0.9 AS DECIMAL(1,1))
|  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=14,30 row-size=88B cardinality=175
|  in pipelines: 65(GETNEXT), 81(OPEN)
|
|--F38:PLAN FRAGMENT [HASH(i_brand_id,i_category_id,i_class_id,i_manufact_id)] hosts=3 instances=6
|  |  Per-Instance Resources: mem-estimate=1.99MB mem-reservation=1.94MB thread-reservation=1
|  JOIN BUILD
|  |  join-table-id=00 plan-id=01 cohort-id=01
|  |  build expressions: i_brand_id, i_category_id, i_class_id, i_manufact_id
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |
|  83:EXCHANGE [HASH(i_brand_id,i_category_id,i_class_id,i_manufact_id)]
|  |  mem-estimate=51.72KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=175
|  |  in pipelines: 81(GETNEXT)
|  |
|  F35:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)] hosts=3 instances=6
|  Per-Instance Resources: mem-estimate=11.72MB mem-reservation=2.88MB thread-reservation=1
|  81:AGGREGATE [FINALIZE]
|  |  output: sum:merge(sales_cnt), sum:merge(sales_amt)
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  |  having: d_year = CAST(2001 AS INT)
|  |  mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=175
|  |  in pipelines: 81(GETNEXT), 79(OPEN)
|  |
|  80:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)]
|  |  mem-estimate=1.72MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=103.17K
|  |  in pipelines: 79(GETNEXT)
|  |
|  F34:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)] hosts=3 instances=6
|  Per-Instance Resources: mem-estimate=21.26MB mem-reservation=4.94MB thread-reservation=1
|  47:AGGREGATE [STREAMING]
|  |  output: sum(sales_cnt), sum(sales_amt)
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  |  mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=30 row-size=44B cardinality=103.17K
|  |  in pipelines: 79(GETNEXT)
|  |
|  79:AGGREGATE [FINALIZE]
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  |  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 79(GETNEXT), 25(OPEN), 32(OPEN), 39(OPEN)
|  |
|  78:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)]
|  |  mem-estimate=1.26MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 25(GETNEXT), 32(GETNEXT), 39(GETNEXT)
|  |
|  F33:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  Per-Instance Resources: mem-estimate=11.99MB mem-reservation=2.00MB thread-reservation=1
|  46:AGGREGATE [STREAMING]
|  |  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  |  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 25(GETNEXT), 32(GETNEXT), 39(GETNEXT)
|  |
|  24:UNION
|  |  mem-estimate=0B mem-reservation=0B thread-reservation=0
|  |  tuple-ids=28 row-size=32B cardinality=103.17K
|  |  in pipelines: 25(GETNEXT), 32(GETNEXT), 39(GETNEXT)
|  |
|  |--45:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  |  hash-table-id=03
|  |  |  hash predicates: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  |  fk/pk conjuncts: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=24,25,26,27N row-size=102B cardinality=14.80K
|  |  |  in pipelines: 39(GETNEXT), 42(OPEN)
|  |  |
|  |  |--F41:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  |  |  |  Per-Instance Resources: mem-estimate=3.61MB mem-reservation=1.94MB thread-reservation=1
|  |  |  JOIN BUILD
|  |  |  |  join-table-id=03 plan-id=04 cohort-id=02
|  |  |  |  build expressions: wr_item_sk, wr_order_number
|  |  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |
|  |  |  77:EXCHANGE [HASH(wr_item_sk,wr_order_number)]
|  |  |  |  mem-estimate=1.67MB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=27 row-size=24B cardinality=71.76K
|  |  |  |  in pipelines: 42(GETNEXT)
|  |  |  |
|  |  |  F31:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=1
|  |  |  42:SCAN HDFS [tpcds_parquet.web_returns, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=5.66MB
|  |  |     stored statistics:
|  |  |       table: rows=71.76K size=5.66MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=71.76K
|  |  |     mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=0
|  |  |     tuple-ids=27 row-size=24B cardinality=71.76K
|  |  |     in pipelines: 42(GETNEXT)
|  |  |
|  |  76:EXCHANGE [HASH(ws_item_sk,ws_order_number)]
|  |  |  mem-estimate=742.74KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=24,25,26 row-size=78B cardinality=14.80K
|  |  |  in pipelines: 39(GETNEXT)
|  |  |
|  |  F28:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  |  Per-Host Shared Resources: mem-estimate=1.00MB mem-reservation=1.00MB thread-reservation=0 runtime-filters-memory=1.00MB
|  |  Per-Instance Resources: mem-estimate=32.00MB mem-reservation=8.00MB thread-reservation=1
|  |  44:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash-table-id=08
|  |  |  hash predicates: ws_sold_date_sk = d_date_sk
|  |  |  fk/pk conjuncts: ws_sold_date_sk = d_date_sk
|  |  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=24,25,26 row-size=78B cardinality=14.80K
|  |  |  in pipelines: 39(GETNEXT), 41(OPEN)
|  |  |
|  |  |--F46:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  |  |  |  Per-Instance Resources: mem-estimate=3.89MB mem-reservation=3.88MB thread-reservation=1
|  |  |  JOIN BUILD
|  |  |  |  join-table-id=08 plan-id=09 cohort-id=02
|  |  |  |  build expressions: d_date_sk
|  |  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |
|  |  |  75:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=26 row-size=8B cardinality=373
|  |  |  |  in pipelines: 41(GETNEXT)
|  |  |  |
|  |  |  F30:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |  41:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     stored statistics:
|  |  |       table: rows=73.05K size=2.15MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|  |  |     tuple-ids=26 row-size=8B cardinality=373
|  |  |     in pipelines: 41(GETNEXT)
|  |  |
|  |  43:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash-table-id=09
|  |  |  hash predicates: ws_item_sk = i_item_sk
|  |  |  fk/pk conjuncts: ws_item_sk = i_item_sk
|  |  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=24,25 row-size=70B cardinality=71.94K
|  |  |  in pipelines: 39(GETNEXT), 40(OPEN)
|  |  |
|  |  |--F47:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  |  |  |  Per-Instance Resources: mem-estimate=4.99MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  |  JOIN BUILD
|  |  |  |  join-table-id=09 plan-id=10 cohort-id=02
|  |  |  |  build expressions: i_item_sk
|  |  |  |  runtime filters: RF030[bloom] <- i_item_sk
|  |  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |
|  |  |  74:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=25 row-size=42B cardinality=1.80K
|  |  |  |  in pipelines: 40(GETNEXT)
|  |  |  |
|  |  |  F29:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |  40:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |     predicates: i_category = 'Books'
|  |  |     stored statistics:
|  |  |       table: rows=18.00K size=1.73MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|  |  |     tuple-ids=25 row-size=42B cardinality=1.80K
|  |  |     in pipelines: 40(GETNEXT)
|  |  |
|  |  39:SCAN HDFS [tpcds_parquet.web_sales, RANDOM]
|  |     HDFS partitions=1/1 files=2 size=45.09MB
|  |     runtime filters: RF030[bloom] -> ws_item_sk
|  |     stored statistics:
|  |       table: rows=719.38K size=45.09MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=644.77K
|  |     mem-estimate=32.00MB mem-reservation=8.00MB thread-reservation=0
|  |     tuple-ids=24 row-size=28B cardinality=719.38K
|  |     in pipelines: 39(GETNEXT)
|  |
|  |--38:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  |  hash-table-id=02
|  |  |  hash predicates: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  |  fk/pk conjuncts: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  |  mem-estimate=0B mem-reservation=0B spill-buffer=128.00KB thread-reservation=0
|  |  |  tuple-ids=20,21,22,23N row-size=102B cardinality=58.90K
|  |  |  in pipelines: 32(GETNEXT), 35(OPEN)
|  |  |
|  |  |--F40:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  |  |  |  Per-Instance Resources: mem-estimate=9.48MB mem-reservation=2.88MB thread-reservation=1
|  |  |  JOIN BUILD
|  |  |  |  join-table-id=02 plan-id=03 cohort-id=02
|  |  |  |  build expressions: sr_item_sk, sr_ticket_number
|  |  |  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  |  |
|  |  |  73:EXCHANGE [HASH(sr_item_sk,sr_ticket_number)]
|  |  |  |  mem-estimate=6.61MB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=23 row-size=24B cardinality=287.51K
|  |  |  |  in pipelines: 35(GETNEXT)
|  |  |  |
|  |  |  F26:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Instance Resources: mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=1
|  |  |  35:SCAN HDFS [tpcds_parquet.store_returns, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=15.43MB
|  |  |     stored statistics:
|  |  |       table: rows=287.51K size=15.43MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=287.51K
|  |  |     mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=0
|  |  |     tuple-ids=23 row-size=24B cardinality=287.51K
|  |  |     in pipelines: 35(GETNEXT)
|  |  |
|  |  72:EXCHANGE [HASH(ss_item_sk,ss_ticket_number)]
|  |  |  mem-estimate=1.99MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=20,21,22 row-size=78B cardinality=58.90K
|  |  |  in pipelines: 32(GETNEXT)
|  |  |
|  |  F23:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  |  Per-Host Shared Resources: mem-estimate=2.00MB mem-reservation=2.00MB thread-reservation=0 runtime-filters-memory=2.00MB
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=1
|  |  37:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash-table-id=06
|  |  |  hash predicates: ss_sold_date_sk = d_date_sk
|  |  |  fk/pk conjuncts: ss_sold_date_sk = d_date_sk
|  |  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=20,21,22 row-size=78B cardinality=58.90K
|  |  |  in pipelines: 32(GETNEXT), 34(OPEN)
|  |  |
|  |  |--F44:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  |  Per-Instance Resources: mem-estimate=4.89MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  |  JOIN BUILD
|  |  |  |  join-table-id=06 plan-id=07 cohort-id=02
|  |  |  |  build expressions: d_date_sk
|  |  |  |  runtime filters: RF024[bloom] <- d_date_sk
|  |  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |
|  |  |  71:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=22 row-size=8B cardinality=373
|  |  |  |  in pipelines: 34(GETNEXT)
|  |  |  |
|  |  |  F25:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  |  |  34:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     stored statistics:
|  |  |       table: rows=73.05K size=2.15MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |  |     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|  |  |     tuple-ids=22 row-size=8B cardinality=373
|  |  |     in pipelines: 34(GETNEXT)
|  |  |
|  |  36:HASH JOIN [INNER JOIN, BROADCAST]
|  |  |  hash-table-id=07
|  |  |  hash predicates: ss_item_sk = i_item_sk
|  |  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  |  tuple-ids=20,21 row-size=70B cardinality=288.04K
|  |  |  in pipelines: 32(GETNEXT), 33(OPEN)
|  |  |
|  |  |--F45:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  |  Per-Instance Resources: mem-estimate=4.99MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  |  JOIN BUILD
|  |  |  |  join-table-id=07 plan-id=08 cohort-id=02
|  |  |  |  build expressions: i_item_sk
|  |  |  |  runtime filters: RF026[bloom] <- i_item_sk
|  |  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |
|  |  |  70:EXCHANGE [BROADCAST]
|  |  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  |  tuple-ids=21 row-size=42B cardinality=1.80K
|  |  |  |  in pipelines: 33(GETNEXT)
|  |  |  |
|  |  |  F24:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |  33:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |     predicates: i_category = 'Books'
|  |  |     stored statistics:
|  |  |       table: rows=18.00K size=1.73MB
|  |  |       columns: all
|  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |     parquet statistics predicates: i_category = 'Books'
|  |  |     parquet dictionary predicates: i_category = 'Books'
|  |  |     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|  |  |     tuple-ids=21 row-size=42B cardinality=1.80K
|  |  |     in pipelines: 33(GETNEXT)
|  |  |
|  |  32:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
|  |     HDFS partitions=1824/1824 files=1824 size=201.02MB
|  |     runtime filters: RF026[bloom] -> ss_item_sk, RF024[bloom] -> ss_sold_date_sk
|  |     stored statistics:
|  |       table: rows=2.88M size=201.02MB
|  |       partitions: 1824/1824 rows=2.88M
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=130.09K
|  |     mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=0
|  |     tuple-ids=20 row-size=28B cardinality=2.88M
|  |     in pipelines: 32(GETNEXT)
|  |
|  31:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  hash-table-id=01
|  |  hash predicates: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  |  fk/pk conjuncts: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=16,17,18,19N row-size=102B cardinality=29.46K
|  |  in pipelines: 25(GETNEXT), 28(OPEN)
|  |
|  |--F39:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  |  |  Per-Instance Resources: mem-estimate=5.26MB mem-reservation=1.94MB thread-reservation=1
|  |  JOIN BUILD
|  |  |  join-table-id=01 plan-id=02 cohort-id=02
|  |  |  build expressions: cr_item_sk, cr_order_number
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  69:EXCHANGE [HASH(cr_item_sk,cr_order_number)]
|  |  |  mem-estimate=3.32MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=19 row-size=24B cardinality=144.07K
|  |  |  in pipelines: 28(GETNEXT)
|  |  |
|  |  F21:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=1
|  |  28:SCAN HDFS [tpcds_parquet.catalog_returns, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=10.62MB
|  |     stored statistics:
|  |       table: rows=144.07K size=10.62MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=144.07K
|  |     mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=0
|  |     tuple-ids=19 row-size=24B cardinality=144.07K
|  |     in pipelines: 28(GETNEXT)
|  |
|  68:EXCHANGE [HASH(cs_item_sk,cs_order_number)]
|  |  mem-estimate=1016.76KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=16,17,18 row-size=78B cardinality=29.46K
|  |  in pipelines: 25(GETNEXT)
|  |
|  F18:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  Per-Host Shared Resources: mem-estimate=2.00MB mem-reservation=2.00MB thread-reservation=0 runtime-filters-memory=2.00MB
|  Per-Instance Resources: mem-estimate=48.00MB mem-reservation=8.00MB thread-reservation=1
|  30:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=04
|  |  hash predicates: cs_sold_date_sk = d_date_sk
|  |  fk/pk conjuncts: cs_sold_date_sk = d_date_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=16,17,18 row-size=78B cardinality=29.46K
|  |  in pipelines: 25(GETNEXT), 27(OPEN)
|  |
|  |--F42:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=4.89MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  JOIN BUILD
|  |  |  join-table-id=04 plan-id=05 cohort-id=02
|  |  |  build expressions: d_date_sk
|  |  |  runtime filters: RF020[bloom] <- d_date_sk
|  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  67:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=18 row-size=8B cardinality=373
|  |  |  in pipelines: 27(GETNEXT)
|  |  |
|  |  F20:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  |  27:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |     stored statistics:
|  |       table: rows=73.05K size=2.15MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2001 AS INT)
|  |     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|  |     tuple-ids=18 row-size=8B cardinality=373
|  |     in pipelines: 27(GETNEXT)
|  |
|  29:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=05
|  |  hash predicates: cs_item_sk = i_item_sk
|  |  fk/pk conjuncts: cs_item_sk = i_item_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=16,17 row-size=70B cardinality=144.16K
|  |  in pipelines: 25(GETNEXT), 26(OPEN)
|  |
|  |--F43:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=4.99MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  JOIN BUILD
|  |  |  join-table-id=05 plan-id=06 cohort-id=02
|  |  |  build expressions: i_item_sk
|  |  |  runtime filters: RF022[bloom] <- i_item_sk
|  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  66:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=17 row-size=42B cardinality=1.80K
|  |  |  in pipelines: 26(GETNEXT)
|  |  |
|  |  F19:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
|  |  26:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     predicates: i_category = 'Books'
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     parquet statistics predicates: i_category = 'Books'
|  |     parquet dictionary predicates: i_category = 'Books'
|  |     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|  |     tuple-ids=17 row-size=42B cardinality=1.80K
|  |     in pipelines: 26(GETNEXT)
|  |
|  25:SCAN HDFS [tpcds_parquet.catalog_sales, RANDOM]
|     HDFS partitions=1/1 files=3 size=96.62MB
|     runtime filters: RF022[bloom] -> cs_item_sk, RF020[bloom] -> cs_sold_date_sk
|     stored statistics:
|       table: rows=1.44M size=96.62MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=650.14K
|     mem-estimate=48.00MB mem-reservation=8.00MB thread-reservation=0
|     tuple-ids=16 row-size=28B cardinality=1.44M
|     in pipelines: 25(GETNEXT)
|
82:EXCHANGE [HASH(i_brand_id,i_category_id,i_class_id,i_manufact_id)]
|  mem-estimate=51.72KB mem-reservation=0B thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=175
|  in pipelines: 65(GETNEXT)
|
F17:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=11.72MB mem-reservation=2.88MB thread-reservation=1
65:AGGREGATE [FINALIZE]
|  output: sum:merge(sales_cnt), sum:merge(sales_amt)
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  having: d_year = CAST(2002 AS INT)
|  mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=175
|  in pipelines: 65(GETNEXT), 63(OPEN)
|
64:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id)]
|  mem-estimate=1.72MB mem-reservation=0B thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=103.17K
|  in pipelines: 63(GETNEXT)
|
F16:PLAN FRAGMENT [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=21.26MB mem-reservation=4.94MB thread-reservation=1
23:AGGREGATE [STREAMING]
|  output: sum(sales_cnt), sum(sales_amt)
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id
|  mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=14 row-size=44B cardinality=103.17K
|  in pipelines: 63(GETNEXT)
|
63:AGGREGATE [FINALIZE]
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 63(GETNEXT), 01(OPEN), 08(OPEN), 15(OPEN)
|
62:EXCHANGE [HASH(d_year,i_brand_id,i_class_id,i_category_id,i_manufact_id,sales_cnt,sales_amt)]
|  mem-estimate=1.26MB mem-reservation=0B thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 01(GETNEXT), 08(GETNEXT), 15(GETNEXT)
|
F15:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
Per-Instance Resources: mem-estimate=11.99MB mem-reservation=2.00MB thread-reservation=1
22:AGGREGATE [STREAMING]
|  group by: d_year, i_brand_id, i_class_id, i_category_id, i_manufact_id, sales_cnt, sales_amt
|  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 01(GETNEXT), 08(GETNEXT), 15(GETNEXT)
|
00:UNION
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|  tuple-ids=12 row-size=32B cardinality=103.17K
|  in pipelines: 01(GETNEXT), 08(GETNEXT), 15(GETNEXT)
|
|--21:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  hash-table-id=12
|  |  hash predicates: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  fk/pk conjuncts: ws_item_sk = wr_item_sk, ws_order_number = wr_order_number
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=8,9,10,11N row-size=102B cardinality=14.80K
|  |  in pipelines: 15(GETNEXT), 18(OPEN)
|  |
|  |--F50:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  |  |  Per-Instance Resources: mem-estimate=3.61MB mem-reservation=1.94MB thread-reservation=1
|  |  JOIN BUILD
|  |  |  join-table-id=12 plan-id=13 cohort-id=01
|  |  |  build expressions: wr_item_sk, wr_order_number
|  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  61:EXCHANGE [HASH(wr_item_sk,wr_order_number)]
|  |  |  mem-estimate=1.67MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=11 row-size=24B cardinality=71.76K
|  |  |  in pipelines: 18(GETNEXT)
|  |  |
|  |  F13:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=1
|  |  18:SCAN HDFS [tpcds_parquet.web_returns, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=5.66MB
|  |     stored statistics:
|  |       table: rows=71.76K size=5.66MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=71.76K
|  |     mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=0
|  |     tuple-ids=11 row-size=24B cardinality=71.76K
|  |     in pipelines: 18(GETNEXT)
|  |
|  60:EXCHANGE [HASH(ws_item_sk,ws_order_number)]
|  |  mem-estimate=742.74KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=8,9,10 row-size=78B cardinality=14.80K
|  |  in pipelines: 15(GETNEXT)
|  |
|  F10:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  Per-Host Shared Resources: mem-estimate=1.00MB mem-reservation=1.00MB thread-reservation=0 runtime-filters-memory=1.00MB
|  Per-Instance Resources: mem-estimate=32.00MB mem-reservation=8.00MB thread-reservation=1
|  20:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=17
|  |  hash predicates: ws_sold_date_sk = d_date_sk
|  |  fk/pk conjuncts: ws_sold_date_sk = d_date_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=8,9,10 row-size=78B cardinality=14.80K
|  |  in pipelines: 15(GETNEXT), 17(OPEN)
|  |
|  |--F55:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  |  |  Per-Instance Resources: mem-estimate=3.89MB mem-reservation=3.88MB thread-reservation=1
|  |  JOIN BUILD
|  |  |  join-table-id=17 plan-id=18 cohort-id=01
|  |  |  build expressions: d_date_sk
|  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  59:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=10 row-size=8B cardinality=373
|  |  |  in pipelines: 17(GETNEXT)
|  |  |
|  |  F12:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  |  17:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     stored statistics:
|  |       table: rows=73.05K size=2.15MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|  |     tuple-ids=10 row-size=8B cardinality=373
|  |     in pipelines: 17(GETNEXT)
|  |
|  19:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=18
|  |  hash predicates: ws_item_sk = i_item_sk
|  |  fk/pk conjuncts: ws_item_sk = i_item_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=8,9 row-size=70B cardinality=71.94K
|  |  in pipelines: 15(GETNEXT), 16(OPEN)
|  |
|  |--F56:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  |  |  Per-Instance Resources: mem-estimate=4.99MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  JOIN BUILD
|  |  |  join-table-id=18 plan-id=19 cohort-id=01
|  |  |  build expressions: i_item_sk
|  |  |  runtime filters: RF018[bloom] <- i_item_sk
|  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  58:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=9 row-size=42B cardinality=1.80K
|  |  |  in pipelines: 16(GETNEXT)
|  |  |
|  |  F11:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
|  |  16:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     predicates: i_category = 'Books'
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     parquet statistics predicates: i_category = 'Books'
|  |     parquet dictionary predicates: i_category = 'Books'
|  |     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|  |     tuple-ids=9 row-size=42B cardinality=1.80K
|  |     in pipelines: 16(GETNEXT)
|  |
|  15:SCAN HDFS [tpcds_parquet.web_sales, RANDOM]
|     HDFS partitions=1/1 files=2 size=45.09MB
|     runtime filters: RF018[bloom] -> ws_item_sk
|     stored statistics:
|       table: rows=719.38K size=45.09MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=644.77K
|     mem-estimate=32.00MB mem-reservation=8.00MB thread-reservation=0
|     tuple-ids=8 row-size=28B cardinality=719.38K
|     in pipelines: 15(GETNEXT)
|
|--14:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  |  hash-table-id=11
|  |  hash predicates: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  fk/pk conjuncts: ss_item_sk = sr_item_sk, ss_ticket_number = sr_ticket_number
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=4,5,6,7N row-size=102B cardinality=58.90K
|  |  in pipelines: 08(GETNEXT), 11(OPEN)
|  |
|  |--F49:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  |  |  Per-Instance Resources: mem-estimate=9.48MB mem-reservation=2.88MB thread-reservation=1
|  |  JOIN BUILD
|  |  |  join-table-id=11 plan-id=12 cohort-id=01
|  |  |  build expressions: sr_item_sk, sr_ticket_number
|  |  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  |
|  |  57:EXCHANGE [HASH(sr_item_sk,sr_ticket_number)]
|  |  |  mem-estimate=6.61MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=7 row-size=24B cardinality=287.51K
|  |  |  in pipelines: 11(GETNEXT)
|  |  |
|  |  F08:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=1
|  |  11:SCAN HDFS [tpcds_parquet.store_returns, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=15.43MB
|  |     stored statistics:
|  |       table: rows=287.51K size=15.43MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=287.51K
|  |     mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=0
|  |     tuple-ids=7 row-size=24B cardinality=287.51K
|  |     in pipelines: 11(GETNEXT)
|  |
|  56:EXCHANGE [HASH(ss_item_sk,ss_ticket_number)]
|  |  mem-estimate=1.99MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=4,5,6 row-size=78B cardinality=58.90K
|  |  in pipelines: 08(GETNEXT)
|  |
|  F05:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  Per-Host Shared Resources: mem-estimate=2.00MB mem-reservation=2.00MB thread-reservation=0 runtime-filters-memory=2.00MB
|  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=1
|  13:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=15
|  |  hash predicates: ss_sold_date_sk = d_date_sk
|  |  fk/pk conjuncts: ss_sold_date_sk = d_date_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=4,5,6 row-size=78B cardinality=58.90K
|  |  in pipelines: 08(GETNEXT), 10(OPEN)
|  |
|  |--F53:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=4.89MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  JOIN BUILD
|  |  |  join-table-id=15 plan-id=16 cohort-id=01
|  |  |  build expressions: d_date_sk
|  |  |  runtime filters: RF012[bloom] <- d_date_sk
|  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  55:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=6 row-size=8B cardinality=373
|  |  |  in pipelines: 10(GETNEXT)
|  |  |
|  |  F07:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  |  10:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     stored statistics:
|  |       table: rows=73.05K size=2.15MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=73.05K
|  |     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|  |     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|  |     tuple-ids=6 row-size=8B cardinality=373
|  |     in pipelines: 10(GETNEXT)
|  |
|  12:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=16
|  |  hash predicates: ss_item_sk = i_item_sk
|  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=4,5 row-size=70B cardinality=288.04K
|  |  in pipelines: 08(GETNEXT), 09(OPEN)
|  |
|  |--F54:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=4.99MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  |  JOIN BUILD
|  |  |  join-table-id=16 plan-id=17 cohort-id=01
|  |  |  build expressions: i_item_sk
|  |  |  runtime filters: RF014[bloom] <- i_item_sk
|  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  54:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=5 row-size=42B cardinality=1.80K
|  |  |  in pipelines: 09(GETNEXT)
|  |  |
|  |  F06:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
|  |  09:SCAN HDFS [tpcds_parquet.item, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     predicates: i_category = 'Books'
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     parquet statistics predicates: i_category = 'Books'
|  |     parquet dictionary predicates: i_category = 'Books'
|  |     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|  |     tuple-ids=5 row-size=42B cardinality=1.80K
|  |     in pipelines: 09(GETNEXT)
|  |
|  08:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
|     HDFS partitions=1824/1824 files=1824 size=201.02MB
|     runtime filters: RF014[bloom] -> ss_item_sk, RF012[bloom] -> ss_sold_date_sk
|     stored statistics:
|       table: rows=2.88M size=201.02MB
|       partitions: 1824/1824 rows=2.88M
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=130.09K
|     mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=0
|     tuple-ids=4 row-size=28B cardinality=2.88M
|     in pipelines: 08(GETNEXT)
|
07:HASH JOIN [LEFT OUTER JOIN, PARTITIONED]
|  hash-table-id=10
|  hash predicates: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  fk/pk conjuncts: cs_item_sk = cr_item_sk, cs_order_number = cr_order_number
|  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,1,2,3N row-size=102B cardinality=29.46K
|  in pipelines: 01(GETNEXT), 04(OPEN)
|
|--F48:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  |  Per-Instance Resources: mem-estimate=5.26MB mem-reservation=1.94MB thread-reservation=1
|  JOIN BUILD
|  |  join-table-id=10 plan-id=11 cohort-id=01
|  |  build expressions: cr_item_sk, cr_order_number
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |
|  53:EXCHANGE [HASH(cr_item_sk,cr_order_number)]
|  |  mem-estimate=3.32MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=3 row-size=24B cardinality=144.07K
|  |  in pipelines: 04(GETNEXT)
|  |
|  F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=1
|  04:SCAN HDFS [tpcds_parquet.catalog_returns, RANDOM]
|     HDFS partitions=1/1 files=1 size=10.62MB
|     stored statistics:
|       table: rows=144.07K size=10.62MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=144.07K
|     mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=0
|     tuple-ids=3 row-size=24B cardinality=144.07K
|     in pipelines: 04(GETNEXT)
|
52:EXCHANGE [HASH(cs_item_sk,cs_order_number)]
|  mem-estimate=1016.76KB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,1,2 row-size=78B cardinality=29.46K
|  in pipelines: 01(GETNEXT)
|
F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
Per-Host Shared Resources: mem-estimate=2.00MB mem-reservation=2.00MB thread-reservation=0 runtime-filters-memory=2.00MB
Per-Instance Resources: mem-estimate=48.00MB mem-reservation=8.00MB thread-reservation=1
06:HASH JOIN [INNER JOIN, BROADCAST]
|  hash-table-id=13
|  hash predicates: cs_sold_date_sk = d_date_sk
|  fk/pk conjuncts: cs_sold_date_sk = d_date_sk
|  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,1,2 row-size=78B cardinality=29.46K
|  in pipelines: 01(GETNEXT), 03(OPEN)
|
|--F51:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  Per-Instance Resources: mem-estimate=4.89MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  JOIN BUILD
|  |  join-table-id=13 plan-id=14 cohort-id=01
|  |  build expressions: d_date_sk
|  |  runtime filters: RF008[bloom] <- d_date_sk
|  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |
|  51:EXCHANGE [BROADCAST]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=2 row-size=8B cardinality=373
|  |  in pipelines: 03(GETNEXT)
|  |
|  F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  03:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|     HDFS partitions=1/1 files=1 size=2.15MB
|     predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|     stored statistics:
|       table: rows=73.05K size=2.15MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=73.05K
|     parquet statistics predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|     parquet dictionary predicates: tpcds_parquet.date_dim.d_year = CAST(2002 AS INT)
|     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|     tuple-ids=2 row-size=8B cardinality=373
|     in pipelines: 03(GETNEXT)
|
05:HASH JOIN [INNER JOIN, BROADCAST]
|  hash-table-id=14
|  hash predicates: cs_item_sk = i_item_sk
|  fk/pk conjuncts: cs_item_sk = i_item_sk
|  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,1 row-size=70B cardinality=144.16K
|  in pipelines: 01(GETNEXT), 02(OPEN)
|
|--F52:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  Per-Instance Resources: mem-estimate=4.99MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  JOIN BUILD
|  |  join-table-id=14 plan-id=15 cohort-id=01
|  |  build expressions: i_item_sk
|  |  runtime filters: RF010[bloom] <- i_item_sk
|  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |
|  50:EXCHANGE [BROADCAST]
|  |  mem-estimate=119.54KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=1 row-size=42B cardinality=1.80K
|  |  in pipelines: 02(GETNEXT)
|  |
|  F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
|  02:SCAN HDFS [tpcds_parquet.item, RANDOM]
|     HDFS partitions=1/1 files=1 size=1.73MB
|     predicates: i_category = 'Books'
|     stored statistics:
|       table: rows=18.00K size=1.73MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=18.00K
|     parquet statistics predicates: i_category = 'Books'
|     parquet dictionary predicates: i_category = 'Books'
|     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|     tuple-ids=1 row-size=42B cardinality=1.80K
|     in pipelines: 02(GETNEXT)
|
01:SCAN HDFS [tpcds_parquet.catalog_sales, RANDOM]
   HDFS partitions=1/1 files=3 size=96.62MB
   runtime filters: RF010[bloom] -> cs_item_sk, RF008[bloom] -> cs_sold_date_sk
   stored statistics:
     table: rows=1.44M size=96.62MB
     columns: all
   extrapolated-rows=disabled max-scan-range-rows=650.14K
   mem-estimate=48.00MB mem-reservation=8.00MB thread-reservation=0
   tuple-ids=0 row-size=28B cardinality=1.44M
   in pipelines: 01(GETNEXT)
====