blob: ffb99b82c25144435db292d990cf5424a9ece0c2 [file] [log] [blame]
# TPCDS-Q61
SELECT promotions,
total,
cast(promotions AS decimal(15,4))/cast(total AS decimal(15,4))*100
FROM
(SELECT sum(ss_ext_sales_price) promotions
FROM store_sales,
store,
promotion,
date_dim,
customer,
customer_address,
item
WHERE ss_sold_date_sk = d_date_sk
AND ss_store_sk = s_store_sk
AND ss_promo_sk = p_promo_sk
AND ss_customer_sk= c_customer_sk
AND ca_address_sk = c_current_addr_sk
AND ss_item_sk = i_item_sk
AND ca_gmt_offset = -5
AND i_category = 'Jewelry'
AND (p_channel_dmail = 'Y'
OR p_channel_email = 'Y'
OR p_channel_tv = 'Y')
AND s_gmt_offset = -5
AND d_year = 1998
AND d_moy = 11) promotional_sales,
(SELECT sum(ss_ext_sales_price) total
FROM store_sales,
store,
date_dim,
customer,
customer_address,
item
WHERE ss_sold_date_sk = d_date_sk
AND ss_store_sk = s_store_sk
AND ss_customer_sk= c_customer_sk
AND ca_address_sk = c_current_addr_sk
AND ss_item_sk = i_item_sk
AND ca_gmt_offset = -5
AND i_category = 'Jewelry'
AND s_gmt_offset = -5
AND d_year = 1998
AND d_moy = 11) all_sales
ORDER BY promotions,
total
LIMIT 100;
---- PLAN
Max Per-Host Resource Reservation: Memory=39.38MB Threads=14
Per-Host Resource Estimates: Memory=591MB
F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
| Per-Host Resources: mem-estimate=591.31MB mem-reservation=39.38MB thread-reservation=14 runtime-filters-memory=10.00MB
PLAN-ROOT SINK
| output exprs: promotions, total, CAST(promotions AS DECIMAL(15,4)) / CAST(total AS DECIMAL(15,4)) * CAST(100 AS DECIMAL(3,0))
| mem-estimate=0B mem-reservation=0B thread-reservation=0
|
27:TOP-N [LIMIT=100]
| order by: promotions ASC, total ASC
| mem-estimate=32B mem-reservation=0B thread-reservation=0
| tuple-ids=17 row-size=32B cardinality=1
| in pipelines: 27(GETNEXT), 13(OPEN)
|
26:NESTED LOOP JOIN [CROSS JOIN]
| mem-estimate=16B mem-reservation=0B thread-reservation=0
| tuple-ids=7,15 row-size=32B cardinality=1
| in pipelines: 13(GETNEXT), 25(OPEN)
|
|--25:AGGREGATE [FINALIZE]
| | output: sum(ss_ext_sales_price)
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 25(GETNEXT), 14(OPEN)
| |
| 24:HASH JOIN [INNER JOIN]
| | hash predicates: c_current_addr_sk = ca_address_sk
| | fk/pk conjuncts: c_current_addr_sk = ca_address_sk
| | runtime filters: RF012[bloom] <- ca_address_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10,12,13 row-size=86B cardinality=3.30K
| | in pipelines: 14(GETNEXT), 18(OPEN)
| |
| |--18:SCAN HDFS [tpcds_parquet.customer_address]
| | HDFS partitions=1/1 files=1 size=1.16MB
| | predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | stored statistics:
| | table: rows=50.00K size=1.16MB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=50.00K
| | parquet statistics predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | parquet dictionary predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| | tuple-ids=13 row-size=8B cardinality=8.33K
| | in pipelines: 18(GETNEXT)
| |
| 23:HASH JOIN [INNER JOIN]
| | hash predicates: ss_customer_sk = c_customer_sk
| | fk/pk conjuncts: ss_customer_sk = c_customer_sk
| | runtime filters: RF014[bloom] <- c_customer_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10,12 row-size=78B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 17(OPEN)
| |
| |--17:SCAN HDFS [tpcds_parquet.customer]
| | HDFS partitions=1/1 files=1 size=5.49MB
| | runtime filters: RF012[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=32.00MB mem-reservation=1.00MB thread-reservation=1
| | tuple-ids=12 row-size=8B cardinality=100.00K
| | in pipelines: 17(GETNEXT)
| |
| 22:HASH JOIN [INNER JOIN]
| | hash predicates: ss_store_sk = s_store_sk
| | fk/pk conjuncts: ss_store_sk = s_store_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10 row-size=70B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 15(OPEN)
| |
| |--15:SCAN HDFS [tpcds_parquet.store]
| | HDFS partitions=1/1 files=1 size=9.93KB
| | predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | stored statistics:
| | table: rows=12 size=9.93KB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=12
| | parquet statistics predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | parquet dictionary predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | mem-estimate=32.00MB mem-reservation=16.00KB thread-reservation=1
| | tuple-ids=10 row-size=8B cardinality=12
| | in pipelines: 15(GETNEXT)
| |
| 21:HASH JOIN [INNER JOIN]
| | hash predicates: ss_item_sk = i_item_sk
| | fk/pk conjuncts: ss_item_sk = i_item_sk
| | runtime filters: RF018[bloom] <- i_item_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14 row-size=62B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 19(OPEN)
| |
| |--19:SCAN HDFS [tpcds_parquet.item]
| | HDFS partitions=1/1 files=1 size=1.73MB
| | predicates: i_category = 'Jewelry'
| | stored statistics:
| | table: rows=18.00K size=1.73MB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=18.00K
| | parquet statistics predicates: i_category = 'Jewelry'
| | parquet dictionary predicates: i_category = 'Jewelry'
| | mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| | tuple-ids=14 row-size=26B cardinality=1.80K
| | in pipelines: 19(GETNEXT)
| |
| 20:HASH JOIN [INNER JOIN]
| | hash predicates: ss_sold_date_sk = d_date_sk
| | fk/pk conjuncts: ss_sold_date_sk = d_date_sk
| | runtime filters: RF020[bloom] <- d_date_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11 row-size=36B cardinality=170.55K
| | in pipelines: 14(GETNEXT), 16(OPEN)
| |
| |--16:SCAN HDFS [tpcds_parquet.date_dim]
| | HDFS partitions=1/1 files=1 size=2.15MB
| | predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 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_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| | parquet dictionary predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| | mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
| | tuple-ids=11 row-size=12B cardinality=108
| | in pipelines: 16(GETNEXT)
| |
| 14:SCAN HDFS [tpcds_parquet.store_sales]
| HDFS partitions=1824/1824 files=1824 size=200.95MB
| runtime filters: RF020[bloom] -> ss_sold_date_sk, RF018[bloom] -> ss_item_sk, RF014[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=64.00MB mem-reservation=2.00MB thread-reservation=1
| tuple-ids=9 row-size=24B cardinality=2.88M
| in pipelines: 14(GETNEXT)
|
13:AGGREGATE [FINALIZE]
| output: sum(ss_ext_sales_price)
| mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| tuple-ids=7 row-size=16B cardinality=1
| in pipelines: 13(GETNEXT), 00(OPEN)
|
12:HASH JOIN [INNER JOIN]
| hash predicates: c_current_addr_sk = ca_address_sk
| fk/pk conjuncts: c_current_addr_sk = ca_address_sk
| runtime filters: RF000[bloom] <- ca_address_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1,4,5 row-size=133B cardinality=3.28K
| in pipelines: 00(GETNEXT), 05(OPEN)
|
|--05:SCAN HDFS [tpcds_parquet.customer_address]
| HDFS partitions=1/1 files=1 size=1.16MB
| predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| stored statistics:
| table: rows=50.00K size=1.16MB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=50.00K
| parquet statistics predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| parquet dictionary predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| tuple-ids=5 row-size=8B cardinality=8.33K
| in pipelines: 05(GETNEXT)
|
11:HASH JOIN [INNER JOIN]
| hash predicates: ss_customer_sk = c_customer_sk
| fk/pk conjuncts: ss_customer_sk = c_customer_sk
| runtime filters: RF002[bloom] <- c_customer_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1,4 row-size=125B cardinality=16.94K
| in pipelines: 00(GETNEXT), 04(OPEN)
|
|--04:SCAN HDFS [tpcds_parquet.customer]
| 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=32.00MB mem-reservation=1.00MB thread-reservation=1
| tuple-ids=4 row-size=8B cardinality=100.00K
| in pipelines: 04(GETNEXT)
|
10:HASH JOIN [INNER JOIN]
| hash predicates: ss_store_sk = s_store_sk
| fk/pk conjuncts: ss_store_sk = s_store_sk
| runtime filters: RF004[bloom] <- s_store_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1 row-size=117B cardinality=16.94K
| in pipelines: 00(GETNEXT), 01(OPEN)
|
|--01:SCAN HDFS [tpcds_parquet.store]
| HDFS partitions=1/1 files=1 size=9.93KB
| predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| stored statistics:
| table: rows=12 size=9.93KB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=12
| parquet statistics predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| parquet dictionary predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| mem-estimate=32.00MB mem-reservation=16.00KB thread-reservation=1
| tuple-ids=1 row-size=8B cardinality=12
| in pipelines: 01(GETNEXT)
|
09:HASH JOIN [INNER JOIN]
| hash predicates: ss_promo_sk = p_promo_sk
| fk/pk conjuncts: ss_promo_sk = p_promo_sk
| runtime filters: RF006[bloom] <- p_promo_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2 row-size=109B cardinality=16.94K
| in pipelines: 00(GETNEXT), 02(OPEN)
|
|--02:SCAN HDFS [tpcds_parquet.promotion]
| HDFS partitions=1/1 files=1 size=23.30KB
| predicates: (p_channel_dmail = 'Y' OR p_channel_email = 'Y' OR p_channel_tv = 'Y')
| stored statistics:
| table: rows=300 size=23.30KB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=300
| mem-estimate=64.00MB mem-reservation=32.00KB thread-reservation=1
| tuple-ids=2 row-size=43B cardinality=300
| in pipelines: 02(GETNEXT)
|
08:HASH JOIN [INNER JOIN]
| hash predicates: ss_item_sk = i_item_sk
| fk/pk conjuncts: ss_item_sk = i_item_sk
| runtime filters: RF008[bloom] <- i_item_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6 row-size=66B cardinality=17.06K
| in pipelines: 00(GETNEXT), 06(OPEN)
|
|--06:SCAN HDFS [tpcds_parquet.item]
| HDFS partitions=1/1 files=1 size=1.73MB
| predicates: i_category = 'Jewelry'
| stored statistics:
| table: rows=18.00K size=1.73MB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=18.00K
| parquet statistics predicates: i_category = 'Jewelry'
| parquet dictionary predicates: i_category = 'Jewelry'
| mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| tuple-ids=6 row-size=26B cardinality=1.80K
| in pipelines: 06(GETNEXT)
|
07:HASH JOIN [INNER JOIN]
| hash predicates: ss_sold_date_sk = d_date_sk
| fk/pk conjuncts: ss_sold_date_sk = d_date_sk
| runtime filters: RF010[bloom] <- d_date_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3 row-size=40B cardinality=170.55K
| in pipelines: 00(GETNEXT), 03(OPEN)
|
|--03:SCAN HDFS [tpcds_parquet.date_dim]
| HDFS partitions=1/1 files=1 size=2.15MB
| predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 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_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| parquet dictionary predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
| tuple-ids=3 row-size=12B cardinality=108
| in pipelines: 03(GETNEXT)
|
00:SCAN HDFS [tpcds_parquet.store_sales]
HDFS partitions=1824/1824 files=1824 size=200.95MB
runtime filters: RF010[bloom] -> ss_sold_date_sk, RF008[bloom] -> ss_item_sk, RF006[bloom] -> ss_promo_sk, RF002[bloom] -> ss_customer_sk, RF004[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=2.00MB thread-reservation=1
tuple-ids=0 row-size=28B cardinality=2.88M
in pipelines: 00(GETNEXT)
---- DISTRIBUTEDPLAN
Max Per-Host Resource Reservation: Memory=43.38MB Threads=30
Per-Host Resource Estimates: Memory=637MB
F08:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
| Per-Host Resources: mem-estimate=10.03MB mem-reservation=0B thread-reservation=1
PLAN-ROOT SINK
| output exprs: promotions, total, CAST(promotions AS DECIMAL(15,4)) / CAST(total AS DECIMAL(15,4)) * CAST(100 AS DECIMAL(3,0))
| mem-estimate=0B mem-reservation=0B thread-reservation=0
|
27:TOP-N [LIMIT=100]
| order by: promotions ASC, total ASC
| mem-estimate=32B mem-reservation=0B thread-reservation=0
| tuple-ids=17 row-size=32B cardinality=1
| in pipelines: 27(GETNEXT), 36(OPEN)
|
26:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
| mem-estimate=16B mem-reservation=0B thread-reservation=0
| tuple-ids=7,15 row-size=32B cardinality=1
| in pipelines: 36(GETNEXT), 44(OPEN)
|
|--45:EXCHANGE [UNPARTITIONED]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 44(GETNEXT)
| |
| F16:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
| Per-Host Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1
| 44:AGGREGATE [FINALIZE]
| | output: sum:merge(ss_ext_sales_price)
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 44(GETNEXT), 25(OPEN)
| |
| 43:EXCHANGE [UNPARTITIONED]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 25(GETNEXT)
| |
| F14:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=3
| Per-Host Resources: mem-estimate=16.51MB mem-reservation=5.88MB thread-reservation=1 runtime-filters-memory=2.00MB
| 25:AGGREGATE
| | output: sum(ss_ext_sales_price)
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 25(GETNEXT), 14(OPEN)
| |
| 24:HASH JOIN [INNER JOIN, BROADCAST]
| | hash predicates: c_current_addr_sk = ca_address_sk
| | fk/pk conjuncts: c_current_addr_sk = ca_address_sk
| | runtime filters: RF012[bloom] <- ca_address_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10,12,13 row-size=86B cardinality=3.30K
| | in pipelines: 14(GETNEXT), 18(OPEN)
| |
| |--42:EXCHANGE [BROADCAST]
| | | mem-estimate=77.10KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=13 row-size=8B cardinality=8.33K
| | | in pipelines: 18(GETNEXT)
| | |
| | F15:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Host Resources: mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=2
| | 18:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
| | HDFS partitions=1/1 files=1 size=1.16MB
| | predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | stored statistics:
| | table: rows=50.00K size=1.16MB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=50.00K
| | parquet statistics predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | parquet dictionary predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| | tuple-ids=13 row-size=8B cardinality=8.33K
| | in pipelines: 18(GETNEXT)
| |
| 23:HASH JOIN [INNER JOIN, PARTITIONED]
| | hash predicates: ss_customer_sk = c_customer_sk
| | fk/pk conjuncts: ss_customer_sk = c_customer_sk
| | runtime filters: RF014[bloom] <- c_customer_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10,12 row-size=78B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 17(OPEN)
| |
| |--41:EXCHANGE [HASH(c_customer_sk)]
| | | mem-estimate=793.25KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=12 row-size=8B cardinality=100.00K
| | | in pipelines: 17(GETNEXT)
| | |
| | F13:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Host Resources: mem-estimate=33.00MB mem-reservation=2.00MB thread-reservation=2 runtime-filters-memory=1.00MB
| | 17:SCAN HDFS [tpcds_parquet.customer, RANDOM]
| | HDFS partitions=1/1 files=1 size=5.49MB
| | runtime filters: RF012[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=32.00MB mem-reservation=1.00MB thread-reservation=1
| | tuple-ids=12 row-size=8B cardinality=100.00K
| | in pipelines: 17(GETNEXT)
| |
| 40:EXCHANGE [HASH(ss_customer_sk)]
| | mem-estimate=645.75KB mem-reservation=0B thread-reservation=0
| | tuple-ids=9,11,14,10 row-size=70B cardinality=17.06K
| | in pipelines: 14(GETNEXT)
| |
| F09:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
| Per-Host Resources: mem-estimate=72.92MB mem-reservation=10.81MB thread-reservation=2 runtime-filters-memory=3.00MB
| 22:HASH JOIN [INNER JOIN, BROADCAST]
| | hash predicates: ss_store_sk = s_store_sk
| | fk/pk conjuncts: ss_store_sk = s_store_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10 row-size=70B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 15(OPEN)
| |
| |--39:EXCHANGE [BROADCAST]
| | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=10 row-size=8B cardinality=12
| | | in pipelines: 15(GETNEXT)
| | |
| | F12:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Host Resources: mem-estimate=32.00MB mem-reservation=16.00KB thread-reservation=2
| | 15:SCAN HDFS [tpcds_parquet.store, RANDOM]
| | HDFS partitions=1/1 files=1 size=9.93KB
| | predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | stored statistics:
| | table: rows=12 size=9.93KB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=12
| | parquet statistics predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | parquet dictionary predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | mem-estimate=32.00MB mem-reservation=16.00KB thread-reservation=1
| | tuple-ids=10 row-size=8B cardinality=12
| | in pipelines: 15(GETNEXT)
| |
| 21:HASH JOIN [INNER JOIN, BROADCAST]
| | hash predicates: ss_item_sk = i_item_sk
| | fk/pk conjuncts: ss_item_sk = i_item_sk
| | runtime filters: RF018[bloom] <- i_item_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14 row-size=62B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 19(OPEN)
| |
| |--38:EXCHANGE [BROADCAST]
| | | mem-estimate=75.41KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=14 row-size=26B cardinality=1.80K
| | | in pipelines: 19(GETNEXT)
| | |
| | F11:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Host Resources: mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=2
| | 19:SCAN HDFS [tpcds_parquet.item, RANDOM]
| | HDFS partitions=1/1 files=1 size=1.73MB
| | predicates: i_category = 'Jewelry'
| | stored statistics:
| | table: rows=18.00K size=1.73MB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=18.00K
| | parquet statistics predicates: i_category = 'Jewelry'
| | parquet dictionary predicates: i_category = 'Jewelry'
| | mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| | tuple-ids=14 row-size=26B cardinality=1.80K
| | in pipelines: 19(GETNEXT)
| |
| 20:HASH JOIN [INNER JOIN, BROADCAST]
| | hash predicates: ss_sold_date_sk = d_date_sk
| | fk/pk conjuncts: ss_sold_date_sk = d_date_sk
| | runtime filters: RF020[bloom] <- d_date_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11 row-size=36B cardinality=170.55K
| | in pipelines: 14(GETNEXT), 16(OPEN)
| |
| |--37:EXCHANGE [BROADCAST]
| | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=11 row-size=12B cardinality=108
| | | in pipelines: 16(GETNEXT)
| | |
| | F10:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Host Resources: mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=2
| | 16:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
| | HDFS partitions=1/1 files=1 size=2.15MB
| | predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 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_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| | parquet dictionary predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| | mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
| | tuple-ids=11 row-size=12B cardinality=108
| | in pipelines: 16(GETNEXT)
| |
| 14:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
| HDFS partitions=1824/1824 files=1824 size=200.95MB
| runtime filters: RF020[bloom] -> ss_sold_date_sk, RF018[bloom] -> ss_item_sk, RF014[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=64.00MB mem-reservation=2.00MB thread-reservation=1
| tuple-ids=9 row-size=24B cardinality=2.88M
| in pipelines: 14(GETNEXT)
|
36:AGGREGATE [FINALIZE]
| output: sum:merge(ss_ext_sales_price)
| mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| tuple-ids=7 row-size=16B cardinality=1
| in pipelines: 36(GETNEXT), 13(OPEN)
|
35:EXCHANGE [UNPARTITIONED]
| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| tuple-ids=7 row-size=16B cardinality=1
| in pipelines: 13(GETNEXT)
|
F06:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=3
Per-Host Resources: mem-estimate=16.91MB mem-reservation=5.88MB thread-reservation=1 runtime-filters-memory=2.00MB
13:AGGREGATE
| output: sum(ss_ext_sales_price)
| mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| tuple-ids=7 row-size=16B cardinality=1
| in pipelines: 13(GETNEXT), 00(OPEN)
|
12:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: c_current_addr_sk = ca_address_sk
| fk/pk conjuncts: c_current_addr_sk = ca_address_sk
| runtime filters: RF000[bloom] <- ca_address_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1,4,5 row-size=133B cardinality=3.28K
| in pipelines: 00(GETNEXT), 05(OPEN)
|
|--34:EXCHANGE [BROADCAST]
| | mem-estimate=77.10KB mem-reservation=0B thread-reservation=0
| | tuple-ids=5 row-size=8B cardinality=8.33K
| | in pipelines: 05(GETNEXT)
| |
| F07:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Host Resources: mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=2
| 05:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
| HDFS partitions=1/1 files=1 size=1.16MB
| predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| stored statistics:
| table: rows=50.00K size=1.16MB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=50.00K
| parquet statistics predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| parquet dictionary predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| tuple-ids=5 row-size=8B cardinality=8.33K
| in pipelines: 05(GETNEXT)
|
11:HASH JOIN [INNER JOIN, PARTITIONED]
| hash predicates: ss_customer_sk = c_customer_sk
| fk/pk conjuncts: ss_customer_sk = c_customer_sk
| runtime filters: RF002[bloom] <- c_customer_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1,4 row-size=125B cardinality=16.94K
| in pipelines: 00(GETNEXT), 04(OPEN)
|
|--33:EXCHANGE [HASH(c_customer_sk)]
| | mem-estimate=793.25KB mem-reservation=0B thread-reservation=0
| | tuple-ids=4 row-size=8B cardinality=100.00K
| | in pipelines: 04(GETNEXT)
| |
| F05:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Host Resources: mem-estimate=33.00MB mem-reservation=2.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=32.00MB mem-reservation=1.00MB thread-reservation=1
| tuple-ids=4 row-size=8B cardinality=100.00K
| in pipelines: 04(GETNEXT)
|
32:EXCHANGE [HASH(ss_customer_sk)]
| mem-estimate=1.03MB mem-reservation=0B thread-reservation=0
| tuple-ids=0,3,6,2,1 row-size=117B cardinality=16.94K
| in pipelines: 00(GETNEXT)
|
F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
Per-Host Resources: mem-estimate=92.88MB mem-reservation=14.75MB thread-reservation=2 runtime-filters-memory=5.00MB
10:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: ss_store_sk = s_store_sk
| fk/pk conjuncts: ss_store_sk = s_store_sk
| runtime filters: RF004[bloom] <- s_store_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1 row-size=117B cardinality=16.94K
| in pipelines: 00(GETNEXT), 01(OPEN)
|
|--31:EXCHANGE [BROADCAST]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=1 row-size=8B cardinality=12
| | in pipelines: 01(GETNEXT)
| |
| F04:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Host Resources: mem-estimate=32.00MB mem-reservation=16.00KB thread-reservation=2
| 01:SCAN HDFS [tpcds_parquet.store, RANDOM]
| HDFS partitions=1/1 files=1 size=9.93KB
| predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| stored statistics:
| table: rows=12 size=9.93KB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=12
| parquet statistics predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| parquet dictionary predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| mem-estimate=32.00MB mem-reservation=16.00KB thread-reservation=1
| tuple-ids=1 row-size=8B cardinality=12
| in pipelines: 01(GETNEXT)
|
09:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: ss_promo_sk = p_promo_sk
| fk/pk conjuncts: ss_promo_sk = p_promo_sk
| runtime filters: RF006[bloom] <- p_promo_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2 row-size=109B cardinality=16.94K
| in pipelines: 00(GETNEXT), 02(OPEN)
|
|--30:EXCHANGE [BROADCAST]
| | mem-estimate=26.37KB mem-reservation=0B thread-reservation=0
| | tuple-ids=2 row-size=43B cardinality=300
| | in pipelines: 02(GETNEXT)
| |
| F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Host Resources: mem-estimate=64.00MB mem-reservation=32.00KB thread-reservation=2
| 02:SCAN HDFS [tpcds_parquet.promotion, RANDOM]
| HDFS partitions=1/1 files=1 size=23.30KB
| predicates: (p_channel_dmail = 'Y' OR p_channel_email = 'Y' OR p_channel_tv = 'Y')
| stored statistics:
| table: rows=300 size=23.30KB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=300
| mem-estimate=64.00MB mem-reservation=32.00KB thread-reservation=1
| tuple-ids=2 row-size=43B cardinality=300
| in pipelines: 02(GETNEXT)
|
08:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: ss_item_sk = i_item_sk
| fk/pk conjuncts: ss_item_sk = i_item_sk
| runtime filters: RF008[bloom] <- i_item_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6 row-size=66B cardinality=17.06K
| in pipelines: 00(GETNEXT), 06(OPEN)
|
|--29:EXCHANGE [BROADCAST]
| | mem-estimate=75.41KB mem-reservation=0B thread-reservation=0
| | tuple-ids=6 row-size=26B cardinality=1.80K
| | in pipelines: 06(GETNEXT)
| |
| F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Host Resources: mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=2
| 06:SCAN HDFS [tpcds_parquet.item, RANDOM]
| HDFS partitions=1/1 files=1 size=1.73MB
| predicates: i_category = 'Jewelry'
| stored statistics:
| table: rows=18.00K size=1.73MB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=18.00K
| parquet statistics predicates: i_category = 'Jewelry'
| parquet dictionary predicates: i_category = 'Jewelry'
| mem-estimate=32.00MB mem-reservation=256.00KB thread-reservation=1
| tuple-ids=6 row-size=26B cardinality=1.80K
| in pipelines: 06(GETNEXT)
|
07:HASH JOIN [INNER JOIN, BROADCAST]
| hash predicates: ss_sold_date_sk = d_date_sk
| fk/pk conjuncts: ss_sold_date_sk = d_date_sk
| runtime filters: RF010[bloom] <- d_date_sk
| mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3 row-size=40B cardinality=170.55K
| in pipelines: 00(GETNEXT), 03(OPEN)
|
|--28:EXCHANGE [BROADCAST]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=3 row-size=12B cardinality=108
| | in pipelines: 03(GETNEXT)
| |
| F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Host Resources: mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=2
| 03:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
| HDFS partitions=1/1 files=1 size=2.15MB
| predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 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_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| parquet dictionary predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1
| tuple-ids=3 row-size=12B cardinality=108
| in pipelines: 03(GETNEXT)
|
00:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
HDFS partitions=1824/1824 files=1824 size=200.95MB
runtime filters: RF010[bloom] -> ss_sold_date_sk, RF008[bloom] -> ss_item_sk, RF006[bloom] -> ss_promo_sk, RF002[bloom] -> ss_customer_sk, RF004[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=2.00MB thread-reservation=1
tuple-ids=0 row-size=28B cardinality=2.88M
in pipelines: 00(GETNEXT)
---- PARALLELPLANS
Max Per-Host Resource Reservation: Memory=76.69MB Threads=35
Per-Host Resource Estimates: Memory=373MB
F08:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
| Per-Instance Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1
PLAN-ROOT SINK
| output exprs: promotions, total, CAST(promotions AS DECIMAL(15,4)) / CAST(total AS DECIMAL(15,4)) * CAST(100 AS DECIMAL(3,0))
| mem-estimate=0B mem-reservation=0B thread-reservation=0
|
27:TOP-N [LIMIT=100]
| order by: promotions ASC, total ASC
| mem-estimate=32B mem-reservation=0B thread-reservation=0
| tuple-ids=17 row-size=32B cardinality=1
| in pipelines: 27(GETNEXT), 36(OPEN)
|
26:NESTED LOOP JOIN [CROSS JOIN, BROADCAST]
| join table id: 00
| mem-estimate=0B mem-reservation=0B thread-reservation=0
| tuple-ids=7,15 row-size=32B cardinality=1
| in pipelines: 36(GETNEXT), 44(OPEN)
|
|--F17:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
| | 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
| |
| 45:EXCHANGE [UNPARTITIONED]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 44(GETNEXT)
| |
| F16:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1
| Per-Instance Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1
| 44:AGGREGATE [FINALIZE]
| | output: sum:merge(ss_ext_sales_price)
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 44(GETNEXT), 25(OPEN)
| |
| 43:EXCHANGE [UNPARTITIONED]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 25(GETNEXT)
| |
| F14:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=6
| Per-Instance Resources: mem-estimate=10.88MB mem-reservation=0B thread-reservation=1
| 25:AGGREGATE
| | output: sum(ss_ext_sales_price)
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| | tuple-ids=15 row-size=16B cardinality=1
| | in pipelines: 25(GETNEXT), 14(OPEN)
| |
| 24:HASH JOIN [INNER JOIN, BROADCAST]
| | hash-table-id=01
| | hash predicates: c_current_addr_sk = ca_address_sk
| | fk/pk conjuncts: c_current_addr_sk = ca_address_sk
| | mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10,12,13 row-size=86B cardinality=3.30K
| | in pipelines: 14(GETNEXT), 18(OPEN)
| |
| |--F18:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=3
| | | Per-Instance Resources: mem-estimate=4.95MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
| | JOIN BUILD
| | | join-table-id=01 plan-id=02 cohort-id=02
| | | build expressions: ca_address_sk
| | | runtime filters: RF012[bloom] <- ca_address_sk
| | | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| | |
| | 42:EXCHANGE [BROADCAST]
| | | mem-estimate=77.10KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=13 row-size=8B cardinality=8.33K
| | | in pipelines: 18(GETNEXT)
| | |
| | F15:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
| | 18:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
| | HDFS partitions=1/1 files=1 size=1.16MB
| | predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | stored statistics:
| | table: rows=50.00K size=1.16MB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=50.00K
| | parquet statistics predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | parquet dictionary predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
| | tuple-ids=13 row-size=8B cardinality=8.33K
| | in pipelines: 18(GETNEXT)
| |
| 23:HASH JOIN [INNER JOIN, PARTITIONED]
| | 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=64.00KB thread-reservation=0
| | tuple-ids=9,11,14,10,12 row-size=78B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 17(OPEN)
| |
| |--F19:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=6
| | | Per-Instance Resources: mem-estimate=3.71MB mem-reservation=2.94MB thread-reservation=1 runtime-filters-memory=1.00MB
| | JOIN BUILD
| | | join-table-id=02 plan-id=03 cohort-id=02
| | | build expressions: c_customer_sk
| | | runtime filters: RF014[bloom] <- c_customer_sk
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| | |
| | 41:EXCHANGE [HASH(c_customer_sk)]
| | | mem-estimate=793.25KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=12 row-size=8B cardinality=100.00K
| | | in pipelines: 17(GETNEXT)
| | |
| | F13: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=1.00MB thread-reservation=1
| | 17:SCAN HDFS [tpcds_parquet.customer, RANDOM]
| | HDFS partitions=1/1 files=1 size=5.49MB
| | runtime filters: RF012[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=1.00MB thread-reservation=0
| | tuple-ids=12 row-size=8B cardinality=100.00K
| | in pipelines: 17(GETNEXT)
| |
| 40:EXCHANGE [HASH(ss_customer_sk)]
| | mem-estimate=903.43KB mem-reservation=0B thread-reservation=0
| | tuple-ids=9,11,14,10 row-size=70B cardinality=17.06K
| | in pipelines: 14(GETNEXT)
| |
| F09: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=16.00MB mem-reservation=2.00MB thread-reservation=1
| 22:HASH JOIN [INNER JOIN, BROADCAST]
| | hash-table-id=03
| | 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=9,11,14,10 row-size=70B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 15(OPEN)
| |
| |--F20:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
| | | Per-Instance Resources: mem-estimate=3.89MB mem-reservation=3.88MB thread-reservation=1
| | JOIN BUILD
| | | join-table-id=03 plan-id=04 cohort-id=02
| | | build expressions: s_store_sk
| | | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| | |
| | 39:EXCHANGE [BROADCAST]
| | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=10 row-size=8B cardinality=12
| | | in pipelines: 15(GETNEXT)
| | |
| | F12:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Instance Resources: mem-estimate=16.00MB mem-reservation=16.00KB thread-reservation=1
| | 15:SCAN HDFS [tpcds_parquet.store, RANDOM]
| | HDFS partitions=1/1 files=1 size=9.93KB
| | predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | stored statistics:
| | table: rows=12 size=9.93KB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=12
| | parquet statistics predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | parquet dictionary predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| | mem-estimate=16.00MB mem-reservation=16.00KB thread-reservation=0
| | tuple-ids=10 row-size=8B cardinality=12
| | in pipelines: 15(GETNEXT)
| |
| 21:HASH JOIN [INNER JOIN, BROADCAST]
| | hash-table-id=04
| | 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=9,11,14 row-size=62B cardinality=17.06K
| | in pipelines: 14(GETNEXT), 19(OPEN)
| |
| |--F21:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
| | | Per-Instance Resources: mem-estimate=4.95MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
| | JOIN BUILD
| | | join-table-id=04 plan-id=05 cohort-id=02
| | | build expressions: i_item_sk
| | | runtime filters: RF018[bloom] <- i_item_sk
| | | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| | |
| | 38:EXCHANGE [BROADCAST]
| | | mem-estimate=75.41KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=14 row-size=26B cardinality=1.80K
| | | in pipelines: 19(GETNEXT)
| | |
| | F11:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
| | 19:SCAN HDFS [tpcds_parquet.item, RANDOM]
| | HDFS partitions=1/1 files=1 size=1.73MB
| | predicates: i_category = 'Jewelry'
| | stored statistics:
| | table: rows=18.00K size=1.73MB
| | columns: all
| | extrapolated-rows=disabled max-scan-range-rows=18.00K
| | parquet statistics predicates: i_category = 'Jewelry'
| | parquet dictionary predicates: i_category = 'Jewelry'
| | mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
| | tuple-ids=14 row-size=26B cardinality=1.80K
| | in pipelines: 19(GETNEXT)
| |
| 20:HASH JOIN [INNER JOIN, BROADCAST]
| | hash-table-id=05
| | hash predicates: ss_sold_date_sk = d_date_sk
| | fk/pk conjuncts: ss_sold_date_sk = d_date_sk
| | mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
| | tuple-ids=9,11 row-size=36B cardinality=170.55K
| | in pipelines: 14(GETNEXT), 16(OPEN)
| |
| |--F22: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: d_date_sk
| | | runtime filters: RF020[bloom] <- d_date_sk
| | | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| | |
| | 37:EXCHANGE [BROADCAST]
| | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | | tuple-ids=11 row-size=12B cardinality=108
| | | in pipelines: 16(GETNEXT)
| | |
| | F10:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| | Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
| | 16:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
| | HDFS partitions=1/1 files=1 size=2.15MB
| | predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 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_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| | parquet dictionary predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| | mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
| | tuple-ids=11 row-size=12B cardinality=108
| | in pipelines: 16(GETNEXT)
| |
| 14:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
| HDFS partitions=1824/1824 files=1824 size=200.95MB
| runtime filters: RF020[bloom] -> ss_sold_date_sk, RF018[bloom] -> ss_item_sk, RF014[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=2.00MB thread-reservation=0
| tuple-ids=9 row-size=24B cardinality=2.88M
| in pipelines: 14(GETNEXT)
|
36:AGGREGATE [FINALIZE]
| output: sum:merge(ss_ext_sales_price)
| mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| tuple-ids=7 row-size=16B cardinality=1
| in pipelines: 36(GETNEXT), 13(OPEN)
|
35:EXCHANGE [UNPARTITIONED]
| mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| tuple-ids=7 row-size=16B cardinality=1
| in pipelines: 13(GETNEXT)
|
F06:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=6
Per-Instance Resources: mem-estimate=11.43MB mem-reservation=0B thread-reservation=1
13:AGGREGATE
| output: sum(ss_ext_sales_price)
| mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0
| tuple-ids=7 row-size=16B cardinality=1
| in pipelines: 13(GETNEXT), 00(OPEN)
|
12:HASH JOIN [INNER JOIN, BROADCAST]
| hash-table-id=06
| hash predicates: c_current_addr_sk = ca_address_sk
| fk/pk conjuncts: c_current_addr_sk = ca_address_sk
| mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1,4,5 row-size=133B cardinality=3.28K
| in pipelines: 00(GETNEXT), 05(OPEN)
|
|--F23:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=3
| | Per-Instance Resources: mem-estimate=4.95MB mem-reservation=4.88MB thread-reservation=1 runtime-filters-memory=1.00MB
| JOIN BUILD
| | join-table-id=06 plan-id=07 cohort-id=01
| | build expressions: ca_address_sk
| | runtime filters: RF000[bloom] <- ca_address_sk
| | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| |
| 34:EXCHANGE [BROADCAST]
| | mem-estimate=77.10KB mem-reservation=0B thread-reservation=0
| | tuple-ids=5 row-size=8B cardinality=8.33K
| | in pipelines: 05(GETNEXT)
| |
| F07:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
| 05:SCAN HDFS [tpcds_parquet.customer_address, RANDOM]
| HDFS partitions=1/1 files=1 size=1.16MB
| predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| stored statistics:
| table: rows=50.00K size=1.16MB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=50.00K
| parquet statistics predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| parquet dictionary predicates: ca_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
| tuple-ids=5 row-size=8B cardinality=8.33K
| in pipelines: 05(GETNEXT)
|
11: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=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2,1,4 row-size=125B cardinality=16.94K
| in pipelines: 00(GETNEXT), 04(OPEN)
|
|--F24:PLAN FRAGMENT [HASH(ss_customer_sk)] hosts=3 instances=6
| | Per-Instance Resources: mem-estimate=3.71MB mem-reservation=2.94MB 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: RF002[bloom] <- c_customer_sk
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0
| |
| 33:EXCHANGE [HASH(c_customer_sk)]
| | mem-estimate=793.25KB mem-reservation=0B thread-reservation=0
| | tuple-ids=4 row-size=8B 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=1.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=1.00MB thread-reservation=0
| tuple-ids=4 row-size=8B cardinality=100.00K
| in pipelines: 04(GETNEXT)
|
32:EXCHANGE [HASH(ss_customer_sk)]
| mem-estimate=1.43MB mem-reservation=0B thread-reservation=0
| tuple-ids=0,3,6,2,1 row-size=117B cardinality=16.94K
| 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=2.00MB thread-reservation=1
10:HASH JOIN [INNER JOIN, BROADCAST]
| hash-table-id=08
| 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,6,2,1 row-size=117B cardinality=16.94K
| in pipelines: 00(GETNEXT), 01(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=08 plan-id=09 cohort-id=01
| | build expressions: s_store_sk
| | runtime filters: RF004[bloom] <- s_store_sk
| | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| |
| 31:EXCHANGE [BROADCAST]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=1 row-size=8B cardinality=12
| | in pipelines: 01(GETNEXT)
| |
| F04:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Instance Resources: mem-estimate=16.00MB mem-reservation=16.00KB thread-reservation=1
| 01:SCAN HDFS [tpcds_parquet.store, RANDOM]
| HDFS partitions=1/1 files=1 size=9.93KB
| predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| stored statistics:
| table: rows=12 size=9.93KB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=12
| parquet statistics predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| parquet dictionary predicates: s_gmt_offset = CAST(-5 AS DECIMAL(3,0))
| mem-estimate=16.00MB mem-reservation=16.00KB thread-reservation=0
| tuple-ids=1 row-size=8B cardinality=12
| in pipelines: 01(GETNEXT)
|
09:HASH JOIN [INNER JOIN, BROADCAST]
| hash-table-id=09
| hash predicates: ss_promo_sk = p_promo_sk
| fk/pk conjuncts: ss_promo_sk = p_promo_sk
| mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3,6,2 row-size=109B cardinality=16.94K
| in pipelines: 00(GETNEXT), 02(OPEN)
|
|--F26: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=09 plan-id=10 cohort-id=01
| | build expressions: p_promo_sk
| | runtime filters: RF006[bloom] <- p_promo_sk
| | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| |
| 30:EXCHANGE [BROADCAST]
| | mem-estimate=26.37KB mem-reservation=0B thread-reservation=0
| | tuple-ids=2 row-size=43B cardinality=300
| | in pipelines: 02(GETNEXT)
| |
| F03:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Instance Resources: mem-estimate=16.00MB mem-reservation=32.00KB thread-reservation=1
| 02:SCAN HDFS [tpcds_parquet.promotion, RANDOM]
| HDFS partitions=1/1 files=1 size=23.30KB
| predicates: (p_channel_dmail = 'Y' OR p_channel_email = 'Y' OR p_channel_tv = 'Y')
| stored statistics:
| table: rows=300 size=23.30KB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=300
| mem-estimate=16.00MB mem-reservation=32.00KB thread-reservation=0
| tuple-ids=2 row-size=43B cardinality=300
| in pipelines: 02(GETNEXT)
|
08: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,6 row-size=66B cardinality=17.06K
| in pipelines: 00(GETNEXT), 06(OPEN)
|
|--F27:PLAN FRAGMENT [RANDOM] hosts=3 instances=3
| | Per-Instance Resources: mem-estimate=4.95MB 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: RF008[bloom] <- i_item_sk
| | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| |
| 29:EXCHANGE [BROADCAST]
| | mem-estimate=75.41KB mem-reservation=0B thread-reservation=0
| | tuple-ids=6 row-size=26B cardinality=1.80K
| | in pipelines: 06(GETNEXT)
| |
| F02:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Instance Resources: mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=1
| 06:SCAN HDFS [tpcds_parquet.item, RANDOM]
| HDFS partitions=1/1 files=1 size=1.73MB
| predicates: i_category = 'Jewelry'
| stored statistics:
| table: rows=18.00K size=1.73MB
| columns: all
| extrapolated-rows=disabled max-scan-range-rows=18.00K
| parquet statistics predicates: i_category = 'Jewelry'
| parquet dictionary predicates: i_category = 'Jewelry'
| mem-estimate=16.00MB mem-reservation=256.00KB thread-reservation=0
| tuple-ids=6 row-size=26B cardinality=1.80K
| in pipelines: 06(GETNEXT)
|
07:HASH JOIN [INNER JOIN, BROADCAST]
| hash-table-id=11
| hash predicates: ss_sold_date_sk = d_date_sk
| fk/pk conjuncts: ss_sold_date_sk = d_date_sk
| mem-estimate=0B mem-reservation=0B spill-buffer=64.00KB thread-reservation=0
| tuple-ids=0,3 row-size=40B cardinality=170.55K
| in pipelines: 00(GETNEXT), 03(OPEN)
|
|--F28: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=11 plan-id=12 cohort-id=01
| | build expressions: d_date_sk
| | runtime filters: RF010[bloom] <- d_date_sk
| | mem-estimate=3.88MB mem-reservation=3.88MB spill-buffer=64.00KB thread-reservation=0
| |
| 28:EXCHANGE [BROADCAST]
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0
| | tuple-ids=3 row-size=12B cardinality=108
| | in pipelines: 03(GETNEXT)
| |
| F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1
| Per-Instance Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=1
| 03:SCAN HDFS [tpcds_parquet.date_dim, RANDOM]
| HDFS partitions=1/1 files=1 size=2.15MB
| predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 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_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| parquet dictionary predicates: d_year = CAST(1998 AS INT), d_moy = CAST(11 AS INT)
| mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=0
| tuple-ids=3 row-size=12B cardinality=108
| in pipelines: 03(GETNEXT)
|
00:SCAN HDFS [tpcds_parquet.store_sales, RANDOM]
HDFS partitions=1824/1824 files=1824 size=200.95MB
runtime filters: RF010[bloom] -> ss_sold_date_sk, RF008[bloom] -> ss_item_sk, RF006[bloom] -> ss_promo_sk, RF002[bloom] -> ss_customer_sk, RF004[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=16.00MB mem-reservation=2.00MB thread-reservation=0
tuple-ids=0 row-size=28B cardinality=2.88M
in pipelines: 00(GETNEXT)
====