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

# TPCDS-Q87
SELECT count(*)
FROM ((SELECT DISTINCT c_last_name,
                         c_first_name,
                         d_date
         FROM store_sales,
              date_dim,
              customer
         WHERE store_sales.ss_sold_date_sk = date_dim.d_date_sk
           AND store_sales.ss_customer_sk = customer.c_customer_sk
           AND d_month_seq BETWEEN 1200 AND 1200+11)
      EXCEPT
        (SELECT DISTINCT c_last_name,
                         c_first_name,
                         d_date
         FROM catalog_sales,
              date_dim,
              customer
         WHERE catalog_sales.cs_sold_date_sk = date_dim.d_date_sk
           AND catalog_sales.cs_bill_customer_sk = customer.c_customer_sk
           AND d_month_seq BETWEEN 1200 AND 1200+11)
      EXCEPT
        (SELECT DISTINCT c_last_name,
                         c_first_name,
                         d_date
         FROM web_sales,
              date_dim,
              customer
         WHERE web_sales.ws_sold_date_sk = date_dim.d_date_sk
           AND web_sales.ws_bill_customer_sk = customer.c_customer_sk
           AND d_month_seq BETWEEN 1200 AND 1200+11)) cool_cust;
---- PLAN
Max Per-Host Resource Reservation: Memory=183.19MB Threads=10
Per-Host Resource Estimates: Memory=569MB
F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=569.21MB mem-reservation=183.19MB thread-reservation=10 runtime-filters-memory=6.00MB
PLAN-ROOT SINK
|  output exprs: count(*)
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
20:AGGREGATE [FINALIZE]
|  output: count(*)
|  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=16 row-size=8B cardinality=1
|  in pipelines: 20(GETNEXT), 05(OPEN)
|
19:HASH JOIN [LEFT ANTI JOIN]
|  hash predicates: c_first_name IS NOT DISTINCT FROM c_first_name, c_last_name IS NOT DISTINCT FROM c_last_name, d_date IS NOT DISTINCT FROM d_date
|  mem-estimate=43.74MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 05(GETNEXT), 17(OPEN)
|
|--17:AGGREGATE [FINALIZE]
|  |  group by: c_last_name, c_first_name, d_date
|  |  mem-estimate=43.74MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=13 row-size=58B cardinality=719.38K
|  |  in pipelines: 17(GETNEXT), 12(OPEN)
|  |
|  16:HASH JOIN [INNER JOIN]
|  |  hash predicates: web_sales.ws_bill_customer_sk = customer.c_customer_sk
|  |  fk/pk conjuncts: web_sales.ws_bill_customer_sk = customer.c_customer_sk
|  |  runtime filters: RF008[bloom] <- customer.c_customer_sk
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=10,11,12 row-size=78B cardinality=719.38K
|  |  in pipelines: 12(GETNEXT), 14(OPEN)
|  |
|  |--14: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=48.00MB mem-reservation=1.00MB thread-reservation=1
|  |     tuple-ids=12 row-size=40B cardinality=100.00K
|  |     in pipelines: 14(GETNEXT)
|  |
|  15:HASH JOIN [INNER JOIN]
|  |  hash predicates: web_sales.ws_sold_date_sk = date_dim.d_date_sk
|  |  fk/pk conjuncts: web_sales.ws_sold_date_sk = date_dim.d_date_sk
|  |  runtime filters: RF010[bloom] <- date_dim.d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=10,11 row-size=38B cardinality=719.38K
|  |  in pipelines: 12(GETNEXT), 13(OPEN)
|  |
|  |--13:SCAN HDFS [tpcds_parquet.date_dim]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 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: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     parquet dictionary predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=11 row-size=30B cardinality=7.30K
|  |     in pipelines: 13(GETNEXT)
|  |
|  12:SCAN HDFS [tpcds_parquet.web_sales]
|     HDFS partitions=1/1 files=2 size=45.09MB
|     runtime filters: RF008[bloom] -> web_sales.ws_bill_customer_sk, RF010[bloom] -> web_sales.ws_sold_date_sk
|     stored statistics:
|       table: rows=719.38K size=45.09MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=644.77K
|     mem-estimate=64.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=10 row-size=8B cardinality=719.38K
|     in pipelines: 12(GETNEXT)
|
18:HASH JOIN [LEFT ANTI JOIN]
|  hash predicates: c_first_name IS NOT DISTINCT FROM c_first_name, c_last_name IS NOT DISTINCT FROM c_last_name, d_date IS NOT DISTINCT FROM d_date
|  mem-estimate=87.66MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 05(GETNEXT), 11(OPEN)
|
|--11:AGGREGATE [FINALIZE]
|  |  group by: c_last_name, c_first_name, d_date
|  |  mem-estimate=87.66MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=8 row-size=58B cardinality=1.44M
|  |  in pipelines: 11(GETNEXT), 06(OPEN)
|  |
|  10:HASH JOIN [INNER JOIN]
|  |  hash predicates: catalog_sales.cs_bill_customer_sk = customer.c_customer_sk
|  |  fk/pk conjuncts: catalog_sales.cs_bill_customer_sk = customer.c_customer_sk
|  |  runtime filters: RF004[bloom] <- customer.c_customer_sk
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=5,6,7 row-size=78B cardinality=1.44M
|  |  in pipelines: 06(GETNEXT), 08(OPEN)
|  |
|  |--08: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=48.00MB mem-reservation=1.00MB thread-reservation=1
|  |     tuple-ids=7 row-size=40B cardinality=100.00K
|  |     in pipelines: 08(GETNEXT)
|  |
|  09:HASH JOIN [INNER JOIN]
|  |  hash predicates: catalog_sales.cs_sold_date_sk = date_dim.d_date_sk
|  |  fk/pk conjuncts: catalog_sales.cs_sold_date_sk = date_dim.d_date_sk
|  |  runtime filters: RF006[bloom] <- date_dim.d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=5,6 row-size=38B cardinality=1.44M
|  |  in pipelines: 06(GETNEXT), 07(OPEN)
|  |
|  |--07:SCAN HDFS [tpcds_parquet.date_dim]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 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: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     parquet dictionary predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=6 row-size=30B cardinality=7.30K
|  |     in pipelines: 07(GETNEXT)
|  |
|  06:SCAN HDFS [tpcds_parquet.catalog_sales]
|     HDFS partitions=1/1 files=3 size=96.62MB
|     runtime filters: RF004[bloom] -> catalog_sales.cs_bill_customer_sk, RF006[bloom] -> catalog_sales.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=96.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=5 row-size=8B cardinality=1.44M
|     in pipelines: 06(GETNEXT)
|
05:AGGREGATE [FINALIZE]
|  group by: c_last_name, c_first_name, d_date
|  mem-estimate=175.15MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 05(GETNEXT), 00(OPEN)
|
04:HASH JOIN [INNER JOIN]
|  hash predicates: store_sales.ss_customer_sk = customer.c_customer_sk
|  fk/pk conjuncts: store_sales.ss_customer_sk = customer.c_customer_sk
|  runtime filters: RF000[bloom] <- customer.c_customer_sk
|  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  tuple-ids=0,1,2 row-size=78B cardinality=2.88M
|  in pipelines: 00(GETNEXT), 02(OPEN)
|
|--02: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=48.00MB mem-reservation=1.00MB thread-reservation=1
|     tuple-ids=2 row-size=40B cardinality=100.00K
|     in pipelines: 02(GETNEXT)
|
03:HASH JOIN [INNER JOIN]
|  hash predicates: store_sales.ss_sold_date_sk = date_dim.d_date_sk
|  fk/pk conjuncts: store_sales.ss_sold_date_sk = date_dim.d_date_sk
|  runtime filters: RF002[bloom] <- date_dim.d_date_sk
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,1 row-size=38B cardinality=2.88M
|  in pipelines: 00(GETNEXT), 01(OPEN)
|
|--01:SCAN HDFS [tpcds_parquet.date_dim]
|     HDFS partitions=1/1 files=1 size=2.15MB
|     predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 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: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|     parquet dictionary predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|     mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1
|     tuple-ids=1 row-size=30B cardinality=7.30K
|     in pipelines: 01(GETNEXT)
|
00:SCAN HDFS [tpcds_parquet.store_sales]
   HDFS partitions=1824/1824 files=1824 size=200.95MB
   runtime filters: RF000[bloom] -> store_sales.ss_customer_sk, RF002[bloom] -> store_sales.ss_sold_date_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=512.00KB thread-reservation=1
   tuple-ids=0 row-size=8B cardinality=2.88M
   in pipelines: 00(GETNEXT)
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=298.56MB Threads=22
Per-Host Resource Estimates: Memory=945MB
F12:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1
PLAN-ROOT SINK
|  output exprs: count(*)
|  mem-estimate=0B mem-reservation=0B thread-reservation=0
|
36:AGGREGATE [FINALIZE]
|  output: count:merge(*)
|  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=16 row-size=8B cardinality=1
|  in pipelines: 36(GETNEXT), 20(OPEN)
|
35:EXCHANGE [UNPARTITIONED]
|  mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
|  tuple-ids=16 row-size=8B cardinality=1
|  in pipelines: 20(GETNEXT)
|
F03:PLAN FRAGMENT [HASH(c_last_name,c_first_name,d_date)] hosts=3 instances=3
Per-Host Resources: mem-estimate=169.06MB mem-reservation=85.00MB thread-reservation=1
20:AGGREGATE
|  output: count(*)
|  mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=16 row-size=8B cardinality=1
|  in pipelines: 20(GETNEXT), 24(OPEN)
|
19:HASH JOIN [LEFT ANTI JOIN, PARTITIONED]
|  hash predicates: c_first_name IS NOT DISTINCT FROM c_first_name, c_last_name IS NOT DISTINCT FROM c_last_name, d_date IS NOT DISTINCT FROM d_date
|  mem-estimate=17.00MB mem-reservation=17.00MB spill-buffer=1.00MB thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 24(GETNEXT), 33(OPEN)
|
|--34:EXCHANGE [HASH(c_last_name,c_first_name,d_date)]
|  |  mem-estimate=10.12MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=13 row-size=58B cardinality=719.38K
|  |  in pipelines: 33(GETNEXT)
|  |
|  F11:PLAN FRAGMENT [HASH(c_last_name,c_first_name,d_date)] hosts=2 instances=2
|  Per-Host Resources: mem-estimate=44.12MB mem-reservation=34.00MB thread-reservation=1
|  33:AGGREGATE [FINALIZE]
|  |  group by: c_last_name, c_first_name, d_date
|  |  mem-estimate=34.00MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=13 row-size=58B cardinality=719.38K
|  |  in pipelines: 33(GETNEXT), 12(OPEN)
|  |
|  32:EXCHANGE [HASH(c_last_name,c_first_name,d_date)]
|  |  mem-estimate=10.12MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=13 row-size=58B cardinality=719.38K
|  |  in pipelines: 12(GETNEXT)
|  |
|  F08:PLAN FRAGMENT [RANDOM] hosts=2 instances=2
|  Per-Host Resources: mem-estimate=110.78MB mem-reservation=46.69MB thread-reservation=2 runtime-filters-memory=2.00MB
|  17:AGGREGATE [STREAMING]
|  |  group by: c_last_name, c_first_name, d_date
|  |  mem-estimate=34.00MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=13 row-size=58B cardinality=719.38K
|  |  in pipelines: 12(GETNEXT)
|  |
|  16:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: web_sales.ws_bill_customer_sk = customer.c_customer_sk
|  |  fk/pk conjuncts: web_sales.ws_bill_customer_sk = customer.c_customer_sk
|  |  runtime filters: RF008[bloom] <- customer.c_customer_sk
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=10,11,12 row-size=78B cardinality=719.38K
|  |  in pipelines: 12(GETNEXT), 14(OPEN)
|  |
|  |--31:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=3.85MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=12 row-size=40B cardinality=100.00K
|  |  |  in pipelines: 14(GETNEXT)
|  |  |
|  |  F10:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=48.00MB mem-reservation=1.00MB thread-reservation=2
|  |  14: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=48.00MB mem-reservation=1.00MB thread-reservation=1
|  |     tuple-ids=12 row-size=40B cardinality=100.00K
|  |     in pipelines: 14(GETNEXT)
|  |
|  15:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: web_sales.ws_sold_date_sk = date_dim.d_date_sk
|  |  fk/pk conjuncts: web_sales.ws_sold_date_sk = date_dim.d_date_sk
|  |  runtime filters: RF010[bloom] <- date_dim.d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=10,11 row-size=38B cardinality=719.38K
|  |  in pipelines: 12(GETNEXT), 13(OPEN)
|  |
|  |--30:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=248.01KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=11 row-size=30B cardinality=7.30K
|  |  |  in pipelines: 13(GETNEXT)
|  |  |
|  |  F09:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=2
|  |  13:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 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: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     parquet dictionary predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=11 row-size=30B cardinality=7.30K
|  |     in pipelines: 13(GETNEXT)
|  |
|  12:SCAN HDFS [tpcds_parquet.web_sales, RANDOM]
|     HDFS partitions=1/1 files=2 size=45.09MB
|     runtime filters: RF008[bloom] -> web_sales.ws_bill_customer_sk, RF010[bloom] -> web_sales.ws_sold_date_sk
|     stored statistics:
|       table: rows=719.38K size=45.09MB
|       columns: all
|     extrapolated-rows=disabled max-scan-range-rows=644.77K
|     mem-estimate=64.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=10 row-size=8B cardinality=719.38K
|     in pipelines: 12(GETNEXT)
|
18:HASH JOIN [LEFT ANTI JOIN, PARTITIONED]
|  hash predicates: c_first_name IS NOT DISTINCT FROM c_first_name, c_last_name IS NOT DISTINCT FROM c_last_name, d_date IS NOT DISTINCT FROM d_date
|  mem-estimate=34.00MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 24(GETNEXT), 28(OPEN)
|
|--29:EXCHANGE [HASH(c_last_name,c_first_name,d_date)]
|  |  mem-estimate=10.18MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=8 row-size=58B cardinality=1.44M
|  |  in pipelines: 28(GETNEXT)
|  |
|  F07:PLAN FRAGMENT [HASH(c_last_name,c_first_name,d_date)] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=54.01MB mem-reservation=34.00MB thread-reservation=1
|  28:AGGREGATE [FINALIZE]
|  |  group by: c_last_name, c_first_name, d_date
|  |  mem-estimate=43.83MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=8 row-size=58B cardinality=1.44M
|  |  in pipelines: 28(GETNEXT), 06(OPEN)
|  |
|  27:EXCHANGE [HASH(c_last_name,c_first_name,d_date)]
|  |  mem-estimate=10.18MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=8 row-size=58B cardinality=1.44M
|  |  in pipelines: 06(GETNEXT)
|  |
|  F04:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
|  Per-Host Resources: mem-estimate=152.61MB mem-reservation=46.69MB thread-reservation=2 runtime-filters-memory=2.00MB
|  11:AGGREGATE [STREAMING]
|  |  group by: c_last_name, c_first_name, d_date
|  |  mem-estimate=43.83MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  |  tuple-ids=8 row-size=58B cardinality=1.44M
|  |  in pipelines: 06(GETNEXT)
|  |
|  10:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: catalog_sales.cs_bill_customer_sk = customer.c_customer_sk
|  |  fk/pk conjuncts: catalog_sales.cs_bill_customer_sk = customer.c_customer_sk
|  |  runtime filters: RF004[bloom] <- customer.c_customer_sk
|  |  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  |  tuple-ids=5,6,7 row-size=78B cardinality=1.44M
|  |  in pipelines: 06(GETNEXT), 08(OPEN)
|  |
|  |--26:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=3.85MB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=7 row-size=40B cardinality=100.00K
|  |  |  in pipelines: 08(GETNEXT)
|  |  |
|  |  F06:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=48.00MB mem-reservation=1.00MB thread-reservation=2
|  |  08: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=48.00MB mem-reservation=1.00MB thread-reservation=1
|  |     tuple-ids=7 row-size=40B cardinality=100.00K
|  |     in pipelines: 08(GETNEXT)
|  |
|  09:HASH JOIN [INNER JOIN, BROADCAST]
|  |  hash predicates: catalog_sales.cs_sold_date_sk = date_dim.d_date_sk
|  |  fk/pk conjuncts: catalog_sales.cs_sold_date_sk = date_dim.d_date_sk
|  |  runtime filters: RF006[bloom] <- date_dim.d_date_sk
|  |  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  |  tuple-ids=5,6 row-size=38B cardinality=1.44M
|  |  in pipelines: 06(GETNEXT), 07(OPEN)
|  |
|  |--25:EXCHANGE [BROADCAST]
|  |  |  mem-estimate=248.01KB mem-reservation=0B thread-reservation=0
|  |  |  tuple-ids=6 row-size=30B cardinality=7.30K
|  |  |  in pipelines: 07(GETNEXT)
|  |  |
|  |  F05:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  |  Per-Host Resources: mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=2
|  |  07:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|  |     HDFS partitions=1/1 files=1 size=2.15MB
|  |     predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 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: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     parquet dictionary predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|  |     mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1
|  |     tuple-ids=6 row-size=30B cardinality=7.30K
|  |     in pipelines: 07(GETNEXT)
|  |
|  06:SCAN HDFS [tpcds_parquet.catalog_sales, RANDOM]
|     HDFS partitions=1/1 files=3 size=96.62MB
|     runtime filters: RF004[bloom] -> catalog_sales.cs_bill_customer_sk, RF006[bloom] -> catalog_sales.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=96.00MB mem-reservation=4.00MB thread-reservation=1
|     tuple-ids=5 row-size=8B cardinality=1.44M
|     in pipelines: 06(GETNEXT)
|
24:AGGREGATE [FINALIZE]
|  group by: c_last_name, c_first_name, d_date
|  mem-estimate=87.57MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 24(GETNEXT), 00(OPEN)
|
23:EXCHANGE [HASH(c_last_name,c_first_name,d_date)]
|  mem-estimate=10.18MB mem-reservation=0B thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 00(GETNEXT)
|
F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
Per-Host Resources: mem-estimate=116.36MB mem-reservation=43.19MB thread-reservation=2 runtime-filters-memory=2.00MB
05:AGGREGATE [STREAMING]
|  group by: c_last_name, c_first_name, d_date
|  mem-estimate=87.57MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0
|  tuple-ids=3 row-size=58B cardinality=2.88M
|  in pipelines: 00(GETNEXT)
|
04:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: store_sales.ss_customer_sk = customer.c_customer_sk
|  fk/pk conjuncts: store_sales.ss_customer_sk = customer.c_customer_sk
|  runtime filters: RF000[bloom] <- customer.c_customer_sk
|  mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0
|  tuple-ids=0,1,2 row-size=78B cardinality=2.88M
|  in pipelines: 00(GETNEXT), 02(OPEN)
|
|--22:EXCHANGE [BROADCAST]
|  |  mem-estimate=3.85MB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=2 row-size=40B cardinality=100.00K
|  |  in pipelines: 02(GETNEXT)
|  |
|  F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=48.00MB mem-reservation=1.00MB thread-reservation=2
|  02: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=48.00MB mem-reservation=1.00MB thread-reservation=1
|     tuple-ids=2 row-size=40B cardinality=100.00K
|     in pipelines: 02(GETNEXT)
|
03:HASH JOIN [INNER JOIN, BROADCAST]
|  hash predicates: store_sales.ss_sold_date_sk = date_dim.d_date_sk
|  fk/pk conjuncts: store_sales.ss_sold_date_sk = date_dim.d_date_sk
|  runtime filters: RF002[bloom] <- date_dim.d_date_sk
|  mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
|  tuple-ids=0,1 row-size=38B cardinality=2.88M
|  in pipelines: 00(GETNEXT), 01(OPEN)
|
|--21:EXCHANGE [BROADCAST]
|  |  mem-estimate=248.01KB mem-reservation=0B thread-reservation=0
|  |  tuple-ids=1 row-size=30B cardinality=7.30K
|  |  in pipelines: 01(GETNEXT)
|  |
|  F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
|  Per-Host Resources: mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=2
|  01:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
|     HDFS partitions=1/1 files=1 size=2.15MB
|     predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 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: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|     parquet dictionary predicates: d_month_seq <= CAST(1211 AS INT), d_month_seq >= CAST(1200 AS INT)
|     mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1
|     tuple-ids=1 row-size=30B cardinality=7.30K
|     in pipelines: 01(GETNEXT)
|
00:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
   HDFS partitions=1824/1824 files=1824 size=200.95MB
   runtime filters: RF000[bloom] -> store_sales.ss_customer_sk, RF002[bloom] -> store_sales.ss_sold_date_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=512.00KB thread-reservation=1
   tuple-ids=0 row-size=8B cardinality=2.88M
   in pipelines: 00(GETNEXT)
====