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

# TPCDS-Q24-2 second of two queries
WITH ssales AS
  (SELECT c_last_name,
          c_first_name,
          s_store_name,
          ca_state,
          s_state,
          i_color,
          i_current_price,
          i_manager_id,
          i_units,
          i_size,
          sum(ss_net_paid) netpaid
   FROM store_sales,
        store_returns,
        store,
        item,
        customer,
        customer_address
   WHERE ss_ticket_number = sr_ticket_number
     AND ss_item_sk = sr_item_sk
     AND ss_customer_sk = c_customer_sk
     AND ss_item_sk = i_item_sk
     AND ss_store_sk = s_store_sk
     AND c_current_addr_sk = ca_address_sk
     AND c_birth_country <> upper(ca_country)
     AND s_zip = ca_zip
     AND s_market_id = 8
   GROUP BY c_last_name,
            c_first_name,
            s_store_name,
            ca_state,
            s_state,
            i_color,
            i_current_price,
            i_manager_id,
            i_units,
            i_size)
SELECT c_last_name,
       c_first_name,
       s_store_name,
       sum(netpaid) paid
FROM ssales
WHERE i_color = 'saddle'
GROUP BY c_last_name,
         c_first_name,
         s_store_name
HAVING sum(netpaid) >
  (SELECT 0.05*avg(netpaid)
   FROM ssales)
ORDER BY c_last_name,
         c_first_name,
         s_store_name ;
