testdata/workloads/functional-planner/queries/PlannerTest/tpcds/tpcds-q42.test - impala - Git at Google

 # TPCDS-Q42
 select
   dt.d_year,
   item.i_category_id,
   item.i_category,
   sum(ss_ext_sales_price)
 from
   date_dim dt,
   store_sales,
   item
 where
   dt.d_date_sk = store_sales.ss_sold_date_sk
   and store_sales.ss_item_sk = item.i_item_sk
   and item.i_manager_id = 1
   and dt.d_moy = 12
   and dt.d_year = 1998
 group by
   dt.d_year,
   item.i_category_id,
   item.i_category
 order by
   sum(ss_ext_sales_price) desc,
   dt.d_year,
   item.i_category_id,
   item.i_category
 limit 100
 ---- PLAN
 Max Per-Host Resource Reservation: Memory=8.81MB Threads=4
 Per-Host Resource Estimates: Memory=150MB
 F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
 |  Per-Host Resources: mem-estimate=149.88MB mem-reservation=8.81MB thread-reservation=4 runtime-filters-memory=2.00MB
 PLAN-ROOT SINK
 |  output exprs: dt.d_year, item.i_category_id, item.i_category, sum(ss_ext_sales_price)
 |  mem-estimate=0B mem-reservation=0B thread-reservation=0
 |
 06:TOP-N [LIMIT=100]
 |  order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
 |  mem-estimate=4.09KB mem-reservation=0B thread-reservation=0
 |  tuple-ids=4 row-size=42B cardinality=100
 |  in pipelines: 06(GETNEXT), 05(OPEN)
 |
 05:AGGREGATE [FINALIZE]
 |  output: sum(ss_ext_sales_price)
 |  group by: dt.d_year, item.i_category_id, item.i_category
 |  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=3 row-size=42B cardinality=1.73K
 |  in pipelines: 05(GETNEXT), 01(OPEN)
 |
 04:HASH JOIN [INNER JOIN]
 |  hash predicates: store_sales.ss_sold_date_sk = dt.d_date_sk
 |  fk/pk conjuncts: store_sales.ss_sold_date_sk = dt.d_date_sk
 |  runtime filters: RF000[bloom] <- dt.d_date_sk
 |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=1,2,0 row-size=62B cardinality=1.73K
 |  in pipelines: 01(GETNEXT), 00(OPEN)
 |
 |--00:SCAN HDFS [tpcds_parquet.date_dim dt]
 |     HDFS partitions=1/1 files=1 size=2.15MB
 |     predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 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: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
 |     parquet dictionary predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
 |     mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
 |     tuple-ids=0 row-size=12B cardinality=108
 |     in pipelines: 00(GETNEXT)
 |
 03:HASH JOIN [INNER JOIN]
 |  hash predicates: store_sales.ss_item_sk = item.i_item_sk
 |  fk/pk conjuncts: store_sales.ss_item_sk = item.i_item_sk
 |  runtime filters: RF002[bloom] <- item.i_item_sk
 |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=1,2 row-size=50B cardinality=29.12K
 |  in pipelines: 01(GETNEXT), 02(OPEN)
 |
 |--02:SCAN HDFS [tpcds_parquet.item]
 |     HDFS partitions=1/1 files=1 size=1.73MB
 |     predicates: item.i_manager_id = CAST(1 AS INT)
 |     stored statistics:
 |       table: rows=18.00K size=1.73MB
 |       columns: all
 |     extrapolated-rows=disabled max-scan-range-rows=18.00K
 |     parquet statistics predicates: item.i_manager_id = CAST(1 AS INT)
 |     parquet dictionary predicates: item.i_manager_id = CAST(1 AS INT)
 |     mem-estimate=64.00MB mem-reservation=256.00KB thread-reservation=1
 |     tuple-ids=2 row-size=34B cardinality=182
 |     in pipelines: 02(GETNEXT)
 |
 01:SCAN HDFS [tpcds_parquet.store_sales]
    HDFS partitions=1824/1824 files=1824 size=200.95MB
    runtime filters: RF000[bloom] -> store_sales.ss_sold_date_sk, RF002[bloom] -> store_sales.ss_item_sk
    stored statistics:
      table: rows=2.88M size=200.95MB
      partitions: 1824/1824 rows=2.88M
      columns: all
    extrapolated-rows=disabled max-scan-range-rows=130.09K
    mem-estimate=32.00MB mem-reservation=1.00MB thread-reservation=1
    tuple-ids=1 row-size=16B cardinality=2.88M
    in pipelines: 01(GETNEXT)
 ---- DISTRIBUTEDPLAN
 Max Per-Host Resource Reservation: Memory=11.56MB Threads=8
 Per-Host Resource Estimates: Memory=170MB
 F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
 |  Per-Host Resources: mem-estimate=16.00KB mem-reservation=0B thread-reservation=1
 PLAN-ROOT SINK
 |  output exprs: dt.d_year, item.i_category_id, item.i_category, sum(ss_ext_sales_price)
 |  mem-estimate=0B mem-reservation=0B thread-reservation=0
 |
 11:MERGING-EXCHANGE [UNPARTITIONED]
 |  order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
 |  limit: 100
 |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
 |  tuple-ids=4 row-size=42B cardinality=100
 |  in pipelines: 06(GETNEXT)
 |
 F03:PLAN FRAGMENT [HASH(dt.d_year,item.i_category_id,item.i_category)] hosts=3 instances=3
 Per-Host Resources: mem-estimate=10.16MB mem-reservation=1.94MB thread-reservation=1
 06:TOP-N [LIMIT=100]
 |  order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
 |  mem-estimate=4.09KB mem-reservation=0B thread-reservation=0
 |  tuple-ids=4 row-size=42B cardinality=100
 |  in pipelines: 06(GETNEXT), 10(OPEN)
 |
 10:AGGREGATE [FINALIZE]
 |  output: sum:merge(ss_ext_sales_price)
 |  group by: dt.d_year, item.i_category_id, item.i_category
 |  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=3 row-size=42B cardinality=1.73K
 |  in pipelines: 10(GETNEXT), 01(OPEN)
 |
 09:EXCHANGE [HASH(dt.d_year,item.i_category_id,item.i_category)]
 |  mem-estimate=161.21KB mem-reservation=0B thread-reservation=0
 |  tuple-ids=3 row-size=42B cardinality=1.73K
 |  in pipelines: 01(GETNEXT)
 |
 F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
 Per-Host Resources: mem-estimate=47.91MB mem-reservation=8.88MB thread-reservation=2 runtime-filters-memory=2.00MB
 05:AGGREGATE [STREAMING]
 |  output: sum(ss_ext_sales_price)
 |  group by: dt.d_year, item.i_category_id, item.i_category
 |  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=3 row-size=42B cardinality=1.73K
 |  in pipelines: 01(GETNEXT)
 |
 04:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: store_sales.ss_sold_date_sk = dt.d_date_sk
 |  fk/pk conjuncts: store_sales.ss_sold_date_sk = dt.d_date_sk
 |  runtime filters: RF000[bloom] <- dt.d_date_sk
 |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=1,2,0 row-size=62B cardinality=1.73K
 |  in pipelines: 01(GETNEXT), 00(OPEN)
 |
 |--08:EXCHANGE [BROADCAST]
 |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
 |  |  tuple-ids=0 row-size=12B cardinality=108
 |  |  in pipelines: 00(GETNEXT)
 |  |
 |  F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
 |  Per-Host Resources: mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=2
 |  00:SCAN HDFS [tpcds_parquet.date_dim dt, RANDOM]
 |     HDFS partitions=1/1 files=1 size=2.15MB
 |     predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 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: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
 |     parquet dictionary predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
 |     mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
 |     tuple-ids=0 row-size=12B cardinality=108
 |     in pipelines: 00(GETNEXT)
 |
 03:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: store_sales.ss_item_sk = item.i_item_sk
 |  fk/pk conjuncts: store_sales.ss_item_sk = item.i_item_sk
 |  runtime filters: RF002[bloom] <- item.i_item_sk
 |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=1,2 row-size=50B cardinality=29.12K
 |  in pipelines: 01(GETNEXT), 02(OPEN)
 |
 |--07:EXCHANGE [BROADCAST]
 |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
 |  |  tuple-ids=2 row-size=34B cardinality=182
 |  |  in pipelines: 02(GETNEXT)
 |  |
 |  F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
 |  Per-Host Resources: mem-estimate=64.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: item.i_manager_id = CAST(1 AS INT)
 |     stored statistics:
 |       table: rows=18.00K size=1.73MB
 |       columns: all
 |     extrapolated-rows=disabled max-scan-range-rows=18.00K
 |     parquet statistics predicates: item.i_manager_id = CAST(1 AS INT)
 |     parquet dictionary predicates: item.i_manager_id = CAST(1 AS INT)
 |     mem-estimate=64.00MB mem-reservation=256.00KB thread-reservation=1
 |     tuple-ids=2 row-size=34B cardinality=182
 |     in pipelines: 02(GETNEXT)
 |
 01:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
    HDFS partitions=1824/1824 files=1824 size=200.95MB
    runtime filters: RF000[bloom] -> store_sales.ss_sold_date_sk, RF002[bloom] -> store_sales.ss_item_sk
    stored statistics:
      table: rows=2.88M size=200.95MB
      partitions: 1824/1824 rows=2.88M
      columns: all
    extrapolated-rows=disabled max-scan-range-rows=130.09K
    mem-estimate=32.00MB mem-reservation=1.00MB thread-reservation=1
    tuple-ids=1 row-size=16B cardinality=2.88M
    in pipelines: 01(GETNEXT)
 ---- PARALLELPLANS
 Max Per-Host Resource Reservation: Memory=22.38MB Threads=9
 Per-Host Resource Estimates: Memory=116MB
 F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
 |  Per-Instance Resources: mem-estimate=28.26KB mem-reservation=0B thread-reservation=1
 PLAN-ROOT SINK
 |  output exprs: dt.d_year, item.i_category_id, item.i_category, sum(ss_ext_sales_price)
 |  mem-estimate=0B mem-reservation=0B thread-reservation=0
 |
 11:MERGING-EXCHANGE [UNPARTITIONED]
 |  order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
 |  limit: 100
 |  mem-estimate=28.26KB mem-reservation=0B thread-reservation=0
 |  tuple-ids=4 row-size=42B cardinality=100
 |  in pipelines: 06(GETNEXT)
 |
 F03:PLAN FRAGMENT [HASH(dt.d_year,item.i_category_id,item.i_category)] hosts=3 instances=6
 Per-Instance Resources: mem-estimate=10.29MB mem-reservation=1.94MB thread-reservation=1
 06:TOP-N [LIMIT=100]
 |  order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
 |  mem-estimate=4.09KB mem-reservation=0B thread-reservation=0
 |  tuple-ids=4 row-size=42B cardinality=100
 |  in pipelines: 06(GETNEXT), 10(OPEN)
 |
 10:AGGREGATE [FINALIZE]
 |  output: sum:merge(ss_ext_sales_price)
 |  group by: dt.d_year, item.i_category_id, item.i_category
 |  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=3 row-size=42B cardinality=1.73K
 |  in pipelines: 10(GETNEXT), 01(OPEN)
 |
 09:EXCHANGE [HASH(dt.d_year,item.i_category_id,item.i_category)]
 |  mem-estimate=298.90KB mem-reservation=0B thread-reservation=0
 |  tuple-ids=3 row-size=42B cardinality=1.73K
 |  in pipelines: 01(GETNEXT)
 |
 F00: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=26.00MB mem-reservation=3.00MB thread-reservation=1
 05:AGGREGATE [STREAMING]
 |  output: sum(ss_ext_sales_price)
 |  group by: dt.d_year, item.i_category_id, item.i_category
 |  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=3 row-size=42B cardinality=1.73K
 |  in pipelines: 01(GETNEXT)
 |
 04:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash-table-id=00
 |  hash predicates: store_sales.ss_sold_date_sk = dt.d_date_sk
 |  fk/pk conjuncts: store_sales.ss_sold_date_sk = dt.d_date_sk
 |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=1,2,0 row-size=62B cardinality=1.73K
 |  in pipelines: 01(GETNEXT), 00(OPEN)
 |
 |--F05: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=00 plan-id=01 cohort-id=01
 |  |  build expressions: dt.d_date_sk
 |  |  runtime filters: RF000[bloom] <- dt.d_date_sk
 |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
 |  |
 |  08:EXCHANGE [BROADCAST]
 |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
 |  |  tuple-ids=0 row-size=12B cardinality=108
 |  |  in pipelines: 00(GETNEXT)
 |  |
 |  F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
 |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
 |  00:SCAN HDFS [tpcds_parquet.date_dim dt, RANDOM]
 |     HDFS partitions=1/1 files=1 size=2.15MB
 |     predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 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: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
 |     parquet dictionary predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
 |     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
 |     tuple-ids=0 row-size=12B cardinality=108
 |     in pipelines: 00(GETNEXT)
 |
 03:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash-table-id=01
 |  hash predicates: store_sales.ss_item_sk = item.i_item_sk
 |  fk/pk conjuncts: store_sales.ss_item_sk = item.i_item_sk
 |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
 |  tuple-ids=1,2 row-size=50B cardinality=29.12K
 |  in pipelines: 01(GETNEXT), 02(OPEN)
 |
 |--F06: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=01 plan-id=02 cohort-id=01
 |  |  build expressions: item.i_item_sk
 |  |  runtime filters: RF002[bloom] <- item.i_item_sk
 |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
 |  |
 |  07:EXCHANGE [BROADCAST]
 |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
 |  |  tuple-ids=2 row-size=34B cardinality=182
 |  |  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: item.i_manager_id = CAST(1 AS INT)
 |     stored statistics:
 |       table: rows=18.00K size=1.73MB
 |       columns: all
 |     extrapolated-rows=disabled max-scan-range-rows=18.00K
 |     parquet statistics predicates: item.i_manager_id = CAST(1 AS INT)
 |     parquet dictionary predicates: item.i_manager_id = CAST(1 AS INT)
 |     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
 |     tuple-ids=2 row-size=34B cardinality=182
 |     in pipelines: 02(GETNEXT)
 |
 01:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
    HDFS partitions=1824/1824 files=1824 size=200.95MB
    runtime filters: RF000[bloom] -> store_sales.ss_sold_date_sk, RF002[bloom] -> store_sales.ss_item_sk
    stored statistics:
      table: rows=2.88M size=200.95MB
      partitions: 1824/1824 rows=2.88M
      columns: all
    extrapolated-rows=disabled max-scan-range-rows=130.09K
    mem-estimate=16.00MB mem-reservation=1.00MB thread-reservation=0
    tuple-ids=1 row-size=16B cardinality=2.88M
    in pipelines: 01(GETNEXT)
 ====
	# TPCDS-Q42
	select
	dt.d_year,
	item.i_category_id,
	item.i_category,
	sum(ss_ext_sales_price)
	from
	date_dim dt,
	store_sales,
	item
	where
	dt.d_date_sk = store_sales.ss_sold_date_sk
	and store_sales.ss_item_sk = item.i_item_sk
	and item.i_manager_id = 1
	and dt.d_moy = 12
	and dt.d_year = 1998
	group by
	dt.d_year,
	item.i_category_id,
	item.i_category
	order by
	sum(ss_ext_sales_price) desc,
	dt.d_year,
	item.i_category_id,
	item.i_category
	limit 100
	---- PLAN
	Max Per-Host Resource Reservation: Memory=8.81MB Threads=4
	Per-Host Resource Estimates: Memory=150MB
	F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
	\| Per-Host Resources: mem-estimate=149.88MB mem-reservation=8.81MB thread-reservation=4 runtime-filters-memory=2.00MB
	PLAN-ROOT SINK
	\| output exprs: dt.d_year, item.i_category_id, item.i_category, sum(ss_ext_sales_price)
	\| mem-estimate=0B mem-reservation=0B thread-reservation=0
	\|
	06:TOP-N [LIMIT=100]
	\| order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
	\| mem-estimate=4.09KB mem-reservation=0B thread-reservation=0
	\| tuple-ids=4 row-size=42B cardinality=100
	\| in pipelines: 06(GETNEXT), 05(OPEN)
	\|
	05:AGGREGATE [FINALIZE]
	\| output: sum(ss_ext_sales_price)
	\| group by: dt.d_year, item.i_category_id, item.i_category
	\| mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=3 row-size=42B cardinality=1.73K
	\| in pipelines: 05(GETNEXT), 01(OPEN)
	\|
	04:HASH JOIN [INNER JOIN]
	\| hash predicates: store_sales.ss_sold_date_sk = dt.d_date_sk
	\| fk/pk conjuncts: store_sales.ss_sold_date_sk = dt.d_date_sk
	\| runtime filters: RF000[bloom] <- dt.d_date_sk
	\| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=1,2,0 row-size=62B cardinality=1.73K
	\| in pipelines: 01(GETNEXT), 00(OPEN)
	\|
	\|--00:SCAN HDFS [tpcds_parquet.date_dim dt]
	\| HDFS partitions=1/1 files=1 size=2.15MB
	\| predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 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: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
	\| parquet dictionary predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
	\| mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
	\| tuple-ids=0 row-size=12B cardinality=108
	\| in pipelines: 00(GETNEXT)
	\|
	03:HASH JOIN [INNER JOIN]
	\| hash predicates: store_sales.ss_item_sk = item.i_item_sk
	\| fk/pk conjuncts: store_sales.ss_item_sk = item.i_item_sk
	\| runtime filters: RF002[bloom] <- item.i_item_sk
	\| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=1,2 row-size=50B cardinality=29.12K
	\| in pipelines: 01(GETNEXT), 02(OPEN)
	\|
	\|--02:SCAN HDFS [tpcds_parquet.item]
	\| HDFS partitions=1/1 files=1 size=1.73MB
	\| predicates: item.i_manager_id = CAST(1 AS INT)
	\| stored statistics:
	\| table: rows=18.00K size=1.73MB
	\| columns: all
	\| extrapolated-rows=disabled max-scan-range-rows=18.00K
	\| parquet statistics predicates: item.i_manager_id = CAST(1 AS INT)
	\| parquet dictionary predicates: item.i_manager_id = CAST(1 AS INT)
	\| mem-estimate=64.00MB mem-reservation=256.00KB thread-reservation=1
	\| tuple-ids=2 row-size=34B cardinality=182
	\| in pipelines: 02(GETNEXT)
	\|
	01:SCAN HDFS [tpcds_parquet.store_sales]
	HDFS partitions=1824/1824 files=1824 size=200.95MB
	runtime filters: RF000[bloom] -> store_sales.ss_sold_date_sk, RF002[bloom] -> store_sales.ss_item_sk
	stored statistics:
	table: rows=2.88M size=200.95MB
	partitions: 1824/1824 rows=2.88M
	columns: all
	extrapolated-rows=disabled max-scan-range-rows=130.09K
	mem-estimate=32.00MB mem-reservation=1.00MB thread-reservation=1
	tuple-ids=1 row-size=16B cardinality=2.88M
	in pipelines: 01(GETNEXT)
	---- DISTRIBUTEDPLAN
	Max Per-Host Resource Reservation: Memory=11.56MB Threads=8
	Per-Host Resource Estimates: Memory=170MB
	F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
	\| Per-Host Resources: mem-estimate=16.00KB mem-reservation=0B thread-reservation=1
	PLAN-ROOT SINK
	\| output exprs: dt.d_year, item.i_category_id, item.i_category, sum(ss_ext_sales_price)
	\| mem-estimate=0B mem-reservation=0B thread-reservation=0
	\|
	11:MERGING-EXCHANGE [UNPARTITIONED]
	\| order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
	\| limit: 100
	\| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
	\| tuple-ids=4 row-size=42B cardinality=100
	\| in pipelines: 06(GETNEXT)
	\|
	F03:PLAN FRAGMENT [HASH(dt.d_year,item.i_category_id,item.i_category)] hosts=3 instances=3
	Per-Host Resources: mem-estimate=10.16MB mem-reservation=1.94MB thread-reservation=1
	06:TOP-N [LIMIT=100]
	\| order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
	\| mem-estimate=4.09KB mem-reservation=0B thread-reservation=0
	\| tuple-ids=4 row-size=42B cardinality=100
	\| in pipelines: 06(GETNEXT), 10(OPEN)
	\|
	10:AGGREGATE [FINALIZE]
	\| output: sum:merge(ss_ext_sales_price)
	\| group by: dt.d_year, item.i_category_id, item.i_category
	\| mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=3 row-size=42B cardinality=1.73K
	\| in pipelines: 10(GETNEXT), 01(OPEN)
	\|
	09:EXCHANGE [HASH(dt.d_year,item.i_category_id,item.i_category)]
	\| mem-estimate=161.21KB mem-reservation=0B thread-reservation=0
	\| tuple-ids=3 row-size=42B cardinality=1.73K
	\| in pipelines: 01(GETNEXT)
	\|
	F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
	Per-Host Resources: mem-estimate=47.91MB mem-reservation=8.88MB thread-reservation=2 runtime-filters-memory=2.00MB
	05:AGGREGATE [STREAMING]
	\| output: sum(ss_ext_sales_price)
	\| group by: dt.d_year, item.i_category_id, item.i_category
	\| mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=3 row-size=42B cardinality=1.73K
	\| in pipelines: 01(GETNEXT)
	\|
	04:HASH JOIN [INNER JOIN, BROADCAST]
	\| hash predicates: store_sales.ss_sold_date_sk = dt.d_date_sk
	\| fk/pk conjuncts: store_sales.ss_sold_date_sk = dt.d_date_sk
	\| runtime filters: RF000[bloom] <- dt.d_date_sk
	\| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=1,2,0 row-size=62B cardinality=1.73K
	\| in pipelines: 01(GETNEXT), 00(OPEN)
	\|
	\|--08:EXCHANGE [BROADCAST]
	\| \| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
	\| \| tuple-ids=0 row-size=12B cardinality=108
	\| \| in pipelines: 00(GETNEXT)
	\| \|
	\| F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
	\| Per-Host Resources: mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=2
	\| 00:SCAN HDFS [tpcds_parquet.date_dim dt, RANDOM]
	\| HDFS partitions=1/1 files=1 size=2.15MB
	\| predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 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: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
	\| parquet dictionary predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
	\| mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
	\| tuple-ids=0 row-size=12B cardinality=108
	\| in pipelines: 00(GETNEXT)
	\|
	03:HASH JOIN [INNER JOIN, BROADCAST]
	\| hash predicates: store_sales.ss_item_sk = item.i_item_sk
	\| fk/pk conjuncts: store_sales.ss_item_sk = item.i_item_sk
	\| runtime filters: RF002[bloom] <- item.i_item_sk
	\| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=1,2 row-size=50B cardinality=29.12K
	\| in pipelines: 01(GETNEXT), 02(OPEN)
	\|
	\|--07:EXCHANGE [BROADCAST]
	\| \| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
	\| \| tuple-ids=2 row-size=34B cardinality=182
	\| \| in pipelines: 02(GETNEXT)
	\| \|
	\| F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
	\| Per-Host Resources: mem-estimate=64.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: item.i_manager_id = CAST(1 AS INT)
	\| stored statistics:
	\| table: rows=18.00K size=1.73MB
	\| columns: all
	\| extrapolated-rows=disabled max-scan-range-rows=18.00K
	\| parquet statistics predicates: item.i_manager_id = CAST(1 AS INT)
	\| parquet dictionary predicates: item.i_manager_id = CAST(1 AS INT)
	\| mem-estimate=64.00MB mem-reservation=256.00KB thread-reservation=1
	\| tuple-ids=2 row-size=34B cardinality=182
	\| in pipelines: 02(GETNEXT)
	\|
	01:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
	HDFS partitions=1824/1824 files=1824 size=200.95MB
	runtime filters: RF000[bloom] -> store_sales.ss_sold_date_sk, RF002[bloom] -> store_sales.ss_item_sk
	stored statistics:
	table: rows=2.88M size=200.95MB
	partitions: 1824/1824 rows=2.88M
	columns: all
	extrapolated-rows=disabled max-scan-range-rows=130.09K
	mem-estimate=32.00MB mem-reservation=1.00MB thread-reservation=1
	tuple-ids=1 row-size=16B cardinality=2.88M
	in pipelines: 01(GETNEXT)
	---- PARALLELPLANS
	Max Per-Host Resource Reservation: Memory=22.38MB Threads=9
	Per-Host Resource Estimates: Memory=116MB
	F04:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
	\| Per-Instance Resources: mem-estimate=28.26KB mem-reservation=0B thread-reservation=1
	PLAN-ROOT SINK
	\| output exprs: dt.d_year, item.i_category_id, item.i_category, sum(ss_ext_sales_price)
	\| mem-estimate=0B mem-reservation=0B thread-reservation=0
	\|
	11:MERGING-EXCHANGE [UNPARTITIONED]
	\| order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
	\| limit: 100
	\| mem-estimate=28.26KB mem-reservation=0B thread-reservation=0
	\| tuple-ids=4 row-size=42B cardinality=100
	\| in pipelines: 06(GETNEXT)
	\|
	F03:PLAN FRAGMENT [HASH(dt.d_year,item.i_category_id,item.i_category)] hosts=3 instances=6
	Per-Instance Resources: mem-estimate=10.29MB mem-reservation=1.94MB thread-reservation=1
	06:TOP-N [LIMIT=100]
	\| order by: sum(ss_ext_sales_price) DESC, dt.d_year ASC, item.i_category_id ASC, item.i_category ASC
	\| mem-estimate=4.09KB mem-reservation=0B thread-reservation=0
	\| tuple-ids=4 row-size=42B cardinality=100
	\| in pipelines: 06(GETNEXT), 10(OPEN)
	\|
	10:AGGREGATE [FINALIZE]
	\| output: sum:merge(ss_ext_sales_price)
	\| group by: dt.d_year, item.i_category_id, item.i_category
	\| mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=3 row-size=42B cardinality=1.73K
	\| in pipelines: 10(GETNEXT), 01(OPEN)
	\|
	09:EXCHANGE [HASH(dt.d_year,item.i_category_id,item.i_category)]
	\| mem-estimate=298.90KB mem-reservation=0B thread-reservation=0
	\| tuple-ids=3 row-size=42B cardinality=1.73K
	\| in pipelines: 01(GETNEXT)
	\|
	F00: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=26.00MB mem-reservation=3.00MB thread-reservation=1
	05:AGGREGATE [STREAMING]
	\| output: sum(ss_ext_sales_price)
	\| group by: dt.d_year, item.i_category_id, item.i_category
	\| mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=3 row-size=42B cardinality=1.73K
	\| in pipelines: 01(GETNEXT)
	\|
	04:HASH JOIN [INNER JOIN, BROADCAST]
	\| hash-table-id=00
	\| hash predicates: store_sales.ss_sold_date_sk = dt.d_date_sk
	\| fk/pk conjuncts: store_sales.ss_sold_date_sk = dt.d_date_sk
	\| mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=1,2,0 row-size=62B cardinality=1.73K
	\| in pipelines: 01(GETNEXT), 00(OPEN)
	\|
	\|--F05: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=00 plan-id=01 cohort-id=01
	\| \| build expressions: dt.d_date_sk
	\| \| runtime filters: RF000[bloom] <- dt.d_date_sk
	\| \| mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
	\| \|
	\| 08:EXCHANGE [BROADCAST]
	\| \| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
	\| \| tuple-ids=0 row-size=12B cardinality=108
	\| \| in pipelines: 00(GETNEXT)
	\| \|
	\| F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
	\| Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
	\| 00:SCAN HDFS [tpcds_parquet.date_dim dt, RANDOM]
	\| HDFS partitions=1/1 files=1 size=2.15MB
	\| predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 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: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
	\| parquet dictionary predicates: dt.d_year = CAST(1998 AS INT), dt.d_moy = CAST(12 AS INT)
	\| mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
	\| tuple-ids=0 row-size=12B cardinality=108
	\| in pipelines: 00(GETNEXT)
	\|
	03:HASH JOIN [INNER JOIN, BROADCAST]
	\| hash-table-id=01
	\| hash predicates: store_sales.ss_item_sk = item.i_item_sk
	\| fk/pk conjuncts: store_sales.ss_item_sk = item.i_item_sk
	\| mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
	\| tuple-ids=1,2 row-size=50B cardinality=29.12K
	\| in pipelines: 01(GETNEXT), 02(OPEN)
	\|
	\|--F06: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=01 plan-id=02 cohort-id=01
	\| \| build expressions: item.i_item_sk
	\| \| runtime filters: RF002[bloom] <- item.i_item_sk
	\| \| mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
	\| \|
	\| 07:EXCHANGE [BROADCAST]
	\| \| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
	\| \| tuple-ids=2 row-size=34B cardinality=182
	\| \| 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: item.i_manager_id = CAST(1 AS INT)
	\| stored statistics:
	\| table: rows=18.00K size=1.73MB
	\| columns: all
	\| extrapolated-rows=disabled max-scan-range-rows=18.00K
	\| parquet statistics predicates: item.i_manager_id = CAST(1 AS INT)
	\| parquet dictionary predicates: item.i_manager_id = CAST(1 AS INT)
	\| mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
	\| tuple-ids=2 row-size=34B cardinality=182
	\| in pipelines: 02(GETNEXT)
	\|
	01:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
	HDFS partitions=1824/1824 files=1824 size=200.95MB
	runtime filters: RF000[bloom] -> store_sales.ss_sold_date_sk, RF002[bloom] -> store_sales.ss_item_sk
	stored statistics:
	table: rows=2.88M size=200.95MB
	partitions: 1824/1824 rows=2.88M
	columns: all
	extrapolated-rows=disabled max-scan-range-rows=130.09K
	mem-estimate=16.00MB mem-reservation=1.00MB thread-reservation=0
	tuple-ids=1 row-size=16B cardinality=2.88M
	in pipelines: 01(GETNEXT)
	====