| # TPCDS-Q23-1 First of two queries. |
| with frequent_ss_items as |
| (select substr(i_item_desc,1,30) itemdesc,i_item_sk item_sk,d_date solddate,count(*) cnt |
| from store_sales |
| ,date_dim |
| ,item |
| where ss_sold_date_sk = d_date_sk |
| and ss_item_sk = i_item_sk |
| and d_year in (2000,2000+1,2000+2,2000+3) |
| group by substr(i_item_desc,1,30),i_item_sk,d_date |
| having count(*) >4), |
| max_store_sales as |
| (select max(csales) tpcds_cmax |
| from (select c_customer_sk,sum(ss_quantity*ss_sales_price) csales |
| from store_sales |
| ,customer |
| ,date_dim |
| where ss_customer_sk = c_customer_sk |
| and ss_sold_date_sk = d_date_sk |
| and d_year in (2000,2000+1,2000+2,2000+3) |
| group by c_customer_sk) x), |
| best_ss_customer as |
| (select c_customer_sk,sum(ss_quantity*ss_sales_price) ssales |
| from store_sales |
| ,customer |
| where ss_customer_sk = c_customer_sk |
| group by c_customer_sk |
| having sum(ss_quantity*ss_sales_price) > (50/100.0) * (select |
| * |
| from |
| max_store_sales)) |
| select sum(sales) |
| from (select cs_quantity*cs_list_price sales |
| from catalog_sales |
| ,date_dim |
| where d_year = 2000 |
| and d_moy = 2 |
| and cs_sold_date_sk = d_date_sk |
| and cs_item_sk in (select item_sk from frequent_ss_items) |
| and cs_bill_customer_sk in (select c_customer_sk from best_ss_customer) |
| union all |
| select ws_quantity*ws_list_price sales |
| from web_sales |
| ,date_dim |
| where d_year = 2000 |
| and d_moy = 2 |
| and ws_sold_date_sk = d_date_sk |
| and ws_item_sk in (select item_sk from frequent_ss_items) |
| and ws_bill_customer_sk in (select c_customer_sk from best_ss_customer)) y |
| limit 100; |
| ---- PLAN |
| Max Per-Host Resource Reservation: Memory=75.19MB Threads=11 |
| Per-Host Resource Estimates: Memory=622MB |
| F00:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 |
| | Per-Host Resources: mem-estimate=621.94MB mem-reservation=75.19MB thread-reservation=11 runtime-filters-memory=10.00MB |
| PLAN-ROOT SINK |
| | output exprs: sum(sales) |
| | mem-estimate=0B mem-reservation=0B thread-reservation=0 |
| | |
| 49:AGGREGATE [FINALIZE] |
| | output: sum(sales) |
| | limit: 100 |
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | tuple-ids=46 row-size=16B cardinality=1 |
| | in pipelines: 49(GETNEXT), 12(OPEN), 36(OPEN) |
| | |
| 00:UNION |
| | mem-estimate=0B mem-reservation=0B thread-reservation=0 |
| | tuple-ids=44 row-size=8B cardinality=128.16K |
| | in pipelines: 12(GETNEXT), 36(GETNEXT) |
| | |
| |--48:HASH JOIN [RIGHT SEMI JOIN] |
| | | hash predicates: c_customer_sk = ws_bill_customer_sk |
| | | runtime filters: RF016[bloom] <- ws_bill_customer_sk |
| | | mem-estimate=2.88MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0 |
| | | tuple-ids=22,23 row-size=36B cardinality=42.85K |
| | | in pipelines: 36(GETNEXT), 25(OPEN) |
| | | |
| | |--47:HASH JOIN [LEFT SEMI JOIN] |
| | | | hash predicates: ws_item_sk = i_item_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=22,23 row-size=36B cardinality=42.85K |
| | | | in pipelines: 25(GETNEXT), 46(OPEN) |
| | | | |
| | | |--46:AGGREGATE [FINALIZE] |
| | | | | group by: i_item_sk |
| | | | | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | | tuple-ids=68 row-size=8B cardinality=17.98K |
| | | | | in pipelines: 46(GETNEXT), 32(OPEN) |
| | | | | |
| | | | 32:AGGREGATE [FINALIZE] |
| | | | | output: count(*) |
| | | | | group by: substr(i_item_desc, CAST(1 AS BIGINT), CAST(30 AS BIGINT)), i_item_sk, d_date |
| | | | | having: count(*) > CAST(4 AS BIGINT) |
| | | | | mem-estimate=123.50MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0 |
| | | | | tuple-ids=27 row-size=50B cardinality=235.45K |
| | | | | in pipelines: 32(GETNEXT), 27(OPEN) |
| | | | | |
| | | | 31:HASH JOIN [INNER JOIN] |
| | | | | hash predicates: ss_item_sk = i_item_sk |
| | | | | fk/pk conjuncts: ss_item_sk = i_item_sk |
| | | | | mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0 |
| | | | | tuple-ids=24,25,26 row-size=162B cardinality=2.35M |
| | | | | in pipelines: 27(GETNEXT), 29(OPEN) |
| | | | | |
| | | | |--29: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=32.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | | tuple-ids=26 row-size=120B cardinality=18.00K |
| | | | | in pipelines: 29(GETNEXT) |
| | | | | |
| | | | 30: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: RF030[bloom] <- d_date_sk |
| | | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | | tuple-ids=24,25 row-size=42B cardinality=2.35M |
| | | | | in pipelines: 27(GETNEXT), 28(OPEN) |
| | | | | |
| | | | |--28:SCAN HDFS [tpcds_parquet.date_dim] |
| | | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | | mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | | tuple-ids=25 row-size=30B cardinality=1.49K |
| | | | | in pipelines: 28(GETNEXT) |
| | | | | |
| | | | 27:SCAN HDFS [tpcds_parquet.store_sales] |
| | | | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | | | runtime filters: RF030[bloom] -> 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=24 row-size=12B cardinality=2.88M |
| | | | in pipelines: 27(GETNEXT) |
| | | | |
| | | 45:HASH JOIN [INNER JOIN] |
| | | | hash predicates: ws_sold_date_sk = d_date_sk |
| | | | fk/pk conjuncts: ws_sold_date_sk = d_date_sk |
| | | | runtime filters: RF026[bloom] <- d_date_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=22,23 row-size=36B cardinality=42.85K |
| | | | in pipelines: 25(GETNEXT), 26(OPEN) |
| | | | |
| | | |--26:SCAN HDFS [tpcds_parquet.date_dim] |
| | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 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(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | | parquet dictionary predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | | mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | | tuple-ids=23 row-size=12B cardinality=108 |
| | | | in pipelines: 26(GETNEXT) |
| | | | |
| | | 25:SCAN HDFS [tpcds_parquet.web_sales] |
| | | HDFS partitions=1/1 files=2 size=45.09MB |
| | | runtime filters: RF026[bloom] -> 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=160.00MB mem-reservation=8.00MB thread-reservation=1 |
| | | tuple-ids=22 row-size=24B cardinality=719.38K |
| | | in pipelines: 25(GETNEXT) |
| | | |
| | 44:NESTED LOOP JOIN [INNER JOIN] |
| | | predicates: sum(ss_quantity * ss_sales_price) > CAST(0.500000 AS DECIMAL(10,6)) * max(csales) |
| | | mem-estimate=16B mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=32,39 row-size=36B cardinality=100.00K |
| | | in pipelines: 36(GETNEXT), 43(OPEN) |
| | | |
| | |--43:AGGREGATE [FINALIZE] |
| | | | output: max(sum(ss_quantity * ss_sales_price)) |
| | | | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | | | tuple-ids=39 row-size=16B cardinality=1 |
| | | | in pipelines: 43(GETNEXT), 42(OPEN) |
| | | | |
| | | 42:AGGREGATE [FINALIZE] |
| | | | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | | | group by: c_customer_sk |
| | | | mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0 |
| | | | tuple-ids=37 row-size=20B cardinality=100.00K |
| | | | in pipelines: 42(GETNEXT), 37(OPEN) |
| | | | |
| | | 41:HASH JOIN [INNER JOIN] |
| | | | hash predicates: ss_customer_sk = c_customer_sk |
| | | | fk/pk conjuncts: ss_customer_sk = c_customer_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=34,36,35 row-size=28B cardinality=2.35M |
| | | | in pipelines: 37(GETNEXT), 38(OPEN) |
| | | | |
| | | |--38: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=16.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | | tuple-ids=35 row-size=4B cardinality=100.00K |
| | | | in pipelines: 38(GETNEXT) |
| | | | |
| | | 40: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: RF022[bloom] <- d_date_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=34,36 row-size=24B cardinality=2.35M |
| | | | in pipelines: 37(GETNEXT), 39(OPEN) |
| | | | |
| | | |--39:SCAN HDFS [tpcds_parquet.date_dim] |
| | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | | tuple-ids=36 row-size=8B cardinality=1.49K |
| | | | in pipelines: 39(GETNEXT) |
| | | | |
| | | 37:SCAN HDFS [tpcds_parquet.store_sales] |
| | | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | | runtime filters: RF022[bloom] -> 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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| | | tuple-ids=34 row-size=16B cardinality=2.88M |
| | | in pipelines: 37(GETNEXT) |
| | | |
| | 36:AGGREGATE [FINALIZE] |
| | | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | | group by: c_customer_sk |
| | | mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0 |
| | | tuple-ids=32 row-size=20B cardinality=100.00K |
| | | in pipelines: 36(GETNEXT), 33(OPEN) |
| | | |
| | 35:HASH JOIN [INNER JOIN] |
| | | hash predicates: ss_customer_sk = c_customer_sk |
| | | fk/pk conjuncts: ss_customer_sk = c_customer_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=30,31 row-size=16B cardinality=2.88M |
| | | in pipelines: 33(GETNEXT), 34(OPEN) |
| | | |
| | |--34:SCAN HDFS [tpcds_parquet.customer] |
| | | HDFS partitions=1/1 files=1 size=5.49MB |
| | | runtime filters: RF016[bloom] -> tpcds_parquet.customer.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=16.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=31 row-size=4B cardinality=100.00K |
| | | in pipelines: 34(GETNEXT) |
| | | |
| | 33:SCAN HDFS [tpcds_parquet.store_sales] |
| | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | runtime filters: RF016[bloom] -> tpcds_parquet.store_sales.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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| | tuple-ids=30 row-size=12B cardinality=2.88M |
| | in pipelines: 33(GETNEXT) |
| | |
| 24:HASH JOIN [RIGHT SEMI JOIN] |
| | hash predicates: c_customer_sk = cs_bill_customer_sk |
| | runtime filters: RF000[bloom] <- cs_bill_customer_sk |
| | mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0 |
| | tuple-ids=0,1 row-size=36B cardinality=85.31K |
| | in pipelines: 12(GETNEXT), 01(OPEN) |
| | |
| |--23:HASH JOIN [LEFT SEMI JOIN] |
| | | hash predicates: cs_item_sk = i_item_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=0,1 row-size=36B cardinality=85.31K |
| | | in pipelines: 01(GETNEXT), 22(OPEN) |
| | | |
| | |--22:AGGREGATE [FINALIZE] |
| | | | group by: i_item_sk |
| | | | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=57 row-size=8B cardinality=17.98K |
| | | | in pipelines: 22(GETNEXT), 08(OPEN) |
| | | | |
| | | 08:AGGREGATE [FINALIZE] |
| | | | output: count(*) |
| | | | group by: substr(i_item_desc, CAST(1 AS BIGINT), CAST(30 AS BIGINT)), i_item_sk, d_date |
| | | | having: count(*) > CAST(4 AS BIGINT) |
| | | | mem-estimate=123.50MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0 |
| | | | tuple-ids=5 row-size=50B cardinality=235.45K |
| | | | in pipelines: 08(GETNEXT), 03(OPEN) |
| | | | |
| | | 07:HASH JOIN [INNER JOIN] |
| | | | hash predicates: ss_item_sk = i_item_sk |
| | | | fk/pk conjuncts: ss_item_sk = i_item_sk |
| | | | mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0 |
| | | | tuple-ids=2,3,4 row-size=162B cardinality=2.35M |
| | | | in pipelines: 03(GETNEXT), 05(OPEN) |
| | | | |
| | | |--05: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=32.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | tuple-ids=4 row-size=120B cardinality=18.00K |
| | | | in pipelines: 05(GETNEXT) |
| | | | |
| | | 06: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: RF014[bloom] <- d_date_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=2,3 row-size=42B cardinality=2.35M |
| | | | in pipelines: 03(GETNEXT), 04(OPEN) |
| | | | |
| | | |--04:SCAN HDFS [tpcds_parquet.date_dim] |
| | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | tuple-ids=3 row-size=30B cardinality=1.49K |
| | | | in pipelines: 04(GETNEXT) |
| | | | |
| | | 03:SCAN HDFS [tpcds_parquet.store_sales] |
| | | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | | runtime filters: RF014[bloom] -> 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=2 row-size=12B cardinality=2.88M |
| | | in pipelines: 03(GETNEXT) |
| | | |
| | 21:HASH JOIN [INNER JOIN] |
| | | hash predicates: cs_sold_date_sk = d_date_sk |
| | | fk/pk conjuncts: cs_sold_date_sk = d_date_sk |
| | | runtime filters: RF010[bloom] <- d_date_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=0,1 row-size=36B cardinality=85.31K |
| | | in pipelines: 01(GETNEXT), 02(OPEN) |
| | | |
| | |--02:SCAN HDFS [tpcds_parquet.date_dim] |
| | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 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(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | parquet dictionary predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=1 row-size=12B cardinality=108 |
| | | in pipelines: 02(GETNEXT) |
| | | |
| | 01:SCAN HDFS [tpcds_parquet.catalog_sales] |
| | HDFS partitions=1/1 files=3 size=96.62MB |
| | runtime filters: RF010[bloom] -> cs_sold_date_sk |
| | stored statistics: |
| | table: rows=1.44M size=96.62MB |
| | columns: all |
| | extrapolated-rows=disabled max-scan-range-rows=650.14K |
| | mem-estimate=240.00MB mem-reservation=8.00MB thread-reservation=1 |
| | tuple-ids=0 row-size=24B cardinality=1.44M |
| | in pipelines: 01(GETNEXT) |
| | |
| 20:NESTED LOOP JOIN [INNER JOIN] |
| | predicates: sum(ss_quantity * ss_sales_price) > CAST(0.500000 AS DECIMAL(10,6)) * max(csales) |
| | mem-estimate=16B mem-reservation=0B thread-reservation=0 |
| | tuple-ids=10,17 row-size=36B cardinality=100.00K |
| | in pipelines: 12(GETNEXT), 19(OPEN) |
| | |
| |--19:AGGREGATE [FINALIZE] |
| | | output: max(sum(ss_quantity * ss_sales_price)) |
| | | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | | tuple-ids=17 row-size=16B cardinality=1 |
| | | in pipelines: 19(GETNEXT), 18(OPEN) |
| | | |
| | 18:AGGREGATE [FINALIZE] |
| | | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | | group by: c_customer_sk |
| | | mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0 |
| | | tuple-ids=15 row-size=20B cardinality=100.00K |
| | | in pipelines: 18(GETNEXT), 13(OPEN) |
| | | |
| | 17:HASH JOIN [INNER JOIN] |
| | | 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=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=12,14,13 row-size=28B cardinality=2.35M |
| | | in pipelines: 13(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=16.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=13 row-size=4B cardinality=100.00K |
| | | in pipelines: 14(GETNEXT) |
| | | |
| | 16: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: RF006[bloom] <- d_date_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=12,14 row-size=24B cardinality=2.35M |
| | | in pipelines: 13(GETNEXT), 15(OPEN) |
| | | |
| | |--15:SCAN HDFS [tpcds_parquet.date_dim] |
| | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=14 row-size=8B cardinality=1.49K |
| | | in pipelines: 15(GETNEXT) |
| | | |
| | 13:SCAN HDFS [tpcds_parquet.store_sales] |
| | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | runtime filters: RF006[bloom] -> ss_sold_date_sk, 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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| | tuple-ids=12 row-size=16B cardinality=2.88M |
| | in pipelines: 13(GETNEXT) |
| | |
| 12:AGGREGATE [FINALIZE] |
| | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | group by: c_customer_sk |
| | mem-estimate=10.00MB mem-reservation=2.88MB spill-buffer=128.00KB thread-reservation=0 |
| | tuple-ids=10 row-size=20B cardinality=100.00K |
| | in pipelines: 12(GETNEXT), 09(OPEN) |
| | |
| 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=8,9 row-size=16B cardinality=2.88M |
| | in pipelines: 09(GETNEXT), 10(OPEN) |
| | |
| |--10:SCAN HDFS [tpcds_parquet.customer] |
| | HDFS partitions=1/1 files=1 size=5.49MB |
| | runtime filters: RF000[bloom] -> tpcds_parquet.customer.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=16.00MB mem-reservation=512.00KB thread-reservation=1 |
| | tuple-ids=9 row-size=4B cardinality=100.00K |
| | in pipelines: 10(GETNEXT) |
| | |
| 09:SCAN HDFS [tpcds_parquet.store_sales] |
| HDFS partitions=1824/1824 files=1824 size=200.95MB |
| runtime filters: RF000[bloom] -> tpcds_parquet.store_sales.ss_customer_sk, RF002[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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| tuple-ids=8 row-size=12B cardinality=2.88M |
| in pipelines: 09(GETNEXT) |
| ---- DISTRIBUTEDPLAN |
| Max Per-Host Resource Reservation: Memory=243.38MB Threads=50 |
| Per-Host Resource Estimates: Memory=1.47GB |
| F31: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: sum(sales) |
| | mem-estimate=0B mem-reservation=0B thread-reservation=0 |
| | |
| 89:AGGREGATE [FINALIZE] |
| | output: sum:merge(sales) |
| | limit: 100 |
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | tuple-ids=46 row-size=16B cardinality=1 |
| | in pipelines: 89(GETNEXT), 49(OPEN) |
| | |
| 88:EXCHANGE [UNPARTITIONED] |
| | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 |
| | tuple-ids=46 row-size=16B cardinality=1 |
| | in pipelines: 49(GETNEXT) |
| | |
| F30:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| Per-Host Resources: mem-estimate=25.76MB mem-reservation=5.88MB thread-reservation=1 runtime-filters-memory=2.00MB |
| 49:AGGREGATE |
| | output: sum(sales) |
| | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | tuple-ids=46 row-size=16B cardinality=1 |
| | in pipelines: 49(GETNEXT), 52(OPEN), 71(OPEN) |
| | |
| 00:UNION |
| | mem-estimate=0B mem-reservation=0B thread-reservation=0 |
| | tuple-ids=44 row-size=8B cardinality=128.16K |
| | in pipelines: 52(GETNEXT), 71(GETNEXT) |
| | |
| |--48:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED] |
| | | hash predicates: c_customer_sk = ws_bill_customer_sk |
| | | runtime filters: RF016[bloom] <- ws_bill_customer_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=22,23 row-size=36B cardinality=42.85K |
| | | in pipelines: 71(GETNEXT), 25(OPEN) |
| | | |
| | |--87:EXCHANGE [HASH(ws_bill_customer_sk)] |
| | | | mem-estimate=841.29KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=22,23 row-size=36B cardinality=42.85K |
| | | | in pipelines: 25(GETNEXT) |
| | | | |
| | | F23:PLAN FRAGMENT [RANDOM] hosts=2 instances=2 |
| | | Per-Host Resources: mem-estimate=165.06MB mem-reservation=12.88MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | | 47:HASH JOIN [LEFT SEMI JOIN, BROADCAST] |
| | | | hash predicates: ws_item_sk = i_item_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=22,23 row-size=36B cardinality=42.85K |
| | | | in pipelines: 25(GETNEXT), 85(OPEN) |
| | | | |
| | | |--86:EXCHANGE [BROADCAST] |
| | | | | mem-estimate=176.43KB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=68 row-size=8B cardinality=17.98K |
| | | | | in pipelines: 85(GETNEXT) |
| | | | | |
| | | | F29:PLAN FRAGMENT [HASH(i_item_sk)] hosts=3 instances=3 |
| | | | Per-Host Resources: mem-estimate=10.08MB mem-reservation=1.94MB thread-reservation=1 |
| | | | 85:AGGREGATE [FINALIZE] |
| | | | | group by: i_item_sk |
| | | | | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | | tuple-ids=68 row-size=8B cardinality=17.98K |
| | | | | in pipelines: 85(GETNEXT), 83(OPEN) |
| | | | | |
| | | | 84:EXCHANGE [HASH(i_item_sk)] |
| | | | | mem-estimate=82.81KB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=68 row-size=8B cardinality=17.98K |
| | | | | in pipelines: 83(GETNEXT) |
| | | | | |
| | | | F28:PLAN FRAGMENT [HASH(substr(i_item_desc, 1, 30),i_item_sk,d_date)] hosts=3 instances=3 |
| | | | Per-Host Resources: mem-estimate=81.91MB mem-reservation=36.00MB thread-reservation=1 |
| | | | 46:AGGREGATE [STREAMING] |
| | | | | group by: i_item_sk |
| | | | | mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0 |
| | | | | tuple-ids=68 row-size=8B cardinality=17.98K |
| | | | | in pipelines: 83(GETNEXT) |
| | | | | |
| | | | 83:AGGREGATE [FINALIZE] |
| | | | | output: count:merge(*) |
| | | | | group by: substr(i_item_desc, 1, 30), i_item_sk, d_date |
| | | | | having: count(*) > CAST(4 AS BIGINT) |
| | | | | mem-estimate=61.75MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0 |
| | | | | tuple-ids=27 row-size=50B cardinality=235.45K |
| | | | | in pipelines: 83(GETNEXT), 27(OPEN) |
| | | | | |
| | | | 82:EXCHANGE [HASH(substr(i_item_desc, 1, 30),i_item_sk,d_date)] |
| | | | | mem-estimate=10.16MB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=27 row-size=50B cardinality=2.35M |
| | | | | in pipelines: 27(GETNEXT) |
| | | | | |
| | | | F25:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| | | | Per-Host Resources: mem-estimate=87.70MB mem-reservation=42.19MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | | | 32:AGGREGATE [STREAMING] |
| | | | | output: count(*) |
| | | | | group by: substr(i_item_desc, CAST(1 AS BIGINT), CAST(30 AS BIGINT)), i_item_sk, d_date |
| | | | | mem-estimate=61.75MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0 |
| | | | | tuple-ids=27 row-size=50B cardinality=2.35M |
| | | | | in pipelines: 27(GETNEXT) |
| | | | | |
| | | | 31:HASH JOIN [INNER JOIN, BROADCAST] |
| | | | | hash predicates: ss_item_sk = i_item_sk |
| | | | | fk/pk conjuncts: ss_item_sk = i_item_sk |
| | | | | mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0 |
| | | | | tuple-ids=24,25,26 row-size=162B cardinality=2.35M |
| | | | | in pipelines: 27(GETNEXT), 29(OPEN) |
| | | | | |
| | | | |--81:EXCHANGE [BROADCAST] |
| | | | | | mem-estimate=2.19MB mem-reservation=0B thread-reservation=0 |
| | | | | | tuple-ids=26 row-size=120B cardinality=18.00K |
| | | | | | in pipelines: 29(GETNEXT) |
| | | | | | |
| | | | | F27:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | | | Per-Host Resources: mem-estimate=32.00MB mem-reservation=2.00MB thread-reservation=2 |
| | | | | 29: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=32.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | | tuple-ids=26 row-size=120B cardinality=18.00K |
| | | | | in pipelines: 29(GETNEXT) |
| | | | | |
| | | | 30: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: RF030[bloom] <- d_date_sk |
| | | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | | tuple-ids=24,25 row-size=42B cardinality=2.35M |
| | | | | in pipelines: 27(GETNEXT), 28(OPEN) |
| | | | | |
| | | | |--80:EXCHANGE [BROADCAST] |
| | | | | | mem-estimate=77.68KB mem-reservation=0B thread-reservation=0 |
| | | | | | tuple-ids=25 row-size=30B cardinality=1.49K |
| | | | | | in pipelines: 28(GETNEXT) |
| | | | | | |
| | | | | F26:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | | | Per-Host Resources: mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=2 |
| | | | | 28:SCAN HDFS [tpcds_parquet.date_dim, RANDOM] |
| | | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | | mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | | tuple-ids=25 row-size=30B cardinality=1.49K |
| | | | | in pipelines: 28(GETNEXT) |
| | | | | |
| | | | 27:SCAN HDFS [tpcds_parquet.store_sales, RANDOM] |
| | | | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | | | runtime filters: RF030[bloom] -> 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=24 row-size=12B cardinality=2.88M |
| | | | in pipelines: 27(GETNEXT) |
| | | | |
| | | 45:HASH JOIN [INNER JOIN, BROADCAST] |
| | | | hash predicates: ws_sold_date_sk = d_date_sk |
| | | | fk/pk conjuncts: ws_sold_date_sk = d_date_sk |
| | | | runtime filters: RF026[bloom] <- d_date_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=22,23 row-size=36B cardinality=42.85K |
| | | | in pipelines: 25(GETNEXT), 26(OPEN) |
| | | | |
| | | |--79:EXCHANGE [BROADCAST] |
| | | | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=23 row-size=12B cardinality=108 |
| | | | | in pipelines: 26(GETNEXT) |
| | | | | |
| | | | F24:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | | Per-Host Resources: mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=2 |
| | | | 26:SCAN HDFS [tpcds_parquet.date_dim, RANDOM] |
| | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 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(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | | parquet dictionary predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | | mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | | tuple-ids=23 row-size=12B cardinality=108 |
| | | | in pipelines: 26(GETNEXT) |
| | | | |
| | | 25:SCAN HDFS [tpcds_parquet.web_sales, RANDOM] |
| | | HDFS partitions=1/1 files=2 size=45.09MB |
| | | runtime filters: RF026[bloom] -> 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=160.00MB mem-reservation=8.00MB thread-reservation=1 |
| | | tuple-ids=22 row-size=24B cardinality=719.38K |
| | | in pipelines: 25(GETNEXT) |
| | | |
| | 44:NESTED LOOP JOIN [INNER JOIN, BROADCAST] |
| | | predicates: sum(ss_quantity * ss_sales_price) > CAST(0.500000 AS DECIMAL(10,6)) * max(csales) |
| | | mem-estimate=16B mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=32,39 row-size=36B cardinality=100.00K |
| | | in pipelines: 71(GETNEXT), 77(OPEN) |
| | | |
| | |--78:EXCHANGE [BROADCAST] |
| | | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=39 row-size=16B cardinality=1 |
| | | | in pipelines: 77(GETNEXT) |
| | | | |
| | | F22:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 |
| | | Per-Host Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1 |
| | | 77:AGGREGATE [FINALIZE] |
| | | | output: max:merge(csales) |
| | | | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | | | tuple-ids=39 row-size=16B cardinality=1 |
| | | | in pipelines: 77(GETNEXT), 43(OPEN) |
| | | | |
| | | 76:EXCHANGE [UNPARTITIONED] |
| | | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=39 row-size=16B cardinality=1 |
| | | | in pipelines: 43(GETNEXT) |
| | | | |
| | | F21:PLAN FRAGMENT [HASH(c_customer_sk)] hosts=3 instances=3 |
| | | Per-Host Resources: mem-estimate=20.00MB mem-reservation=1.94MB thread-reservation=1 |
| | | 43:AGGREGATE |
| | | | output: max(sum(ss_quantity * ss_sales_price)) |
| | | | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | | | tuple-ids=39 row-size=16B cardinality=1 |
| | | | in pipelines: 43(GETNEXT), 75(OPEN) |
| | | | |
| | | 75:AGGREGATE [FINALIZE] |
| | | | output: sum:merge(ss_quantity * ss_sales_price) |
| | | | group by: c_customer_sk |
| | | | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=37 row-size=20B cardinality=100.00K |
| | | | in pipelines: 75(GETNEXT), 37(OPEN) |
| | | | |
| | | 74:EXCHANGE [HASH(c_customer_sk)] |
| | | | mem-estimate=723.04KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=37 row-size=20B cardinality=100.00K |
| | | | in pipelines: 37(GETNEXT) |
| | | | |
| | | F18:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| | | Per-Host Resources: mem-estimate=63.29MB mem-reservation=8.88MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | | 42:AGGREGATE [STREAMING] |
| | | | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | | | group by: c_customer_sk |
| | | | mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0 |
| | | | tuple-ids=37 row-size=20B cardinality=100.00K |
| | | | in pipelines: 37(GETNEXT) |
| | | | |
| | | 41:HASH JOIN [INNER JOIN, BROADCAST] |
| | | | hash predicates: ss_customer_sk = c_customer_sk |
| | | | fk/pk conjuncts: ss_customer_sk = c_customer_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=34,36,35 row-size=28B cardinality=2.35M |
| | | | in pipelines: 37(GETNEXT), 38(OPEN) |
| | | | |
| | | |--73:EXCHANGE [BROADCAST] |
| | | | | mem-estimate=398.62KB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=35 row-size=4B cardinality=100.00K |
| | | | | in pipelines: 38(GETNEXT) |
| | | | | |
| | | | F20:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | | Per-Host Resources: mem-estimate=16.00MB mem-reservation=512.00KB thread-reservation=2 |
| | | | 38: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=512.00KB thread-reservation=1 |
| | | | tuple-ids=35 row-size=4B cardinality=100.00K |
| | | | in pipelines: 38(GETNEXT) |
| | | | |
| | | 40: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: RF022[bloom] <- d_date_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=34,36 row-size=24B cardinality=2.35M |
| | | | in pipelines: 37(GETNEXT), 39(OPEN) |
| | | | |
| | | |--72:EXCHANGE [BROADCAST] |
| | | | | mem-estimate=23.65KB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=36 row-size=8B cardinality=1.49K |
| | | | | in pipelines: 39(GETNEXT) |
| | | | | |
| | | | F19:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | | Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2 |
| | | | 39:SCAN HDFS [tpcds_parquet.date_dim, RANDOM] |
| | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | | tuple-ids=36 row-size=8B cardinality=1.49K |
| | | | in pipelines: 39(GETNEXT) |
| | | | |
| | | 37:SCAN HDFS [tpcds_parquet.store_sales, RANDOM] |
| | | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | | runtime filters: RF022[bloom] -> 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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| | | tuple-ids=34 row-size=16B cardinality=2.88M |
| | | in pipelines: 37(GETNEXT) |
| | | |
| | 71:AGGREGATE [FINALIZE] |
| | | output: sum:merge(ss_quantity * ss_sales_price) |
| | | group by: c_customer_sk |
| | | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=32 row-size=20B cardinality=100.00K |
| | | in pipelines: 71(GETNEXT), 33(OPEN) |
| | | |
| | 70:EXCHANGE [HASH(c_customer_sk)] |
| | | mem-estimate=723.04KB mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=32 row-size=20B cardinality=100.00K |
| | | in pipelines: 33(GETNEXT) |
| | | |
| | F15:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| | Per-Host Resources: mem-estimate=61.33MB mem-reservation=6.94MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | 36:AGGREGATE [STREAMING] |
| | | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | | group by: c_customer_sk |
| | | mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0 |
| | | tuple-ids=32 row-size=20B cardinality=100.00K |
| | | in pipelines: 33(GETNEXT) |
| | | |
| | 35:HASH JOIN [INNER JOIN, BROADCAST] |
| | | hash predicates: ss_customer_sk = c_customer_sk |
| | | fk/pk conjuncts: ss_customer_sk = c_customer_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=30,31 row-size=16B cardinality=2.88M |
| | | in pipelines: 33(GETNEXT), 34(OPEN) |
| | | |
| | |--69:EXCHANGE [BROADCAST] |
| | | | mem-estimate=398.62KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=31 row-size=4B cardinality=100.00K |
| | | | in pipelines: 34(GETNEXT) |
| | | | |
| | | F16:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | Per-Host Resources: mem-estimate=17.00MB mem-reservation=1.50MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | | 34:SCAN HDFS [tpcds_parquet.customer, RANDOM] |
| | | HDFS partitions=1/1 files=1 size=5.49MB |
| | | runtime filters: RF016[bloom] -> tpcds_parquet.customer.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=16.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=31 row-size=4B cardinality=100.00K |
| | | in pipelines: 34(GETNEXT) |
| | | |
| | 33:SCAN HDFS [tpcds_parquet.store_sales, RANDOM] |
| | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | runtime filters: RF016[bloom] -> tpcds_parquet.store_sales.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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| | tuple-ids=30 row-size=12B cardinality=2.88M |
| | in pipelines: 33(GETNEXT) |
| | |
| 24:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED] |
| | hash predicates: c_customer_sk = cs_bill_customer_sk |
| | runtime filters: RF000[bloom] <- cs_bill_customer_sk |
| | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | tuple-ids=0,1 row-size=36B cardinality=85.31K |
| | in pipelines: 52(GETNEXT), 01(OPEN) |
| | |
| |--68:EXCHANGE [HASH(cs_bill_customer_sk)] |
| | | mem-estimate=1.11MB mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=0,1 row-size=36B cardinality=85.31K |
| | | in pipelines: 01(GETNEXT) |
| | | |
| | F08:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| | Per-Host Resources: mem-estimate=245.06MB mem-reservation=12.88MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | 23:HASH JOIN [LEFT SEMI JOIN, BROADCAST] |
| | | hash predicates: cs_item_sk = i_item_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=0,1 row-size=36B cardinality=85.31K |
| | | in pipelines: 01(GETNEXT), 66(OPEN) |
| | | |
| | |--67:EXCHANGE [BROADCAST] |
| | | | mem-estimate=176.43KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=57 row-size=8B cardinality=17.98K |
| | | | in pipelines: 66(GETNEXT) |
| | | | |
| | | F14:PLAN FRAGMENT [HASH(i_item_sk)] hosts=3 instances=3 |
| | | Per-Host Resources: mem-estimate=10.08MB mem-reservation=1.94MB thread-reservation=1 |
| | | 66:AGGREGATE [FINALIZE] |
| | | | group by: i_item_sk |
| | | | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=57 row-size=8B cardinality=17.98K |
| | | | in pipelines: 66(GETNEXT), 64(OPEN) |
| | | | |
| | | 65:EXCHANGE [HASH(i_item_sk)] |
| | | | mem-estimate=82.81KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=57 row-size=8B cardinality=17.98K |
| | | | in pipelines: 64(GETNEXT) |
| | | | |
| | | F13:PLAN FRAGMENT [HASH(substr(i_item_desc, 1, 30),i_item_sk,d_date)] hosts=3 instances=3 |
| | | Per-Host Resources: mem-estimate=81.91MB mem-reservation=36.00MB thread-reservation=1 |
| | | 22:AGGREGATE [STREAMING] |
| | | | group by: i_item_sk |
| | | | mem-estimate=10.00MB mem-reservation=2.00MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=57 row-size=8B cardinality=17.98K |
| | | | in pipelines: 64(GETNEXT) |
| | | | |
| | | 64:AGGREGATE [FINALIZE] |
| | | | output: count:merge(*) |
| | | | group by: substr(i_item_desc, 1, 30), i_item_sk, d_date |
| | | | having: count(*) > CAST(4 AS BIGINT) |
| | | | mem-estimate=61.75MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0 |
| | | | tuple-ids=5 row-size=50B cardinality=235.45K |
| | | | in pipelines: 64(GETNEXT), 03(OPEN) |
| | | | |
| | | 63:EXCHANGE [HASH(substr(i_item_desc, 1, 30),i_item_sk,d_date)] |
| | | | mem-estimate=10.16MB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=5 row-size=50B cardinality=2.35M |
| | | | in pipelines: 03(GETNEXT) |
| | | | |
| | | F10:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| | | Per-Host Resources: mem-estimate=87.70MB mem-reservation=42.19MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | | 08:AGGREGATE [STREAMING] |
| | | | output: count(*) |
| | | | group by: substr(i_item_desc, CAST(1 AS BIGINT), CAST(30 AS BIGINT)), i_item_sk, d_date |
| | | | mem-estimate=61.75MB mem-reservation=34.00MB spill-buffer=2.00MB thread-reservation=0 |
| | | | tuple-ids=5 row-size=50B cardinality=2.35M |
| | | | in pipelines: 03(GETNEXT) |
| | | | |
| | | 07:HASH JOIN [INNER JOIN, BROADCAST] |
| | | | hash predicates: ss_item_sk = i_item_sk |
| | | | fk/pk conjuncts: ss_item_sk = i_item_sk |
| | | | mem-estimate=4.75MB mem-reservation=4.75MB spill-buffer=256.00KB thread-reservation=0 |
| | | | tuple-ids=2,3,4 row-size=162B cardinality=2.35M |
| | | | in pipelines: 03(GETNEXT), 05(OPEN) |
| | | | |
| | | |--62:EXCHANGE [BROADCAST] |
| | | | | mem-estimate=2.19MB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=4 row-size=120B cardinality=18.00K |
| | | | | in pipelines: 05(GETNEXT) |
| | | | | |
| | | | F12:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | | Per-Host Resources: mem-estimate=32.00MB mem-reservation=2.00MB thread-reservation=2 |
| | | | 05: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=32.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | tuple-ids=4 row-size=120B cardinality=18.00K |
| | | | in pipelines: 05(GETNEXT) |
| | | | |
| | | 06: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: RF014[bloom] <- d_date_sk |
| | | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | | tuple-ids=2,3 row-size=42B cardinality=2.35M |
| | | | in pipelines: 03(GETNEXT), 04(OPEN) |
| | | | |
| | | |--61:EXCHANGE [BROADCAST] |
| | | | | mem-estimate=77.68KB mem-reservation=0B thread-reservation=0 |
| | | | | tuple-ids=3 row-size=30B cardinality=1.49K |
| | | | | in pipelines: 04(GETNEXT) |
| | | | | |
| | | | F11:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | | Per-Host Resources: mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=2 |
| | | | 04:SCAN HDFS [tpcds_parquet.date_dim, RANDOM] |
| | | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | | mem-estimate=48.00MB mem-reservation=2.00MB thread-reservation=1 |
| | | | tuple-ids=3 row-size=30B cardinality=1.49K |
| | | | in pipelines: 04(GETNEXT) |
| | | | |
| | | 03:SCAN HDFS [tpcds_parquet.store_sales, RANDOM] |
| | | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | | runtime filters: RF014[bloom] -> 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=2 row-size=12B cardinality=2.88M |
| | | in pipelines: 03(GETNEXT) |
| | | |
| | 21:HASH JOIN [INNER JOIN, BROADCAST] |
| | | hash predicates: cs_sold_date_sk = d_date_sk |
| | | fk/pk conjuncts: cs_sold_date_sk = d_date_sk |
| | | runtime filters: RF010[bloom] <- d_date_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=0,1 row-size=36B cardinality=85.31K |
| | | in pipelines: 01(GETNEXT), 02(OPEN) |
| | | |
| | |--60:EXCHANGE [BROADCAST] |
| | | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=1 row-size=12B cardinality=108 |
| | | | in pipelines: 02(GETNEXT) |
| | | | |
| | | F09:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | Per-Host Resources: mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=2 |
| | | 02:SCAN HDFS [tpcds_parquet.date_dim, RANDOM] |
| | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 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(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | parquet dictionary predicates: d_year = CAST(2000 AS INT), d_moy = CAST(2 AS INT) |
| | | mem-estimate=48.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=1 row-size=12B cardinality=108 |
| | | in pipelines: 02(GETNEXT) |
| | | |
| | 01:SCAN HDFS [tpcds_parquet.catalog_sales, RANDOM] |
| | HDFS partitions=1/1 files=3 size=96.62MB |
| | runtime filters: RF010[bloom] -> cs_sold_date_sk |
| | stored statistics: |
| | table: rows=1.44M size=96.62MB |
| | columns: all |
| | extrapolated-rows=disabled max-scan-range-rows=650.14K |
| | mem-estimate=240.00MB mem-reservation=8.00MB thread-reservation=1 |
| | tuple-ids=0 row-size=24B cardinality=1.44M |
| | in pipelines: 01(GETNEXT) |
| | |
| 20:NESTED LOOP JOIN [INNER JOIN, BROADCAST] |
| | predicates: sum(ss_quantity * ss_sales_price) > CAST(0.500000 AS DECIMAL(10,6)) * max(csales) |
| | mem-estimate=16B mem-reservation=0B thread-reservation=0 |
| | tuple-ids=10,17 row-size=36B cardinality=100.00K |
| | in pipelines: 52(GETNEXT), 58(OPEN) |
| | |
| |--59:EXCHANGE [BROADCAST] |
| | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=17 row-size=16B cardinality=1 |
| | | in pipelines: 58(GETNEXT) |
| | | |
| | F07:PLAN FRAGMENT [UNPARTITIONED] hosts=1 instances=1 |
| | Per-Host Resources: mem-estimate=10.02MB mem-reservation=0B thread-reservation=1 |
| | 58:AGGREGATE [FINALIZE] |
| | | output: max:merge(csales) |
| | | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | | tuple-ids=17 row-size=16B cardinality=1 |
| | | in pipelines: 58(GETNEXT), 19(OPEN) |
| | | |
| | 57:EXCHANGE [UNPARTITIONED] |
| | | mem-estimate=16.00KB mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=17 row-size=16B cardinality=1 |
| | | in pipelines: 19(GETNEXT) |
| | | |
| | F06:PLAN FRAGMENT [HASH(c_customer_sk)] hosts=3 instances=3 |
| | Per-Host Resources: mem-estimate=20.00MB mem-reservation=1.94MB thread-reservation=1 |
| | 19:AGGREGATE |
| | | output: max(sum(ss_quantity * ss_sales_price)) |
| | | mem-estimate=10.00MB mem-reservation=0B spill-buffer=2.00MB thread-reservation=0 |
| | | tuple-ids=17 row-size=16B cardinality=1 |
| | | in pipelines: 19(GETNEXT), 56(OPEN) |
| | | |
| | 56:AGGREGATE [FINALIZE] |
| | | output: sum:merge(ss_quantity * ss_sales_price) |
| | | group by: c_customer_sk |
| | | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=15 row-size=20B cardinality=100.00K |
| | | in pipelines: 56(GETNEXT), 13(OPEN) |
| | | |
| | 55:EXCHANGE [HASH(c_customer_sk)] |
| | | mem-estimate=723.04KB mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=15 row-size=20B cardinality=100.00K |
| | | in pipelines: 13(GETNEXT) |
| | | |
| | F03:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| | Per-Host Resources: mem-estimate=64.29MB mem-reservation=9.88MB thread-reservation=2 runtime-filters-memory=2.00MB |
| | 18:AGGREGATE [STREAMING] |
| | | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | | group by: c_customer_sk |
| | | mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0 |
| | | tuple-ids=15 row-size=20B cardinality=100.00K |
| | | in pipelines: 13(GETNEXT) |
| | | |
| | 17:HASH JOIN [INNER JOIN, BROADCAST] |
| | | 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=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=12,14,13 row-size=28B cardinality=2.35M |
| | | in pipelines: 13(GETNEXT), 14(OPEN) |
| | | |
| | |--54:EXCHANGE [BROADCAST] |
| | | | mem-estimate=398.62KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=13 row-size=4B cardinality=100.00K |
| | | | in pipelines: 14(GETNEXT) |
| | | | |
| | | F05:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | Per-Host Resources: mem-estimate=16.00MB mem-reservation=512.00KB 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=16.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=13 row-size=4B cardinality=100.00K |
| | | in pipelines: 14(GETNEXT) |
| | | |
| | 16: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: RF006[bloom] <- d_date_sk |
| | | mem-estimate=1.94MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | | tuple-ids=12,14 row-size=24B cardinality=2.35M |
| | | in pipelines: 13(GETNEXT), 15(OPEN) |
| | | |
| | |--53:EXCHANGE [BROADCAST] |
| | | | mem-estimate=23.65KB mem-reservation=0B thread-reservation=0 |
| | | | tuple-ids=14 row-size=8B cardinality=1.49K |
| | | | in pipelines: 15(GETNEXT) |
| | | | |
| | | F04:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | | Per-Host Resources: mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=2 |
| | | 15:SCAN HDFS [tpcds_parquet.date_dim, RANDOM] |
| | | HDFS partitions=1/1 files=1 size=2.15MB |
| | | predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 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 IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | parquet dictionary predicates: d_year IN (CAST(2000 AS INT), CAST(2001 AS INT), CAST(2002 AS INT), CAST(2003 AS INT)) |
| | | mem-estimate=32.00MB mem-reservation=512.00KB thread-reservation=1 |
| | | tuple-ids=14 row-size=8B cardinality=1.49K |
| | | in pipelines: 15(GETNEXT) |
| | | |
| | 13:SCAN HDFS [tpcds_parquet.store_sales, RANDOM] |
| | HDFS partitions=1824/1824 files=1824 size=200.95MB |
| | runtime filters: RF006[bloom] -> ss_sold_date_sk, 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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| | tuple-ids=12 row-size=16B cardinality=2.88M |
| | in pipelines: 13(GETNEXT) |
| | |
| 52:AGGREGATE [FINALIZE] |
| | output: sum:merge(ss_quantity * ss_sales_price) |
| | group by: c_customer_sk |
| | mem-estimate=10.00MB mem-reservation=1.94MB spill-buffer=64.00KB thread-reservation=0 |
| | tuple-ids=10 row-size=20B cardinality=100.00K |
| | in pipelines: 52(GETNEXT), 09(OPEN) |
| | |
| 51:EXCHANGE [HASH(c_customer_sk)] |
| | mem-estimate=723.04KB mem-reservation=0B thread-reservation=0 |
| | tuple-ids=10 row-size=20B cardinality=100.00K |
| | in pipelines: 09(GETNEXT) |
| | |
| F00:PLAN FRAGMENT [RANDOM] hosts=3 instances=3 |
| Per-Host Resources: mem-estimate=62.33MB mem-reservation=7.94MB thread-reservation=2 runtime-filters-memory=2.00MB |
| 12:AGGREGATE [STREAMING] |
| | output: sum(CAST(ss_quantity AS DECIMAL(10,0)) * ss_sales_price) |
| | group by: c_customer_sk |
| | mem-estimate=10.00MB mem-reservation=3.00MB spill-buffer=128.00KB thread-reservation=0 |
| | tuple-ids=10 row-size=20B cardinality=100.00K |
| | in pipelines: 09(GETNEXT) |
| | |
| 11:HASH JOIN [INNER JOIN, BROADCAST] |
| | 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=8,9 row-size=16B cardinality=2.88M |
| | in pipelines: 09(GETNEXT), 10(OPEN) |
| | |
| |--50:EXCHANGE [BROADCAST] |
| | | mem-estimate=398.62KB mem-reservation=0B thread-reservation=0 |
| | | tuple-ids=9 row-size=4B cardinality=100.00K |
| | | in pipelines: 10(GETNEXT) |
| | | |
| | F01:PLAN FRAGMENT [RANDOM] hosts=1 instances=1 |
| | Per-Host Resources: mem-estimate=17.00MB mem-reservation=1.50MB thread-reservation=2 runtime-filters-memory=1.00MB |
| | 10:SCAN HDFS [tpcds_parquet.customer, RANDOM] |
| | HDFS partitions=1/1 files=1 size=5.49MB |
| | runtime filters: RF000[bloom] -> tpcds_parquet.customer.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=16.00MB mem-reservation=512.00KB thread-reservation=1 |
| | tuple-ids=9 row-size=4B cardinality=100.00K |
| | in pipelines: 10(GETNEXT) |
| | |
| 09:SCAN HDFS [tpcds_parquet.store_sales, RANDOM] |
| HDFS partitions=1824/1824 files=1824 size=200.95MB |
| runtime filters: RF000[bloom] -> tpcds_parquet.store_sales.ss_customer_sk, RF002[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=48.00MB mem-reservation=1.00MB thread-reservation=1 |
| tuple-ids=8 row-size=12B cardinality=2.88M |
| in pipelines: 09(GETNEXT) |
| ==== |