---- PLAN
Max Per-Host Resource Reservation: Memory=91.81MB Threads=13
Per-Host Resource Estimates: Memory=936MB
F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=936.44MB mem-reservation=91.81MB thread-reservation=13 runtime-filters-memory=10.00MB
PLAN-ROOT SINK
|  output exprs: $c$1, $c$2, $c$3, $c$4
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
27:SORT
|  order by: $c$1 ASC, $c$2 ASC, $c$3 ASC
|  mem-estimate=12.00MB mem-reservation=12.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=21 row-size=68B cardinality=7.69K
|  in pipelines: 27(GETNEXT), 12(OPEN)
|
26:NESTED LOOP JOIN [INNER JOIN]
|  predicates: sum(netpaid) > CAST(0.05 AS DECIMAL(2,2)) * avg(netpaid)
|  mem-estimate=16B mem-reservation=0B thread-reservation=0
|  tuple-ids=8,19 row-size=84B cardinality=7.69K
|  in pipelines: 12(GETNEXT), 25(OPEN)
|
|--25:AGGREGATE [FINALIZE]
|  |  output: avg(sum(ss_net_paid))
|  |  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=19 row-size=16B cardinality=1
|  |  in pipelines: 25(GETNEXT), 24(OPEN)
|  |
|  24:AGGREGATE [FINALIZE]
|  |  output: sum(ss_net_paid)
|  |  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  |  mem-estimate=114.18MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=16 row-size=154B cardinality=706.14K
|  |  in pipelines: 24(GETNEXT), 13(OPEN)
|  |
|  23:HASH JOIN [INNER JOIN]
|  |  hash predicates: c_current_addr_sk = ca_address_sk, s_zip = ca_zip
|  |  fk/pk conjuncts: c_current_addr_sk = ca_address_sk
|  |  other predicates: c_birth_country != upper(ca_country)
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13,14,15 row-size=290B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 18(OPEN)
|  |
|  |--18:SCAN HDFS [tpcds_parquet.customer_address]
|  |     HDFS partitions=1/1 files=1 size=1.16MB
|  |     stored statistics:
|  |       table: rows=50.00K size=1.16MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=50.00K
|  |     mem-estimate=64.00MB mem-reservation=512.00KB thread-reservation=1
|  |     tuple-ids=15 row-size=60B cardinality=50.00K
|  |     in pipelines: 18(GETNEXT)
|  |
|  22:HASH JOIN [INNER JOIN]
|  |  hash predicates: ss_customer_sk = c_customer_sk
|  |  fk/pk conjuncts: ss_customer_sk = c_customer_sk
|  |  mem-estimate=8.50MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13,14 row-size=230B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 17(OPEN)
|  |
|  |--17:SCAN HDFS [tpcds_parquet.customer]
|  |     HDFS partitions=1/1 files=1 size=5.49MB
|  |     stored statistics:
|  |       table: rows=100.00K size=5.49MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=100.00K
|  |     mem-estimate=80.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=14 row-size=65B cardinality=100.00K
|  |     in pipelines: 17(GETNEXT)
|  |
|  21:HASH JOIN [INNER JOIN]
|  |  hash predicates: ss_item_sk = i_item_sk
|  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13 row-size=165B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 16(OPEN)
|  |
|  |--16:SCAN HDFS [tpcds_parquet.item]
|  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |     tuple-ids=13 row-size=66B cardinality=18.00K
|  |     in pipelines: 16(GETNEXT)
|  |
|  20:HASH JOIN [INNER JOIN]
|  |  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
|  |  runtime filters: RF022[bloom] <- sr_item_sk, RF023[bloom] <- sr_ticket_number
|  |  mem-estimate=8.50MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  |  tuple-ids=10,12,11 row-size=99B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 14(OPEN)
|  |
|  |--14: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=48.00MB mem-reservation=4.00MB thread-reservation=1
|  |     tuple-ids=11 row-size=16B cardinality=287.51K
|  |     in pipelines: 14(GETNEXT)
|  |
|  19:HASH JOIN [INNER JOIN]
|  |  hash predicates: ss_store_sk = s_store_sk
|  |  fk/pk conjuncts: ss_store_sk = s_store_sk
|  |  runtime filters: RF026[bloom] <- s_store_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=10,12 row-size=83B cardinality=960.13K
|  |  in pipelines: 13(GETNEXT), 15(OPEN)
|  |
|  |--15:SCAN HDFS [tpcds_parquet.store]
|  |     HDFS partitions=1/1 files=1 size=9.93KB
|  |     predicates: s_market_id = CAST(8 AS INT)
|  |     stored statistics:
|  |       table: rows=12 size=9.93KB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=12
|  |     parquet statistics predicates: s_market_id = CAST(8 AS INT)
|  |     parquet dictionary predicates: s_market_id = CAST(8 AS INT)
|  |     mem-estimate=80.00MB mem-reservation=40.00KB thread-reservation=1
|  |     tuple-ids=12 row-size=55B cardinality=2
|  |     in pipelines: 15(GETNEXT)
|  |
|  13:SCAN HDFS [tpcds_parquet.store_sales]
|     HDFS partitions=1824/1824 files=1824 size=200.95MB
|     runtime filters: RF026[bloom] -> ss_store_sk, RF022[bloom] -> ss_item_sk, RF023[bloom] -> ss_ticket_number
|     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=80.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=10 row-size=28B cardinality=2.88M
|     in pipelines: 13(GETNEXT)
|
12:AGGREGATE [FINALIZE]
|  output: sum(sum(ss_net_paid))
|  group by: c_last_name, c_first_name, s_store_name
|  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=8 row-size=68B cardinality=7.69K
|  in pipelines: 12(GETNEXT), 11(OPEN)
|
11:AGGREGATE [FINALIZE]
|  output: sum(ss_net_paid)
|  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=6 row-size=154B cardinality=7.69K
|  in pipelines: 11(GETNEXT), 05(OPEN)
|
10:HASH JOIN [INNER JOIN]
|  hash predicates: ca_address_sk = c_current_addr_sk, ca_zip = s_zip
|  fk/pk conjuncts: ca_address_sk = c_current_addr_sk
|  other predicates: c_birth_country != upper(ca_country)
|  runtime filters: RF000[bloom] <- c_current_addr_sk, RF001[bloom] <- s_zip
|  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=5,4,1,0,3,2 row-size=290B cardinality=7.69K
|  in pipelines: 05(GETNEXT), 04(OPEN)
|
|--09:HASH JOIN [INNER JOIN]
|  |  hash predicates: c_customer_sk = ss_customer_sk
|  |  fk/pk conjuncts: c_customer_sk = ss_customer_sk
|  |  runtime filters: RF004[bloom] <- ss_customer_sk
|  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=4,1,0,3,2 row-size=230B cardinality=7.69K
|  |  in pipelines: 04(GETNEXT), 01(OPEN)
|  |
|  |--08:HASH JOIN [INNER 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
|  |  |  runtime filters: RF006[bloom] <- ss_item_sk, RF007[bloom] <- ss_ticket_number
|  |  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  |  tuple-ids=1,0,3,2 row-size=165B cardinality=7.69K
|  |  |  in pipelines: 01(GETNEXT), 00(OPEN)
|  |  |
|  |  |--07:HASH JOIN [INNER JOIN]
|  |  |  |  hash predicates: ss_store_sk = s_store_sk
|  |  |  |  fk/pk conjuncts: ss_store_sk = s_store_sk
|  |  |  |  runtime filters: RF010[bloom] <- s_store_sk
|  |  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |  tuple-ids=0,3,2 row-size=149B cardinality=10.46K
|  |  |  |  in pipelines: 00(GETNEXT), 02(OPEN)
|  |  |  |
|  |  |  |--02:SCAN HDFS [tpcds_parquet.store]
|  |  |  |     HDFS partitions=1/1 files=1 size=9.93KB
|  |  |  |     predicates: s_market_id = CAST(8 AS INT)
|  |  |  |     stored statistics:
|  |  |  |       table: rows=12 size=9.93KB
|  |  |  |       columns: all
|  |  |  |     extrapolated-rows=disabled max-scan-range-rows=12
|  |  |  |     parquet statistics predicates: s_market_id = CAST(8 AS INT)
|  |  |  |     parquet dictionary predicates: s_market_id = CAST(8 AS INT)
|  |  |  |     mem-estimate=80.00MB mem-reservation=40.00KB thread-reservation=1
|  |  |  |     tuple-ids=2 row-size=55B cardinality=2
|  |  |  |     in pipelines: 02(GETNEXT)
|  |  |  |
|  |  |  06:HASH JOIN [INNER JOIN]
|  |  |  |  hash predicates: ss_item_sk = i_item_sk
|  |  |  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  |  |  runtime filters: RF012[bloom] <- i_item_sk
|  |  |  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  |  |  tuple-ids=0,3 row-size=94B cardinality=31.36K
|  |  |  |  in pipelines: 00(GETNEXT), 03(OPEN)
|  |  |  |
|  |  |  |--03:SCAN HDFS [tpcds_parquet.item]
|  |  |  |     HDFS partitions=1/1 files=1 size=1.73MB
|  |  |  |     predicates: tpcds_parquet.item.i_color = 'saddle'
|  |  |  |     stored statistics:
|  |  |  |       table: rows=18.00K size=1.73MB
|  |  |  |       columns: all
|  |  |  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |  |  |     parquet statistics predicates: tpcds_parquet.item.i_color = 'saddle'
|  |  |  |     parquet dictionary predicates: tpcds_parquet.item.i_color = 'saddle'
|  |  |  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |  |  |     tuple-ids=3 row-size=66B cardinality=196
|  |  |  |     in pipelines: 03(GETNEXT)
|  |  |  |
|  |  |  00:SCAN HDFS [tpcds_parquet.store_sales]
|  |  |     HDFS partitions=1824/1824 files=1824 size=200.95MB
|  |  |     runtime filters: RF012[bloom] -> ss_item_sk, RF010[bloom] -> ss_store_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=80.00MB mem-reservation=4.00MB thread-reservation=1
|  |  |     tuple-ids=0 row-size=28B cardinality=2.88M
|  |  |     in pipelines: 00(GETNEXT)
|  |  |
|  |  01:SCAN HDFS [tpcds_parquet.store_returns]
|  |     HDFS partitions=1/1 files=1 size=15.43MB
|  |     runtime filters: RF006[bloom] -> sr_item_sk, RF007[bloom] -> sr_ticket_number
|  |     stored statistics:
|  |       table: rows=287.51K size=15.43MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=287.51K
|  |     mem-estimate=48.00MB mem-reservation=4.00MB thread-reservation=1
|  |     tuple-ids=1 row-size=16B cardinality=287.51K
|  |     in pipelines: 01(GETNEXT)
|  |
|  04:SCAN HDFS [tpcds_parquet.customer]
|     HDFS partitions=1/1 files=1 size=5.49MB
|     runtime filters: RF004[bloom] -> c_customer_sk
|     stored statistics:
|       table: rows=100.00K size=5.49MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=100.00K
|     mem-estimate=80.00MB mem-reservation=2.00MB thread-reservation=1
|     tuple-ids=4 row-size=65B cardinality=100.00K
|     in pipelines: 04(GETNEXT)
|
05:SCAN HDFS [tpcds_parquet.customer_address]
   HDFS partitions=1/1 files=1 size=1.16MB
   runtime filters: RF000[bloom] -> ca_address_sk, RF001[bloom] -> ca_zip
   stored statistics:
     table: rows=50.00K size=1.16MB
     columns: all
   extrapolated-rows=disabled max-scan-range-rows=50.00K
   mem-estimate=64.00MB mem-reservation=512.00KB thread-reservation=1
   tuple-ids=5 row-size=60B cardinality=50.00K
   in pipelines: 05(GETNEXT)
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=165.45MB Threads=32
Per-Host Resource Estimates: Memory=1.14GB
F19:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=387.40KB mem-reservation=0B thread-reservation=1
PLAN-ROOT SINK
|  output exprs: $c$1, $c$2, $c$3, $c$4
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
50:MERGING-EXCHANGE [UNPARTITIONED]
|  order by: $c$1 ASC, $c$2 ASC, $c$3 ASC
|  mem-estimate=387.40KB mem-reservation=0B thread-reservation=0
|  tuple-ids=21 row-size=68B cardinality=7.69K
|  in pipelines: 27(GETNEXT)
|
F10:PLAN FRAGMENT [HASH(c_last_name,c_first_name,s_store_name)] hosts=3 instances=3
Per-Host Resources: mem-estimate=22.02MB mem-reservation=13.94MB thread-reservation=1
27:SORT
|  order by: $c$1 ASC, $c$2 ASC, $c$3 ASC
|  mem-estimate=12.00MB mem-reservation=12.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=21 row-size=68B cardinality=7.69K
|  in pipelines: 27(GETNEXT), 39(OPEN)
|
26:NESTED LOOP JOIN [INNER JOIN, BROADCAST]
|  predicates: sum(netpaid) > CAST(0.05 AS DECIMAL(2,2)) * avg(netpaid)
|  mem-estimate=16B mem-reservation=0B thread-reservation=0
|  tuple-ids=8,19 row-size=84B cardinality=7.69K
|  in pipelines: 39(GETNEXT), 48(OPEN)
|
|--49:EXCHANGE [BROADCAST]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=19 row-size=16B cardinality=1
|  |  in pipelines: 48(GETNEXT)
|  |
|  F18:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1
|  48:AGGREGATE [FINALIZE]
|  |  output: avg:merge(netpaid)
|  |  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=19 row-size=16B cardinality=1
|  |  in pipelines: 48(GETNEXT), 25(OPEN)
|  |
|  47:EXCHANGE [UNPARTITIONED]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=18 row-size=16B cardinality=1
|  |  in pipelines: 25(GETNEXT)
|  |
|  F17:PLAN FRAGMENT [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=67.55MB mem-reservation=34.00MB thread-reservation=1
|  25:AGGREGATE
|  |  output: avg(sum(ss_net_paid))
|  |  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=18 row-size=16B cardinality=1
|  |  in pipelines: 25(GETNEXT), 46(OPEN)
|  |
|  46:AGGREGATE [FINALIZE]
|  |  output: sum:merge(ss_net_paid)
|  |  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  |  mem-estimate=57.09MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=16 row-size=154B cardinality=706.14K
|  |  in pipelines: 46(GETNEXT), 13(OPEN)
|  |
|  45:EXCHANGE [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)]
|  |  mem-estimate=10.46MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=16 row-size=154B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT)
|  |
|  F11:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=181.43MB mem-reservation=67.56MB thread-reservation=2 runtime-filters-memory=3.00MB
|  24:AGGREGATE [STREAMING]
|  |  output: sum(ss_net_paid)
|  |  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  |  mem-estimate=57.09MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=16 row-size=154B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT)
|  |
|  23:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: c_current_addr_sk = ca_address_sk, s_zip = ca_zip
|  |  fk/pk conjuncts: c_current_addr_sk = ca_address_sk
|  |  other predicates: c_birth_country != upper(ca_country)
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13,14,15 row-size=290B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 18(OPEN)
|  |
|  |--44:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=2.92MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=15 row-size=60B cardinality=50.00K
|  |  |  in pipelines: 18(GETNEXT)
|  |  |
|  |  F16:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=64.00MB mem-reservation=512.00KB thread-reservation=2
|  |  18:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.16MB
|  |     stored statistics:
|  |       table: rows=50.00K size=1.16MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=50.00K
|  |     mem-estimate=64.00MB mem-reservation=512.00KB thread-reservation=1
|  |     tuple-ids=15 row-size=60B cardinality=50.00K
|  |     in pipelines: 18(GETNEXT)
|  |
|  22:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: ss_customer_sk = c_customer_sk
|  |  fk/pk conjuncts: ss_customer_sk = c_customer_sk
|  |  mem-estimate=8.50MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13,14 row-size=230B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 17(OPEN)
|  |
|  |--43:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=6.23MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=14 row-size=65B cardinality=100.00K
|  |  |  in pipelines: 17(GETNEXT)
|  |  |
|  |  F15:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=80.00MB mem-reservation=2.00MB thread-reservation=2
|  |  17:SCAN HDFS [tpcds_parquet.customer, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=5.49MB
|  |     stored statistics:
|  |       table: rows=100.00K size=5.49MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=100.00K
|  |     mem-estimate=80.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=14 row-size=65B cardinality=100.00K
|  |     in pipelines: 17(GETNEXT)
|  |
|  21:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: ss_item_sk = i_item_sk
|  |  fk/pk conjuncts: ss_item_sk = i_item_sk
|  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13 row-size=165B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 16(OPEN)
|  |
|  |--42:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=1.20MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=13 row-size=66B cardinality=18.00K
|  |  |  in pipelines: 16(GETNEXT)
|  |  |
|  |  F14: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
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|  |     tuple-ids=13 row-size=66B cardinality=18.00K
|  |     in pipelines: 16(GETNEXT)
|  |
|  20:HASH JOIN [INNER JOIN, BROADCAST]
|  |  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
|  |  runtime filters: RF022[bloom] <- sr_item_sk, RF023[bloom] <- sr_ticket_number
|  |  mem-estimate=8.50MB mem-reservation=8.50MB spill-buffer=512.00KB thread-reservation=0
|  |  tuple-ids=10,12,11 row-size=99B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 14(OPEN)
|  |
|  |--41:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=4.41MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=11 row-size=16B cardinality=287.51K
|  |  |  in pipelines: 14(GETNEXT)
|  |  |
|  |  F13:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=48.00MB mem-reservation=4.00MB thread-reservation=2
|  |  14: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=48.00MB mem-reservation=4.00MB thread-reservation=1
|  |     tuple-ids=11 row-size=16B cardinality=287.51K
|  |     in pipelines: 14(GETNEXT)
|  |
|  19:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: ss_store_sk = s_store_sk
|  |  fk/pk conjuncts: ss_store_sk = s_store_sk
|  |  runtime filters: RF026[bloom] <- s_store_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=10,12 row-size=83B cardinality=960.13K
|  |  in pipelines: 13(GETNEXT), 15(OPEN)
|  |
|  |--40:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=12 row-size=55B cardinality=2
|  |  |  in pipelines: 15(GETNEXT)
|  |  |
|  |  F12:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=80.00MB mem-reservation=40.00KB thread-reservation=2
|  |  15:SCAN HDFS [tpcds_parquet.store, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=9.93KB
|  |     predicates: s_market_id = CAST(8 AS INT)
|  |     stored statistics:
|  |       table: rows=12 size=9.93KB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=12
|  |     parquet statistics predicates: s_market_id = CAST(8 AS INT)
|  |     parquet dictionary predicates: s_market_id = CAST(8 AS INT)
|  |     mem-estimate=80.00MB mem-reservation=40.00KB thread-reservation=1
|  |     tuple-ids=12 row-size=55B cardinality=2
|  |     in pipelines: 15(GETNEXT)
|  |
|  13:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
|     HDFS partitions=1824/1824 files=1824 size=200.95MB
|     runtime filters: RF026[bloom] -> ss_store_sk, RF022[bloom] -> ss_item_sk, RF023[bloom] -> ss_ticket_number
|     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=80.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=10 row-size=28B cardinality=2.88M
|     in pipelines: 13(GETNEXT)
|
39:AGGREGATE [FINALIZE]
|  output: sum:merge(netpaid)
|  group by: c_last_name, c_first_name, s_store_name
|  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=8 row-size=68B cardinality=7.69K
|  in pipelines: 39(GETNEXT), 37(OPEN)
|
38:EXCHANGE [HASH(c_last_name,c_first_name,s_store_name)]
|  mem-estimate=387.40KB mem-reservation=0B thread-reservation=0
|  tuple-ids=8 row-size=68B cardinality=7.69K
|  in pipelines: 37(GETNEXT)
|
F09:PLAN FRAGMENT [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)] hosts=3 instances=3
Per-Host Resources: mem-estimate=20.84MB mem-reservation=3.94MB thread-reservation=1
12:AGGREGATE [STREAMING]
|  output: sum(sum(ss_net_paid))
|  group by: c_last_name, c_first_name, s_store_name
|  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=8 row-size=68B cardinality=7.69K
|  in pipelines: 37(GETNEXT)
|
37:AGGREGATE [FINALIZE]
|  output: sum:merge(ss_net_paid)
|  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=6 row-size=154B cardinality=7.69K
|  in pipelines: 37(GETNEXT), 00(OPEN)
|
36:EXCHANGE [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)]
|  mem-estimate=860.24KB mem-reservation=0B thread-reservation=0
|  tuple-ids=6 row-size=154B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
F08:PLAN FRAGMENT [HASH(c_current_addr_sk,s_zip)] hosts=3 instances=3
Per-Host Resources: mem-estimate=18.15MB mem-reservation=5.94MB thread-reservation=1 runtime-filters-memory=2.00MB
11:AGGREGATE [STREAMING]
|  output: sum(ss_net_paid)
|  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=6 row-size=154B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
10:HASH JOIN [INNER JOIN, PARTITIONED]
|  hash predicates: c_current_addr_sk = ca_address_sk, s_zip = ca_zip
|  fk/pk conjuncts: c_current_addr_sk = ca_address_sk
|  other predicates: c_birth_country != upper(ca_country)
|  runtime filters: RF000[bloom] <- ca_address_sk, RF001[bloom] <- ca_zip
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,3,2,1,4,5 row-size=290B cardinality=7.69K
|  in pipelines: 00(GETNEXT), 05(OPEN)
|
|--35:EXCHANGE [HASH(ca_address_sk,ca_zip)]
|  |  mem-estimate=2.92MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=5 row-size=60B cardinality=50.00K
|  |  in pipelines: 05(GETNEXT)
|  |
|  F07:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=64.00MB mem-reservation=512.00KB thread-reservation=2
|  05:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
|     HDFS partitions=1/1 files=1 size=1.16MB
|     stored statistics:
|       table: rows=50.00K size=1.16MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=50.00K
|     mem-estimate=64.00MB mem-reservation=512.00KB thread-reservation=1
|     tuple-ids=5 row-size=60B cardinality=50.00K
|     in pipelines: 05(GETNEXT)
|
34:EXCHANGE [HASH(c_current_addr_sk,s_zip)]
|  mem-estimate=1.29MB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,3,2,1,4 row-size=230B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
F06:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=3
Per-Host Resources: mem-estimate=12.92MB mem-reservation=5.75MB thread-reservation=1 runtime-filters-memory=1.00MB
09:HASH JOIN [INNER JOIN, PARTITIONED]
|  hash predicates: ss_customer_sk = c_customer_sk
|  fk/pk conjuncts: ss_customer_sk = c_customer_sk
|  runtime filters: RF004[bloom] <- c_customer_sk
|  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  tuple-ids=0,3,2,1,4 row-size=230B cardinality=7.69K
|  in pipelines: 00(GETNEXT), 04(OPEN)
|
|--33:EXCHANGE [HASH(c_customer_sk)]
|  |  mem-estimate=6.23MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=4 row-size=65B cardinality=100.00K
|  |  in pipelines: 04(GETNEXT)
|  |
|  F05:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=81.00MB mem-reservation=3.00MB thread-reservation=2 runtime-filters-memory=1.00MB
|  04:SCAN HDFS [tpcds_parquet.customer, RANDOM]
|     HDFS partitions=1/1 files=1 size=5.49MB
|     runtime filters: RF000[bloom] -> c_current_addr_sk
|     stored statistics:
|       table: rows=100.00K size=5.49MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=100.00K
|     mem-estimate=80.00MB mem-reservation=2.00MB thread-reservation=1
|     tuple-ids=4 row-size=65B cardinality=100.00K
|     in pipelines: 04(GETNEXT)
|
32:EXCHANGE [HASH(ss_customer_sk)]
|  mem-estimate=956.98KB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,3,2,1 row-size=165B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
F04:PLAN FRAGMENT [HASH(ss_item_sk,ss_ticket_number)] hosts=3 instances=3
Per-Host Resources: mem-estimate=10.25MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=2.00MB
08:HASH JOIN [INNER 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
|  runtime filters: RF006[bloom] <- sr_item_sk, RF007[bloom] <- sr_ticket_number
|  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=0,3,2,1 row-size=165B cardinality=7.69K
|  in pipelines: 00(GETNEXT), 01(OPEN)
|
|--31:EXCHANGE [HASH(sr_item_sk,sr_ticket_number)]
|  |  mem-estimate=4.41MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=1 row-size=16B cardinality=287.51K
|  |  in pipelines: 01(GETNEXT)
|  |
|  F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=48.00MB mem-reservation=4.00MB thread-reservation=2
|  01: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=48.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=1 row-size=16B cardinality=287.51K
|     in pipelines: 01(GETNEXT)
|
30:EXCHANGE [HASH(ss_item_sk,ss_ticket_number)]
|  mem-estimate=991.19KB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,3,2 row-size=149B cardinality=10.46K
|  in pipelines: 00(GETNEXT)
|
F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
Per-Host Resources: mem-estimate=88.92MB mem-reservation=12.88MB thread-reservation=2 runtime-filters-memory=5.00MB
07:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: ss_store_sk = s_store_sk
|  fk/pk conjuncts: ss_store_sk = s_store_sk
|  runtime filters: RF010[bloom] <- s_store_sk
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,3,2 row-size=149B cardinality=10.46K
|  in pipelines: 00(GETNEXT), 02(OPEN)
|
|--29:EXCHANGE [BROADCAST]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=2 row-size=55B cardinality=2
|  |  in pipelines: 02(GETNEXT)
|  |
|  F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=81.00MB mem-reservation=1.04MB thread-reservation=2 runtime-filters-memory=1.00MB
|  02:SCAN HDFS [tpcds_parquet.store, RANDOM]
|     HDFS partitions=1/1 files=1 size=9.93KB
|     predicates: s_market_id = CAST(8 AS INT)
|     runtime filters: RF001[bloom] -> s_zip
|     stored statistics:
|       table: rows=12 size=9.93KB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=12
|     parquet statistics predicates: s_market_id = CAST(8 AS INT)
|     parquet dictionary predicates: s_market_id = CAST(8 AS INT)
|     mem-estimate=80.00MB mem-reservation=40.00KB thread-reservation=1
|     tuple-ids=2 row-size=55B cardinality=2
|     in pipelines: 02(GETNEXT)
|
06:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: ss_item_sk = i_item_sk
|  fk/pk conjuncts: ss_item_sk = i_item_sk
|  runtime filters: RF012[bloom] <- i_item_sk
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,3 row-size=94B cardinality=31.36K
|  in pipelines: 00(GETNEXT), 03(OPEN)
|
|--28:EXCHANGE [BROADCAST]
|  |  mem-estimate=26.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=3 row-size=66B cardinality=196
|  |  in pipelines: 03(GETNEXT)
|  |
|  F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=97.00MB mem-reservation=1.25MB thread-reservation=2 runtime-filters-memory=1.00MB
|  03:SCAN HDFS [tpcds_parquet.item, RANDOM]
|     HDFS partitions=1/1 files=1 size=1.73MB
|     predicates: tpcds_parquet.item.i_color = 'saddle'
|     runtime filters: RF006[bloom] -> tpcds_parquet.item.i_item_sk
|     stored statistics:
|       table: rows=18.00K size=1.73MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=18.00K
|     parquet statistics predicates: tpcds_parquet.item.i_color = 'saddle'
|     parquet dictionary predicates: tpcds_parquet.item.i_color = 'saddle'
|     mem-estimate=96.00MB mem-reservation=256.00KB thread-reservation=1
|     tuple-ids=3 row-size=66B cardinality=196
|     in pipelines: 03(GETNEXT)
|
00:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
   HDFS partitions=1824/1824 files=1824 size=200.95MB
   runtime filters: RF012[bloom] -> ss_item_sk, RF010[bloom] -> ss_store_sk, RF006[bloom] -> ss_item_sk, RF007[bloom] -> ss_ticket_number, RF004[bloom] -> ss_customer_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=80.00MB mem-reservation=4.00MB thread-reservation=1
   tuple-ids=0 row-size=28B cardinality=2.88M
   in pipelines: 00(GETNEXT)
---- PARALLELPLANS
Max Per-Host Resource Reservation: Memory=305.70MB Threads=42
Per-Host Resource Estimates: Memory=667MB
F19:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=604.05KB mem-reservation=0B thread-reservation=1
PLAN-ROOT SINK
|  output exprs: $c$1, $c$2, $c$3, $c$4
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
50:MERGING-EXCHANGE [UNPARTITIONED]
|  order by: $c$1 ASC, $c$2 ASC, $c$3 ASC
|  mem-estimate=604.05KB mem-reservation=0B thread-reservation=0
|  tuple-ids=21 row-size=68B cardinality=7.69K
|  in pipelines: 27(GETNEXT)
|
F10:PLAN FRAGMENT [HASH(c_last_name,c_first_name,s_store_name)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=22.00MB mem-reservation=13.94MB thread-reservation=1
27:SORT
|  order by: $c$1 ASC, $c$2 ASC, $c$3 ASC
|  mem-estimate=12.00MB mem-reservation=12.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=21 row-size=68B cardinality=7.69K
|  in pipelines: 27(GETNEXT), 39(OPEN)
|
26:NESTED LOOP JOIN [INNER JOIN, BROADCAST]
|  join table id: 00
|  predicates: sum(netpaid) > CAST(0.05 AS DECIMAL(2,2)) * avg(netpaid)
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|  tuple-ids=8,19 row-size=84B cardinality=7.69K
|  in pipelines: 39(GETNEXT), 48(OPEN)
|
|--F20:PLAN FRAGMENT [HASH(c_last_name,c_first_name,s_store_name)] hosts=3 instances=3
|  |  Per-Instance Resources: mem-estimate=16.02KB mem-reservation=0B thread-reservation=1
|  JOIN BUILD
|  |  join-table-id=00 plan-id=01 cohort-id=01
|  |  mem-estimate=16B mem-reservation=0B thread-reservation=0
|  |
|  49:EXCHANGE [BROADCAST]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=19 row-size=16B cardinality=1
|  |  in pipelines: 48(GETNEXT)
|  |
|  F18:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1
|  48:AGGREGATE [FINALIZE]
|  |  output: avg:merge(netpaid)
|  |  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=19 row-size=16B cardinality=1
|  |  in pipelines: 48(GETNEXT), 25(OPEN)
|  |
|  47:EXCHANGE [UNPARTITIONED]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=18 row-size=16B cardinality=1
|  |  in pipelines: 25(GETNEXT)
|  |
|  F17:PLAN FRAGMENT [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)] hosts=3 instances=6
|  Per-Instance Resources: mem-estimate=44.93MB mem-reservation=34.00MB thread-reservation=1
|  25:AGGREGATE
|  |  output: avg(sum(ss_net_paid))
|  |  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=18 row-size=16B cardinality=1
|  |  in pipelines: 25(GETNEXT), 46(OPEN)
|  |
|  46:AGGREGATE [FINALIZE]
|  |  output: sum:merge(ss_net_paid)
|  |  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  |  mem-estimate=34.00MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=16 row-size=154B cardinality=706.14K
|  |  in pipelines: 46(GETNEXT), 13(OPEN)
|  |
|  45:EXCHANGE [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)]
|  |  mem-estimate=10.93MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=16 row-size=154B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT)
|  |
|  F11:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
|  Per-Host Shared Resources: mem-estimate=3.00MB mem-reservation=3.00MB thread-reservation=0 runtime-filters-memory=3.00MB
|  Per-Instance Resources: mem-estimate=50.00MB mem-reservation=38.00MB thread-reservation=1
|  24:AGGREGATE [STREAMING]
|  |  output: sum(ss_net_paid)
|  |  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  |  mem-estimate=34.00MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=16 row-size=154B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT)
|  |
|  23:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=01
|  |  hash predicates: c_current_addr_sk = ca_address_sk, s_zip = ca_zip
|  |  fk/pk conjuncts: c_current_addr_sk = ca_address_sk
|  |  other predicates: c_birth_country != upper(ca_country)
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13,14,15 row-size=290B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 18(OPEN)
|  |
|  |--F21:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=12.42MB mem-reservation=9.50MB thread-reservation=1
|  |  JOIN BUILD
|  |  |  join-table-id=01 plan-id=02 cohort-id=02
|  |  |  build expressions: ca_address_sk, ca_zip
|  |  |  mem-estimate=9.50MB mem-reservation=9.50MB spill-buffer=256.00KB thread-reservation=0
|  |  |
|  |  44:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=2.92MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=15 row-size=60B cardinality=50.00K
|  |  |  in pipelines: 18(GETNEXT)
|  |  |
|  |  F16:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  |  18:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=1.16MB
|  |     stored statistics:
|  |       table: rows=50.00K size=1.16MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=50.00K
|  |     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|  |     tuple-ids=15 row-size=60B cardinality=50.00K
|  |     in pipelines: 18(GETNEXT)
|  |
|  22:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=02
|  |  hash predicates: ss_customer_sk = c_customer_sk
|  |  fk/pk conjuncts: ss_customer_sk = c_customer_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=512.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13,14 row-size=230B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 17(OPEN)
|  |
|  |--F22:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=23.23MB mem-reservation=17.00MB thread-reservation=1
|  |  JOIN BUILD
|  |  |  join-table-id=02 plan-id=03 cohort-id=02
|  |  |  build expressions: c_customer_sk
|  |  |  mem-estimate=17.00MB mem-reservation=17.00MB spill-buffer=512.00KB thread-reservation=0
|  |  |
|  |  43:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=6.23MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=14 row-size=65B cardinality=100.00K
|  |  |  in pipelines: 17(GETNEXT)
|  |  |
|  |  F15:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=1
|  |  17:SCAN HDFS [tpcds_parquet.customer, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=5.49MB
|  |     stored statistics:
|  |       table: rows=100.00K size=5.49MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=100.00K
|  |     mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=0
|  |     tuple-ids=14 row-size=65B cardinality=100.00K
|  |     in pipelines: 17(GETNEXT)
|  |
|  21:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=03
|  |  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=128.00KB thread-reservation=0
|  |  tuple-ids=10,12,11,13 row-size=165B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 16(OPEN)
|  |
|  |--F23:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=6.95MB mem-reservation=5.75MB thread-reservation=1
|  |  JOIN BUILD
|  |  |  join-table-id=03 plan-id=04 cohort-id=02
|  |  |  build expressions: i_item_sk
|  |  |  mem-estimate=5.75MB mem-reservation=5.75MB spill-buffer=128.00KB thread-reservation=0
|  |  |
|  |  42:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=1.20MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=13 row-size=66B cardinality=18.00K
|  |  |  in pipelines: 16(GETNEXT)
|  |  |
|  |  F14: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
|  |     stored statistics:
|  |       table: rows=18.00K size=1.73MB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=18.00K
|  |     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|  |     tuple-ids=13 row-size=66B cardinality=18.00K
|  |     in pipelines: 16(GETNEXT)
|  |
|  20:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=04
|  |  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=512.00KB thread-reservation=0
|  |  tuple-ids=10,12,11 row-size=99B cardinality=706.14K
|  |  in pipelines: 13(GETNEXT), 14(OPEN)
|  |
|  |--F24:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  |  Per-Instance Resources: mem-estimate=23.41MB mem-reservation=19.00MB thread-reservation=1 runtime-filters-memory=2.00MB
|  |  JOIN BUILD
|  |  |  join-table-id=04 plan-id=05 cohort-id=02
|  |  |  build expressions: sr_item_sk, sr_ticket_number
|  |  |  runtime filters: RF022[bloom] <- sr_item_sk, RF023[bloom] <- sr_ticket_number
|  |  |  mem-estimate=17.00MB mem-reservation=17.00MB spill-buffer=512.00KB thread-reservation=0
|  |  |
|  |  41:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=4.41MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=11 row-size=16B cardinality=287.51K
|  |  |  in pipelines: 14(GETNEXT)
|  |  |
|  |  F13:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=1
|  |  14: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=11 row-size=16B cardinality=287.51K
|  |     in pipelines: 14(GETNEXT)
|  |
|  19:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash-table-id=05
|  |  hash predicates: ss_store_sk = s_store_sk
|  |  fk/pk conjuncts: ss_store_sk = s_store_sk
|  |  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=10,12 row-size=83B cardinality=960.13K
|  |  in pipelines: 13(GETNEXT), 15(OPEN)
|  |
|  |--F25: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=05 plan-id=06 cohort-id=02
|  |  |  build expressions: s_store_sk
|  |  |  runtime filters: RF026[bloom] <- s_store_sk
|  |  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |  |
|  |  40:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=12 row-size=55B cardinality=2
|  |  |  in pipelines: 15(GETNEXT)
|  |  |
|  |  F12:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=40.00KB thread-reservation=1
|  |  15:SCAN HDFS [tpcds_parquet.store, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=9.93KB
|  |     predicates: s_market_id = CAST(8 AS INT)
|  |     stored statistics:
|  |       table: rows=12 size=9.93KB
|  |       columns: all
|  |     extrapolated-rows=disabled max-scan-range-rows=12
|  |     parquet statistics predicates: s_market_id = CAST(8 AS INT)
|  |     parquet dictionary predicates: s_market_id = CAST(8 AS INT)
|  |     mem-estimate=16.00MB mem-reservation=40.00KB thread-reservation=0
|  |     tuple-ids=12 row-size=55B cardinality=2
|  |     in pipelines: 15(GETNEXT)
|  |
|  13:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
|     HDFS partitions=1824/1824 files=1824 size=200.95MB
|     runtime filters: RF026[bloom] -> ss_store_sk, RF022[bloom] -> ss_item_sk, RF023[bloom] -> ss_ticket_number
|     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=4.00MB thread-reservation=0
|     tuple-ids=10 row-size=28B cardinality=2.88M
|     in pipelines: 13(GETNEXT)
|
39:AGGREGATE [FINALIZE]
|  output: sum:merge(netpaid)
|  group by: c_last_name, c_first_name, s_store_name
|  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=8 row-size=68B cardinality=7.69K
|  in pipelines: 39(GETNEXT), 37(OPEN)
|
38:EXCHANGE [HASH(c_last_name,c_first_name,s_store_name)]
|  mem-estimate=604.05KB mem-reservation=0B thread-reservation=0
|  tuple-ids=8 row-size=68B cardinality=7.69K
|  in pipelines: 37(GETNEXT)
|
F09:PLAN FRAGMENT [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=21.30MB mem-reservation=3.94MB thread-reservation=1
12:AGGREGATE [STREAMING]
|  output: sum(sum(ss_net_paid))
|  group by: c_last_name, c_first_name, s_store_name
|  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=8 row-size=68B cardinality=7.69K
|  in pipelines: 37(GETNEXT)
|
37:AGGREGATE [FINALIZE]
|  output: sum:merge(ss_net_paid)
|  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=6 row-size=154B cardinality=7.69K
|  in pipelines: 37(GETNEXT), 00(OPEN)
|
36:EXCHANGE [HASH(c_last_name,c_first_name,s_store_name,ca_state,s_state,i_color,i_current_price,i_manager_id,i_units,i_size)]
|  mem-estimate=1.30MB mem-reservation=0B thread-reservation=0
|  tuple-ids=6 row-size=154B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
F08:PLAN FRAGMENT [HASH(c_current_addr_sk,s_zip)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=12.03MB mem-reservation=2.00MB thread-reservation=1
11:AGGREGATE [STREAMING]
|  output: sum(ss_net_paid)
|  group by: c_last_name, c_first_name, s_store_name, ca_state, s_state, i_color, i_current_price, i_manager_id, i_units, i_size
|  mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=6 row-size=154B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
10:HASH JOIN [INNER JOIN, PARTITIONED]
|  hash-table-id=06
|  hash predicates: c_current_addr_sk = ca_address_sk, s_zip = ca_zip
|  fk/pk conjuncts: c_current_addr_sk = ca_address_sk
|  other predicates: c_birth_country != upper(ca_country)
|  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,3,2,1,4,5 row-size=290B cardinality=7.69K
|  in pipelines: 00(GETNEXT), 05(OPEN)
|
|--F26:PLAN FRAGMENT [HASH(c_current_addr_sk,s_zip)] hosts=3 instances=6
|  |  Per-Instance Resources: mem-estimate=6.86MB mem-reservation=3.94MB thread-reservation=1 runtime-filters-memory=2.00MB
|  JOIN BUILD
|  |  join-table-id=06 plan-id=07 cohort-id=01
|  |  build expressions: ca_address_sk, ca_zip
|  |  runtime filters: RF000[bloom] <- ca_address_sk, RF001[bloom] <- ca_zip
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |
|  35:EXCHANGE [HASH(ca_address_sk,ca_zip)]
|  |  mem-estimate=2.92MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=5 row-size=60B cardinality=50.00K
|  |  in pipelines: 05(GETNEXT)
|  |
|  F07:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
|  05:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
|     HDFS partitions=1/1 files=1 size=1.16MB
|     stored statistics:
|       table: rows=50.00K size=1.16MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=50.00K
|     mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
|     tuple-ids=5 row-size=60B cardinality=50.00K
|     in pipelines: 05(GETNEXT)
|
34:EXCHANGE [HASH(c_current_addr_sk,s_zip)]
|  mem-estimate=2.03MB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,3,2,1,4 row-size=230B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
F06:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=1.47MB mem-reservation=0B thread-reservation=1
09:HASH JOIN [INNER JOIN, PARTITIONED]
|  hash-table-id=07
|  hash predicates: ss_customer_sk = c_customer_sk
|  fk/pk conjuncts: ss_customer_sk = c_customer_sk
|  mem-estimate=0B mem-reservation=0B spill-buffer=128.00KB thread-reservation=0
|  tuple-ids=0,3,2,1,4 row-size=230B cardinality=7.69K
|  in pipelines: 00(GETNEXT), 04(OPEN)
|
|--F27:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=6
|  |  Per-Instance Resources: mem-estimate=10.11MB mem-reservation=3.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  JOIN BUILD
|  |  join-table-id=07 plan-id=08 cohort-id=01
|  |  build expressions: c_customer_sk
|  |  runtime filters: RF004[bloom] <- c_customer_sk
|  |  mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0
|  |
|  33:EXCHANGE [HASH(c_customer_sk)]
|  |  mem-estimate=6.23MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=4 row-size=65B cardinality=100.00K
|  |  in pipelines: 04(GETNEXT)
|  |
|  F05:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  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=16.00MB mem-reservation=2.00MB thread-reservation=1
|  04:SCAN HDFS [tpcds_parquet.customer, RANDOM]
|     HDFS partitions=1/1 files=1 size=5.49MB
|     runtime filters: RF000[bloom] -> c_current_addr_sk
|     stored statistics:
|       table: rows=100.00K size=5.49MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=100.00K
|     mem-estimate=16.00MB mem-reservation=2.00MB thread-reservation=0
|     tuple-ids=4 row-size=65B cardinality=100.00K
|     in pipelines: 04(GETNEXT)
|
32:EXCHANGE [HASH(ss_customer_sk)]
|  mem-estimate=1.47MB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,3,2,1 row-size=165B cardinality=7.69K
|  in pipelines: 00(GETNEXT)
|
F04:PLAN FRAGMENT [HASH(ss_item_sk,ss_ticket_number)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=1.44MB mem-reservation=0B thread-reservation=1
08:HASH JOIN [INNER JOIN, PARTITIONED]
|  hash-table-id=08
|  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=64.00KB thread-reservation=0
|  tuple-ids=0,3,2,1 row-size=165B cardinality=7.69K
|  in pipelines: 00(GETNEXT), 01(OPEN)
|
|--F28:PLAN FRAGMENT [HASH(ss_item_sk,ss_ticket_number)] hosts=3 instances=6
|  |  Per-Instance Resources: mem-estimate=8.34MB mem-reservation=3.94MB thread-reservation=1 runtime-filters-memory=2.00MB
|  JOIN BUILD
|  |  join-table-id=08 plan-id=09 cohort-id=01
|  |  build expressions: sr_item_sk, sr_ticket_number
|  |  runtime filters: RF006[bloom] <- sr_item_sk, RF007[bloom] <- sr_ticket_number
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |
|  31:EXCHANGE [HASH(sr_item_sk,sr_ticket_number)]
|  |  mem-estimate=4.41MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=1 row-size=16B cardinality=287.51K
|  |  in pipelines: 01(GETNEXT)
|  |
|  F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Instance Resources: mem-estimate=24.00MB mem-reservation=4.00MB thread-reservation=1
|  01: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=1 row-size=16B cardinality=287.51K
|     in pipelines: 01(GETNEXT)
|
30:EXCHANGE [HASH(ss_item_sk,ss_ticket_number)]
|  mem-estimate=1.44MB mem-reservation=0B thread-reservation=0
|  tuple-ids=0,3,2 row-size=149B cardinality=10.46K
|  in pipelines: 00(GETNEXT)
|
F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=6
Per-Host Shared Resources: mem-estimate=5.00MB mem-reservation=5.00MB thread-reservation=0 runtime-filters-memory=5.00MB
Per-Instance Resources: mem-estimate=16.00MB mem-reservation=4.00MB thread-reservation=1
07:HASH JOIN [INNER JOIN, BROADCAST]
|  hash-table-id=09
|  hash predicates: ss_store_sk = s_store_sk
|  fk/pk conjuncts: ss_store_sk = s_store_sk
|  mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,3,2 row-size=149B cardinality=10.46K
|  in pipelines: 00(GETNEXT), 02(OPEN)
|
|--F29: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=09 plan-id=10 cohort-id=01
|  |  build expressions: s_store_sk
|  |  runtime filters: RF010[bloom] <- s_store_sk
|  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |
|  29:EXCHANGE [BROADCAST]
|  |  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=2 row-size=55B cardinality=2
|  |  in pipelines: 02(GETNEXT)
|  |
|  F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  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=16.00MB mem-reservation=40.00KB thread-reservation=1
|  02:SCAN HDFS [tpcds_parquet.store, RANDOM]
|     HDFS partitions=1/1 files=1 size=9.93KB
|     predicates: s_market_id = CAST(8 AS INT)
|     runtime filters: RF001[bloom] -> s_zip
|     stored statistics:
|       table: rows=12 size=9.93KB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=12
|     parquet statistics predicates: s_market_id = CAST(8 AS INT)
|     parquet dictionary predicates: s_market_id = CAST(8 AS INT)
|     mem-estimate=16.00MB mem-reservation=40.00KB thread-reservation=0
|     tuple-ids=2 row-size=55B cardinality=2
|     in pipelines: 02(GETNEXT)
|
06:HASH JOIN [INNER JOIN, BROADCAST]
|  hash-table-id=10
|  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=0,3 row-size=94B cardinality=31.36K
|  in pipelines: 00(GETNEXT), 03(OPEN)
|
|--F30:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  |  Per-Instance Resources: mem-estimate=4.90MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
|  JOIN BUILD
|  |  join-table-id=10 plan-id=11 cohort-id=01
|  |  build expressions: i_item_sk
|  |  runtime filters: RF012[bloom] <- i_item_sk
|  |  mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
|  |
|  28:EXCHANGE [BROADCAST]
|  |  mem-estimate=26.00KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=3 row-size=66B cardinality=196
|  |  in pipelines: 03(GETNEXT)
|  |
|  F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  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=16.00MB mem-reservation=256.00KB thread-reservation=1
|  03:SCAN HDFS [tpcds_parquet.item, RANDOM]
|     HDFS partitions=1/1 files=1 size=1.73MB
|     predicates: tpcds_parquet.item.i_color = 'saddle'
|     runtime filters: RF006[bloom] -> tpcds_parquet.item.i_item_sk
|     stored statistics:
|       table: rows=18.00K size=1.73MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=18.00K
|     parquet statistics predicates: tpcds_parquet.item.i_color = 'saddle'
|     parquet dictionary predicates: tpcds_parquet.item.i_color = 'saddle'
|     mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
|     tuple-ids=3 row-size=66B cardinality=196
|     in pipelines: 03(GETNEXT)
|
00:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
   HDFS partitions=1824/1824 files=1824 size=200.95MB
   runtime filters: RF012[bloom] -> ss_item_sk, RF010[bloom] -> ss_store_sk, RF006[bloom] -> ss_item_sk, RF007[bloom] -> ss_ticket_number, RF004[bloom] -> ss_customer_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=4.00MB thread-reservation=0
   tuple-ids=0 row-size=28B cardinality=2.88M
   in pipelines: 00(GETNEXT)
====