Repository: incubator-impala Updated Branches: refs/heads/master db5de41a8 -> 05b91a973
http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/1a5c43ef/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test index 492f7a4..4de9722 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpcds-all.test @@ -700,7 +700,7 @@ limit 100 | |--00:SCAN HDFS [tpcds.date_dim] | partitions=1/1 files=1 size=9.84MB -| predicates: d_year = 1999, d_moy = 11, tpcds.date_dim.d_date_sk >= 2451484, tpcds.date_dim.d_date_sk <= 2451513 +| predicates: d_year = 1999, d_moy = 11, tpcds.date_dim.d_date_sk <= 2451513, tpcds.date_dim.d_date_sk >= 2451484 | 08:HASH JOIN [INNER JOIN] | hash predicates: ss_item_sk = i_item_sk @@ -765,7 +765,7 @@ limit 100 | | | 00:SCAN HDFS [tpcds.date_dim] | partitions=1/1 files=1 size=9.84MB -| predicates: d_year = 1999, d_moy = 11, tpcds.date_dim.d_date_sk >= 2451484, tpcds.date_dim.d_date_sk <= 2451513 +| predicates: d_year = 1999, d_moy = 11, tpcds.date_dim.d_date_sk <= 2451513, tpcds.date_dim.d_date_sk >= 2451484 | 08:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: ss_item_sk = i_item_sk @@ -844,7 +844,7 @@ limit 100 | | | 00:SCAN HDFS [tpcds.date_dim] | partitions=1/1 files=1 size=9.84MB -| predicates: d_year = 1999, d_moy = 11, tpcds.date_dim.d_date_sk >= 2451484, tpcds.date_dim.d_date_sk <= 2451513 +| predicates: d_year = 1999, d_moy = 11, tpcds.date_dim.d_date_sk <= 2451513, tpcds.date_dim.d_date_sk >= 2451484 | 08:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: ss_item_sk = i_item_sk @@ -1161,7 +1161,7 @@ limit 100000 |--07:AGGREGATE [FINALIZE] | | output: count(*) | | group by: ss_ticket_number, ss_customer_sk -| | having: count(*) >= 15, count(*) <= 20 +| | having: count(*) <= 20, count(*) >= 15 | | | 06:HASH JOIN [INNER JOIN] | | hash predicates: store_sales.ss_store_sk = store.s_store_sk @@ -1211,7 +1211,7 @@ limit 100000 | 15:AGGREGATE [FINALIZE] | | output: count:merge(*) | | group by: ss_ticket_number, ss_customer_sk -| | having: count(*) >= 15, count(*) <= 20 +| | having: count(*) <= 20, count(*) >= 15 | | | 14:EXCHANGE [HASH(ss_ticket_number,ss_customer_sk)] | | @@ -1277,7 +1277,7 @@ limit 100000 | 15:AGGREGATE [FINALIZE] | | output: count:merge(*) | | group by: ss_ticket_number, ss_customer_sk -| | having: count(*) >= 15, count(*) <= 20 +| | having: count(*) <= 20, count(*) >= 15 | | | 14:EXCHANGE [HASH(ss_ticket_number,ss_customer_sk)] | | @@ -2525,7 +2525,7 @@ limit 100 | | | |--13:SCAN HDFS [tpcds.date_dim d] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_month_seq >= 1185 + 12, d_month_seq <= 1185 + 23 +| | predicates: d_month_seq <= 1185 + 23, d_month_seq >= 1185 + 12 | | | 11:AGGREGATE [FINALIZE] | | output: sum(CASE WHEN (d_day_name = 'Sunday') THEN ss_sales_price ELSE NULL END), sum(CASE WHEN (d_day_name = 'Monday') THEN ss_sales_price ELSE NULL END), sum(CASE WHEN (d_day_name = 'Tuesday') THEN ss_sales_price ELSE NULL END), sum(CASE WHEN (d_day_name = 'Wednesday') THEN ss_sales_price ELSE NULL END), sum(CASE WHEN (d_day_name = 'Thursday') THEN ss_sales_price ELSE NULL END), sum(CASE WHEN (d_day_name = 'Friday') THEN ss_sales_price ELSE NULL END), sum(CASE WHEN (d_day_name = 'Saturday') THEN ss_sales_price ELSE NULL END) @@ -2606,7 +2606,7 @@ limit 100 | | | | | 13:SCAN HDFS [tpcds.date_dim d] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_month_seq >= 1185 + 12, d_month_seq <= 1185 + 23 +| | predicates: d_month_seq <= 1185 + 23, d_month_seq >= 1185 + 12 | | | 27:AGGREGATE [FINALIZE] | | output: sum:merge(CASE WHEN (d_day_name = 'Sunday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Monday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Tuesday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Wednesday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Thursday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Friday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Saturday') THEN ss_sales_price ELSE NULL END) @@ -2725,7 +2725,7 @@ limit 100 | | | | | 13:SCAN HDFS [tpcds.date_dim d] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_month_seq >= 1185 + 12, d_month_seq <= 1185 + 23 +| | predicates: d_month_seq <= 1185 + 23, d_month_seq >= 1185 + 12 | | | 27:AGGREGATE [FINALIZE] | | output: sum:merge(CASE WHEN (d_day_name = 'Sunday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Monday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Tuesday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Wednesday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Thursday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Friday') THEN ss_sales_price ELSE NULL END), sum:merge(CASE WHEN (d_day_name = 'Saturday') THEN ss_sales_price ELSE NULL END) @@ -2897,7 +2897,7 @@ limit 100 | 02:SCAN HDFS [tpcds.date_dim] partitions=1/1 files=1 size=9.84MB - predicates: tpcds.date_dim.d_date_sk >= 2451911, tpcds.date_dim.d_date_sk <= 2452275, d_month_seq IN (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212 + 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11) + predicates: tpcds.date_dim.d_date_sk <= 2452275, tpcds.date_dim.d_date_sk >= 2451911, d_month_seq IN (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212 + 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11) runtime filters: RF001 -> d_date_sk ---- DISTRIBUTEDPLAN 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -2958,7 +2958,7 @@ limit 100 | 02:SCAN HDFS [tpcds.date_dim] partitions=1/1 files=1 size=9.84MB - predicates: tpcds.date_dim.d_date_sk >= 2451911, tpcds.date_dim.d_date_sk <= 2452275, d_month_seq IN (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212 + 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11) + predicates: tpcds.date_dim.d_date_sk <= 2452275, tpcds.date_dim.d_date_sk >= 2451911, d_month_seq IN (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212 + 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11) runtime filters: RF001 -> d_date_sk ---- PARALLELPLANS 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -3031,7 +3031,7 @@ limit 100 | 02:SCAN HDFS [tpcds.date_dim] partitions=1/1 files=1 size=9.84MB - predicates: tpcds.date_dim.d_date_sk >= 2451911, tpcds.date_dim.d_date_sk <= 2452275, d_month_seq IN (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212 + 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11) + predicates: tpcds.date_dim.d_date_sk <= 2452275, tpcds.date_dim.d_date_sk >= 2451911, d_month_seq IN (1212, 1212 + 1, 1212 + 2, 1212 + 3, 1212 + 4, 1212 + 5, 1212 + 6, 1212 + 7, 1212 + 8, 1212 + 9, 1212 + 10, 1212 + 11) runtime filters: RF001 -> d_date_sk ==== # TPCDS-Q65 @@ -3444,7 +3444,7 @@ limit 100 | | | |--01:SCAN HDFS [tpcds.date_dim] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_date >= '1999-01-01', d_date <= '1999-03-31' +| | predicates: d_date <= '1999-03-31', d_date >= '1999-01-01' | | | 05:HASH JOIN [INNER JOIN] | | hash predicates: store_sales.ss_hdemo_sk = household_demographics.hd_demo_sk @@ -3522,7 +3522,7 @@ limit 100 | | | | | 01:SCAN HDFS [tpcds.date_dim] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_date >= '1999-01-01', d_date <= '1999-03-31' +| | predicates: d_date <= '1999-03-31', d_date >= '1999-01-01' | | | 05:HASH JOIN [INNER JOIN, BROADCAST] | | hash predicates: store_sales.ss_hdemo_sk = household_demographics.hd_demo_sk @@ -3622,7 +3622,7 @@ limit 100 | | | | | 01:SCAN HDFS [tpcds.date_dim] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_date >= '1999-01-01', d_date <= '1999-03-31' +| | predicates: d_date <= '1999-03-31', d_date >= '1999-01-01' | | | 05:HASH JOIN [INNER JOIN, BROADCAST] | | hash predicates: store_sales.ss_hdemo_sk = household_demographics.hd_demo_sk @@ -3695,7 +3695,7 @@ limit 1000 |--07:AGGREGATE [FINALIZE] | | output: count(*) | | group by: ss_ticket_number, ss_customer_sk -| | having: count(*) >= 1, count(*) <= 5 +| | having: count(*) <= 5, count(*) >= 1 | | | 06:HASH JOIN [INNER JOIN] | | hash predicates: store_sales.ss_store_sk = store.s_store_sk @@ -3744,7 +3744,7 @@ limit 1000 | 16:AGGREGATE [FINALIZE] | | output: count:merge(*) | | group by: ss_ticket_number, ss_customer_sk -| | having: count(*) >= 1, count(*) <= 5 +| | having: count(*) <= 5, count(*) >= 1 | | | 15:EXCHANGE [HASH(ss_ticket_number,ss_customer_sk)] | | @@ -3811,7 +3811,7 @@ limit 1000 | 16:AGGREGATE [FINALIZE] | | output: count:merge(*) | | group by: ss_ticket_number, ss_customer_sk -| | having: count(*) >= 1, count(*) <= 5 +| | having: count(*) <= 5, count(*) >= 1 | | | 15:EXCHANGE [HASH(ss_ticket_number,ss_customer_sk)] | | @@ -3931,7 +3931,7 @@ limit 100 | | | |--01:SCAN HDFS [tpcds.date_dim] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_date >= '1999-01-01', d_date <= '1999-03-31' +| | predicates: d_date <= '1999-03-31', d_date >= '1999-01-01' | | | 05:HASH JOIN [INNER JOIN] | | hash predicates: store_sales.ss_store_sk = store.s_store_sk @@ -3939,7 +3939,7 @@ limit 100 | | | |--02:SCAN HDFS [tpcds.store] | | partitions=1/1 files=1 size=3.08KB -| | predicates: store.s_number_employees >= 200, store.s_number_employees <= 295 +| | predicates: store.s_number_employees <= 295, store.s_number_employees >= 200 | | | 04:HASH JOIN [INNER JOIN] | | hash predicates: store_sales.ss_hdemo_sk = household_demographics.hd_demo_sk @@ -3988,7 +3988,7 @@ limit 100 | | | | | 01:SCAN HDFS [tpcds.date_dim] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_date >= '1999-01-01', d_date <= '1999-03-31' +| | predicates: d_date <= '1999-03-31', d_date >= '1999-01-01' | | | 13:EXCHANGE [HASH(store_sales.ss_sold_date_sk)] | | @@ -4000,7 +4000,7 @@ limit 100 | | | | | 02:SCAN HDFS [tpcds.store] | | partitions=1/1 files=1 size=3.08KB -| | predicates: store.s_number_employees >= 200, store.s_number_employees <= 295 +| | predicates: store.s_number_employees <= 295, store.s_number_employees >= 200 | | | 04:HASH JOIN [INNER JOIN, BROADCAST] | | hash predicates: store_sales.ss_hdemo_sk = household_demographics.hd_demo_sk @@ -4059,7 +4059,7 @@ limit 100 | | | | | 01:SCAN HDFS [tpcds.date_dim] | | partitions=1/1 files=1 size=9.84MB -| | predicates: d_date >= '1999-01-01', d_date <= '1999-03-31' +| | predicates: d_date <= '1999-03-31', d_date >= '1999-01-01' | | | 13:EXCHANGE [HASH(store_sales.ss_sold_date_sk)] | | @@ -4075,7 +4075,7 @@ limit 100 | | | | | 02:SCAN HDFS [tpcds.store] | | partitions=1/1 files=1 size=3.08KB -| | predicates: store.s_number_employees >= 200, store.s_number_employees <= 295 +| | predicates: store.s_number_employees <= 295, store.s_number_employees >= 200 | | | 04:HASH JOIN [INNER JOIN, BROADCAST] | | hash predicates: store_sales.ss_hdemo_sk = household_demographics.hd_demo_sk @@ -4159,7 +4159,7 @@ limit 100) tmp2 | |--02:SCAN HDFS [tpcds.date_dim] | partitions=1/1 files=1 size=9.84MB -| predicates: d_year IN (2000), tpcds.date_dim.d_date_sk >= 2451545, tpcds.date_dim.d_date_sk <= 2451910 +| predicates: d_year IN (2000), tpcds.date_dim.d_date_sk <= 2451910, tpcds.date_dim.d_date_sk >= 2451545 | 04:HASH JOIN [INNER JOIN] | hash predicates: ss_item_sk = i_item_sk @@ -4217,7 +4217,7 @@ limit 100) tmp2 | | | 02:SCAN HDFS [tpcds.date_dim] | partitions=1/1 files=1 size=9.84MB -| predicates: d_year IN (2000), tpcds.date_dim.d_date_sk >= 2451545, tpcds.date_dim.d_date_sk <= 2451910 +| predicates: d_year IN (2000), tpcds.date_dim.d_date_sk <= 2451910, tpcds.date_dim.d_date_sk >= 2451545 | 04:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: ss_item_sk = i_item_sk @@ -4285,7 +4285,7 @@ limit 100) tmp2 | | | 02:SCAN HDFS [tpcds.date_dim] | partitions=1/1 files=1 size=9.84MB -| predicates: d_year IN (2000), tpcds.date_dim.d_date_sk >= 2451545, tpcds.date_dim.d_date_sk <= 2451910 +| predicates: d_year IN (2000), tpcds.date_dim.d_date_sk <= 2451910, tpcds.date_dim.d_date_sk >= 2451545 | 04:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: ss_item_sk = i_item_sk @@ -4512,7 +4512,7 @@ limit 1000 | 02:SCAN HDFS [tpcds.date_dim] partitions=1/1 files=1 size=9.84MB - predicates: tpcds.date_dim.d_date_sk >= 2451911, tpcds.date_dim.d_date_sk <= 2451941, d_date >= '2001-01-01', d_date <= '2001-01-31' + predicates: tpcds.date_dim.d_date_sk <= 2451941, tpcds.date_dim.d_date_sk >= 2451911, d_date <= '2001-01-31', d_date >= '2001-01-01' runtime filters: RF000 -> d_date_sk ---- DISTRIBUTEDPLAN 13:MERGING-EXCHANGE [UNPARTITIONED] @@ -4561,7 +4561,7 @@ limit 1000 | 02:SCAN HDFS [tpcds.date_dim] partitions=1/1 files=1 size=9.84MB - predicates: tpcds.date_dim.d_date_sk >= 2451911, tpcds.date_dim.d_date_sk <= 2451941, d_date >= '2001-01-01', d_date <= '2001-01-31' + predicates: tpcds.date_dim.d_date_sk <= 2451941, tpcds.date_dim.d_date_sk >= 2451911, d_date <= '2001-01-31', d_date >= '2001-01-01' runtime filters: RF000 -> d_date_sk ---- PARALLELPLANS 13:MERGING-EXCHANGE [UNPARTITIONED] @@ -4618,7 +4618,7 @@ limit 1000 | 02:SCAN HDFS [tpcds.date_dim] partitions=1/1 files=1 size=9.84MB - predicates: tpcds.date_dim.d_date_sk >= 2451911, tpcds.date_dim.d_date_sk <= 2451941, d_date >= '2001-01-01', d_date <= '2001-01-31' + predicates: tpcds.date_dim.d_date_sk <= 2451941, tpcds.date_dim.d_date_sk >= 2451911, d_date <= '2001-01-31', d_date >= '2001-01-01' runtime filters: RF000 -> d_date_sk ==== # TPCD-Q6 http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/1a5c43ef/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test index 7864153..fc6f4e2 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test @@ -124,8 +124,8 @@ limit 100 | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC | 17:HASH JOIN [RIGHT SEMI JOIN] -| hash predicates: min(ps_supplycost) = ps_supplycost, ps_partkey = p_partkey -| runtime filters: RF001 <- p_partkey +| hash predicates: ps_partkey = p_partkey, min(ps_supplycost) = ps_supplycost +| runtime filters: RF000 <- p_partkey | |--16:HASH JOIN [INNER JOIN] | | hash predicates: n_regionkey = r_regionkey @@ -193,7 +193,7 @@ limit 100 | 05:SCAN HDFS [tpch.partsupp] partitions=1/1 files=1 size=112.71MB - runtime filters: RF001 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey + runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey ---- DISTRIBUTEDPLAN 30:MERGING-EXCHANGE [UNPARTITIONED] | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC @@ -203,10 +203,10 @@ limit 100 | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC | 17:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED] -| hash predicates: min(ps_supplycost) = ps_supplycost, ps_partkey = p_partkey -| runtime filters: RF001 <- p_partkey +| hash predicates: ps_partkey = p_partkey, min(ps_supplycost) = ps_supplycost +| runtime filters: RF000 <- p_partkey | -|--29:EXCHANGE [HASH(ps_supplycost,p_partkey)] +|--29:EXCHANGE [HASH(p_partkey,ps_supplycost)] | | | 16:HASH JOIN [INNER JOIN, BROADCAST] | | hash predicates: n_regionkey = r_regionkey @@ -252,7 +252,7 @@ limit 100 | partitions=1/1 files=1 size=1.33MB | runtime filters: RF006 -> s_nationkey, RF007 -> s_suppkey | -28:EXCHANGE [HASH(min(ps_supplycost),ps_partkey)] +28:EXCHANGE [HASH(ps_partkey,min(ps_supplycost))] | 23:AGGREGATE [FINALIZE] | output: min:merge(ps_supplycost) @@ -296,7 +296,7 @@ limit 100 | 05:SCAN HDFS [tpch.partsupp] partitions=1/1 files=1 size=112.71MB - runtime filters: RF001 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey + runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey ---- PARALLELPLANS 30:MERGING-EXCHANGE [UNPARTITIONED] | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC @@ -306,14 +306,14 @@ limit 100 | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC | 17:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED] -| hash predicates: min(ps_supplycost) = ps_supplycost, ps_partkey = p_partkey -| runtime filters: RF001 <- p_partkey +| hash predicates: ps_partkey = p_partkey, min(ps_supplycost) = ps_supplycost +| runtime filters: RF000 <- p_partkey | |--JOIN BUILD | | join-table-id=00 plan-id=01 cohort-id=01 -| | build expressions: ps_supplycost, p_partkey +| | build expressions: p_partkey, ps_supplycost | | -| 29:EXCHANGE [HASH(ps_supplycost,p_partkey)] +| 29:EXCHANGE [HASH(p_partkey,ps_supplycost)] | | | 16:HASH JOIN [INNER JOIN, BROADCAST] | | hash predicates: n_regionkey = r_regionkey @@ -375,7 +375,7 @@ limit 100 | partitions=1/1 files=1 size=1.33MB | runtime filters: RF006 -> s_nationkey, RF007 -> s_suppkey | -28:EXCHANGE [HASH(min(ps_supplycost),ps_partkey)] +28:EXCHANGE [HASH(ps_partkey,min(ps_supplycost))] | 23:AGGREGATE [FINALIZE] | output: min:merge(ps_supplycost) @@ -431,7 +431,7 @@ limit 100 | 05:SCAN HDFS [tpch.partsupp] partitions=1/1 files=1 size=112.71MB - runtime filters: RF001 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey + runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey ==== # TPCH-Q3 # Q3 - Shipping Priority Query @@ -619,7 +619,7 @@ order by | |--00:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1993-07-01', o_orderdate < '1993-10-01' +| predicates: o_orderdate < '1993-10-01', o_orderdate >= '1993-07-01' | 01:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB @@ -650,7 +650,7 @@ order by | | | 00:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1993-07-01', o_orderdate < '1993-10-01' +| predicates: o_orderdate < '1993-10-01', o_orderdate >= '1993-07-01' | 05:EXCHANGE [HASH(l_orderkey)] | @@ -687,7 +687,7 @@ order by | | | 00:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1993-07-01', o_orderdate < '1993-10-01' +| predicates: o_orderdate < '1993-10-01', o_orderdate >= '1993-07-01' | 05:EXCHANGE [HASH(l_orderkey)] | @@ -747,8 +747,8 @@ order by | runtime filters: RF000 -> n_regionkey | 08:HASH JOIN [INNER JOIN] -| hash predicates: l_suppkey = s_suppkey, c_nationkey = s_nationkey -| runtime filters: RF002 <- s_suppkey, RF003 <- s_nationkey +| hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey +| runtime filters: RF002 <- s_nationkey, RF003 <- s_suppkey | |--03:SCAN HDFS [tpch.supplier] | partitions=1/1 files=1 size=1.33MB @@ -760,7 +760,7 @@ order by | |--00:SCAN HDFS [tpch.customer] | partitions=1/1 files=1 size=23.08MB -| runtime filters: RF001 -> tpch.customer.c_nationkey, RF003 -> c_nationkey +| runtime filters: RF001 -> tpch.customer.c_nationkey, RF002 -> c_nationkey | 06:HASH JOIN [INNER JOIN] | hash predicates: l_orderkey = o_orderkey @@ -768,12 +768,12 @@ order by | |--01:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01' +| predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01' | runtime filters: RF004 -> o_custkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF002 -> l_suppkey, RF005 -> l_orderkey + runtime filters: RF003 -> l_suppkey, RF005 -> l_orderkey ---- DISTRIBUTEDPLAN 20:MERGING-EXCHANGE [UNPARTITIONED] | order by: sum(l_extendedprice * (1 - l_discount)) DESC @@ -812,8 +812,8 @@ order by | runtime filters: RF000 -> n_regionkey | 08:HASH JOIN [INNER JOIN, BROADCAST] -| hash predicates: l_suppkey = s_suppkey, c_nationkey = s_nationkey -| runtime filters: RF002 <- s_suppkey, RF003 <- s_nationkey +| hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey +| runtime filters: RF002 <- s_nationkey, RF003 <- s_suppkey | |--15:EXCHANGE [BROADCAST] | | @@ -829,7 +829,7 @@ order by | | | 00:SCAN HDFS [tpch.customer] | partitions=1/1 files=1 size=23.08MB -| runtime filters: RF001 -> tpch.customer.c_nationkey, RF003 -> c_nationkey +| runtime filters: RF001 -> tpch.customer.c_nationkey, RF002 -> c_nationkey | 06:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: l_orderkey = o_orderkey @@ -839,12 +839,12 @@ order by | | | 01:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01' +| predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01' | runtime filters: RF004 -> o_custkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF002 -> l_suppkey, RF005 -> l_orderkey + runtime filters: RF003 -> l_suppkey, RF005 -> l_orderkey ---- PARALLELPLANS 20:MERGING-EXCHANGE [UNPARTITIONED] | order by: sum(l_extendedprice * (1 - l_discount)) DESC @@ -891,12 +891,12 @@ order by | runtime filters: RF000 -> n_regionkey | 08:HASH JOIN [INNER JOIN, BROADCAST] -| hash predicates: l_suppkey = s_suppkey, c_nationkey = s_nationkey -| runtime filters: RF002 <- s_suppkey, RF003 <- s_nationkey +| hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey +| runtime filters: RF002 <- s_nationkey, RF003 <- s_suppkey | |--JOIN BUILD | | join-table-id=02 plan-id=03 cohort-id=01 -| | build expressions: s_suppkey, s_nationkey +| | build expressions: s_nationkey, s_suppkey | | | 15:EXCHANGE [BROADCAST] | | @@ -916,7 +916,7 @@ order by | | | 00:SCAN HDFS [tpch.customer] | partitions=1/1 files=1 size=23.08MB -| runtime filters: RF001 -> tpch.customer.c_nationkey, RF003 -> c_nationkey +| runtime filters: RF001 -> tpch.customer.c_nationkey, RF002 -> c_nationkey | 06:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: l_orderkey = o_orderkey @@ -930,12 +930,12 @@ order by | | | 01:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01' +| predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01' | runtime filters: RF004 -> o_custkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF002 -> l_suppkey, RF005 -> l_orderkey + runtime filters: RF003 -> l_suppkey, RF005 -> l_orderkey ==== # TPCH-Q6 # Q6 - Forecasting Revenue Change Query @@ -954,7 +954,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_discount >= 0.05, l_discount <= 0.07, l_quantity < 24, l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' + predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' ---- DISTRIBUTEDPLAN 03:AGGREGATE [FINALIZE] | output: sum:merge(l_extendedprice * l_discount) @@ -966,7 +966,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_discount >= 0.05, l_discount <= 0.07, l_quantity < 24, l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' + predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' ---- PARALLELPLANS 03:AGGREGATE [FINALIZE] | output: sum:merge(l_extendedprice * l_discount) @@ -978,7 +978,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_discount >= 0.05, l_discount <= 0.07, l_quantity < 24, l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' + predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' ==== # TPCH-Q7 # Q7 - Volume Shipping Query @@ -1069,7 +1069,7 @@ order by | 01:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1995-01-01', l_shipdate <= '1996-12-31' + predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01' runtime filters: RF003 -> l_suppkey, RF004 -> l_orderkey ---- DISTRIBUTEDPLAN 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -1141,7 +1141,7 @@ order by | 01:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1995-01-01', l_shipdate <= '1996-12-31' + predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01' runtime filters: RF003 -> l_suppkey, RF004 -> l_orderkey ---- PARALLELPLANS 21:MERGING-EXCHANGE [UNPARTITIONED] @@ -1233,7 +1233,7 @@ order by | 01:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1995-01-01', l_shipdate <= '1996-12-31' + predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01' runtime filters: RF003 -> l_suppkey, RF004 -> l_orderkey ==== # TPCH-Q8 @@ -1336,7 +1336,7 @@ order by | | | 03:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31' +| predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01' | runtime filters: RF005 -> o_orderkey | 04:SCAN HDFS [tpch.customer] @@ -1430,7 +1430,7 @@ order by | | | 03:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31' +| predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01' | runtime filters: RF005 -> o_orderkey | 04:SCAN HDFS [tpch.customer] @@ -1552,7 +1552,7 @@ order by | | | 03:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31' +| predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01' | runtime filters: RF005 -> o_orderkey | 04:SCAN HDFS [tpch.customer] @@ -1608,8 +1608,8 @@ order by | partitions=1/1 files=1 size=2.15KB | 09:HASH JOIN [INNER JOIN] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey -| runtime filters: RF001 <- ps_suppkey, RF002 <- ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey +| runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey | |--03:SCAN HDFS [tpch.partsupp] | partitions=1/1 files=1 size=112.71MB @@ -1620,7 +1620,7 @@ order by | |--01:SCAN HDFS [tpch.supplier] | partitions=1/1 files=1 size=1.33MB -| runtime filters: RF000 -> s_nationkey, RF001 -> tpch.supplier.s_suppkey +| runtime filters: RF000 -> s_nationkey, RF002 -> tpch.supplier.s_suppkey | 07:HASH JOIN [INNER JOIN] | hash predicates: l_orderkey = o_orderkey @@ -1636,11 +1636,11 @@ order by |--00:SCAN HDFS [tpch.part] | partitions=1/1 files=1 size=22.83MB | predicates: p_name LIKE '%green%' -| runtime filters: RF002 -> tpch.part.p_partkey +| runtime filters: RF001 -> tpch.part.p_partkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF001 -> l_suppkey, RF002 -> l_partkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey + runtime filters: RF001 -> l_partkey, RF002 -> l_suppkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey ---- DISTRIBUTEDPLAN 21:MERGING-EXCHANGE [UNPARTITIONED] | order by: nation ASC, o_year DESC @@ -1668,8 +1668,8 @@ order by | partitions=1/1 files=1 size=2.15KB | 09:HASH JOIN [INNER JOIN, BROADCAST] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey -| runtime filters: RF001 <- ps_suppkey, RF002 <- ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey +| runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey | |--17:EXCHANGE [BROADCAST] | | @@ -1684,7 +1684,7 @@ order by | | | 01:SCAN HDFS [tpch.supplier] | partitions=1/1 files=1 size=1.33MB -| runtime filters: RF000 -> s_nationkey, RF001 -> tpch.supplier.s_suppkey +| runtime filters: RF000 -> s_nationkey, RF002 -> tpch.supplier.s_suppkey | 07:HASH JOIN [INNER JOIN, PARTITIONED] | hash predicates: l_orderkey = o_orderkey @@ -1706,11 +1706,11 @@ order by | 00:SCAN HDFS [tpch.part] | partitions=1/1 files=1 size=22.83MB | predicates: p_name LIKE '%green%' -| runtime filters: RF002 -> tpch.part.p_partkey +| runtime filters: RF001 -> tpch.part.p_partkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF001 -> l_suppkey, RF002 -> l_partkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey + runtime filters: RF001 -> l_partkey, RF002 -> l_suppkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey ---- PARALLELPLANS 21:MERGING-EXCHANGE [UNPARTITIONED] | order by: nation ASC, o_year DESC @@ -1742,12 +1742,12 @@ order by | partitions=1/1 files=1 size=2.15KB | 09:HASH JOIN [INNER JOIN, BROADCAST] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey -| runtime filters: RF001 <- ps_suppkey, RF002 <- ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey +| runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey | |--JOIN BUILD | | join-table-id=01 plan-id=02 cohort-id=01 -| | build expressions: ps_suppkey, ps_partkey +| | build expressions: ps_partkey, ps_suppkey | | | 17:EXCHANGE [BROADCAST] | | @@ -1766,7 +1766,7 @@ order by | | | 01:SCAN HDFS [tpch.supplier] | partitions=1/1 files=1 size=1.33MB -| runtime filters: RF000 -> s_nationkey, RF001 -> tpch.supplier.s_suppkey +| runtime filters: RF000 -> s_nationkey, RF002 -> tpch.supplier.s_suppkey | 07:HASH JOIN [INNER JOIN, PARTITIONED] | hash predicates: l_orderkey = o_orderkey @@ -1796,11 +1796,11 @@ order by | 00:SCAN HDFS [tpch.part] | partitions=1/1 files=1 size=22.83MB | predicates: p_name LIKE '%green%' -| runtime filters: RF002 -> tpch.part.p_partkey +| runtime filters: RF001 -> tpch.part.p_partkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF001 -> l_suppkey, RF002 -> l_partkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey + runtime filters: RF001 -> l_partkey, RF002 -> l_suppkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey ==== # TPCH-Q10 # Q10 - Returned Item Reporting Query @@ -1862,7 +1862,7 @@ limit 20 | | | |--01:SCAN HDFS [tpch.orders] | | partitions=1/1 files=1 size=162.56MB -| | predicates: o_orderdate >= '1993-10-01', o_orderdate < '1994-01-01' +| | predicates: o_orderdate < '1994-01-01', o_orderdate >= '1993-10-01' | | | 02:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB @@ -1913,7 +1913,7 @@ limit 20 | | | | | 01:SCAN HDFS [tpch.orders] | | partitions=1/1 files=1 size=162.56MB -| | predicates: o_orderdate >= '1993-10-01', o_orderdate < '1994-01-01' +| | predicates: o_orderdate < '1994-01-01', o_orderdate >= '1993-10-01' | | | 02:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB @@ -1976,7 +1976,7 @@ limit 20 | | | | | 01:SCAN HDFS [tpch.orders] | | partitions=1/1 files=1 size=162.56MB -| | predicates: o_orderdate >= '1993-10-01', o_orderdate < '1994-01-01' +| | predicates: o_orderdate < '1994-01-01', o_orderdate >= '1993-10-01' | | | 02:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB @@ -2294,7 +2294,7 @@ order by | |--01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_shipdate < l_commitdate, l_receiptdate >= '1994-01-01', l_receiptdate < '1995-01-01' +| predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_receiptdate < '1995-01-01', l_receiptdate >= '1994-01-01', l_shipdate < l_commitdate | 00:SCAN HDFS [tpch.orders] partitions=1/1 files=1 size=162.56MB @@ -2324,7 +2324,7 @@ order by | | | 01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_shipdate < l_commitdate, l_receiptdate >= '1994-01-01', l_receiptdate < '1995-01-01' +| predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_receiptdate < '1995-01-01', l_receiptdate >= '1994-01-01', l_shipdate < l_commitdate | 05:EXCHANGE [HASH(o_orderkey)] | @@ -2360,7 +2360,7 @@ order by | | | 01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_shipdate < l_commitdate, l_receiptdate >= '1994-01-01', l_receiptdate < '1995-01-01' +| predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_receiptdate < '1995-01-01', l_receiptdate >= '1994-01-01', l_shipdate < l_commitdate | 05:EXCHANGE [HASH(o_orderkey)] | @@ -2518,7 +2518,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1995-09-01', l_shipdate < '1995-10-01' + predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' runtime filters: RF000 -> l_partkey ---- DISTRIBUTEDPLAN 07:AGGREGATE [FINALIZE] @@ -2542,7 +2542,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1995-09-01', l_shipdate < '1995-10-01' + predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' runtime filters: RF000 -> l_partkey ---- PARALLELPLANS 07:AGGREGATE [FINALIZE] @@ -2570,7 +2570,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1995-09-01', l_shipdate < '1995-10-01' + predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' runtime filters: RF000 -> l_partkey ==== # TPCH-Q15 @@ -2621,7 +2621,7 @@ order by | | | 03:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN] | hash predicates: s_suppkey = l_suppkey @@ -2633,7 +2633,7 @@ order by | | | 01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 00:SCAN HDFS [tpch.supplier] partitions=1/1 files=1 size=1.33MB @@ -2670,7 +2670,7 @@ order by | | | 03:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: s_suppkey = l_suppkey @@ -2690,7 +2690,7 @@ order by | | | 01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 00:SCAN HDFS [tpch.supplier] partitions=1/1 files=1 size=1.33MB @@ -2731,7 +2731,7 @@ order by | | | 03:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN, BROADCAST] | hash predicates: s_suppkey = l_suppkey @@ -2755,7 +2755,7 @@ order by | | | 01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 00:SCAN HDFS [tpch.supplier] partitions=1/1 files=1 size=1.33MB @@ -3423,9 +3423,9 @@ order by | runtime filters: RF004 -> s_nationkey | 07:HASH JOIN [RIGHT SEMI JOIN] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey | other join predicates: ps_availqty > 0.5 * sum(l_quantity) -| runtime filters: RF001 <- ps_suppkey, RF002 <- ps_partkey +| runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey | |--06:HASH JOIN [LEFT SEMI JOIN] | | hash predicates: ps_partkey = p_partkey @@ -3445,8 +3445,8 @@ order by | 04:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' - runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey + predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' + runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_partkey, RF002 -> tpch.lineitem.l_suppkey ---- DISTRIBUTEDPLAN 18:MERGING-EXCHANGE [UNPARTITIONED] | order by: s_name ASC @@ -3477,9 +3477,9 @@ order by 16:EXCHANGE [HASH(ps_suppkey)] | 07:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey | other join predicates: ps_availqty > 0.5 * sum(l_quantity) -| runtime filters: RF001 <- ps_suppkey, RF002 <- ps_partkey +| runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey | |--14:EXCHANGE [HASH(ps_partkey,ps_suppkey)] | | @@ -3509,8 +3509,8 @@ order by | 04:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' - runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey + predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' + runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_partkey, RF002 -> tpch.lineitem.l_suppkey ---- PARALLELPLANS 18:MERGING-EXCHANGE [UNPARTITIONED] | order by: s_name ASC @@ -3549,13 +3549,13 @@ order by 16:EXCHANGE [HASH(ps_suppkey)] | 07:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey | other join predicates: ps_availqty > 0.5 * sum(l_quantity) -| runtime filters: RF001 <- ps_suppkey, RF002 <- ps_partkey +| runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey | |--JOIN BUILD | | join-table-id=02 plan-id=03 cohort-id=01 -| | build expressions: ps_suppkey, ps_partkey +| | build expressions: ps_partkey, ps_suppkey | | | 14:EXCHANGE [HASH(ps_partkey,ps_suppkey)] | | @@ -3589,8 +3589,8 @@ order by | 04:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' - runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey + predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' + runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_partkey, RF002 -> tpch.lineitem.l_suppkey ==== # TPCH-Q21 # Q21 - Suppliers Who Kept Orders Waiting Query http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/1a5c43ef/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test index 5659b4b..6c70c35 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test @@ -81,7 +81,7 @@ limit 100 | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC | 17:HASH JOIN [RIGHT SEMI JOIN] -| hash predicates: min(ps_supplycost) = ps_supplycost, ps_partkey = p_partkey +| hash predicates: ps_partkey = p_partkey, min(ps_supplycost) = ps_supplycost | |--16:HASH JOIN [INNER JOIN] | | hash predicates: n_regionkey = r_regionkey @@ -261,7 +261,7 @@ order by |--04:SCAN KUDU [tpch_kudu.nation] | 08:HASH JOIN [INNER JOIN] -| hash predicates: l_suppkey = s_suppkey, c_nationkey = s_nationkey +| hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey | |--03:SCAN KUDU [tpch_kudu.supplier] | @@ -274,7 +274,7 @@ order by | hash predicates: l_orderkey = o_orderkey | |--01:SCAN KUDU [tpch_kudu.orders] -| kudu predicates: o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01' +| kudu predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01' | 02:SCAN KUDU [tpch_kudu.lineitem] ==== @@ -293,7 +293,7 @@ where | output: sum(l_extendedprice * l_discount) | 00:SCAN KUDU [tpch_kudu.lineitem] - kudu predicates: l_discount >= 0.05, l_discount <= 0.07, l_quantity < 24, l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' + kudu predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' ==== # Q7 - Volume Shipping Query select @@ -369,7 +369,7 @@ order by |--02:SCAN KUDU [tpch_kudu.orders] | 01:SCAN KUDU [tpch_kudu.lineitem] - kudu predicates: l_shipdate >= '1995-01-01', l_shipdate <= '1996-12-31' + kudu predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01' ==== # Q8 - National Market Share Query select @@ -453,7 +453,7 @@ order by | | 02:SCAN KUDU [tpch_kudu.lineitem] | | | 03:SCAN KUDU [tpch_kudu.orders] -| kudu predicates: o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31' +| kudu predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01' | 04:SCAN KUDU [tpch_kudu.customer] ==== @@ -503,7 +503,7 @@ order by |--05:SCAN KUDU [tpch_kudu.nation] | 09:HASH JOIN [INNER JOIN] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey | |--03:SCAN KUDU [tpch_kudu.partsupp] | @@ -579,7 +579,7 @@ limit 20 | | hash predicates: l_orderkey = o_orderkey | | | |--01:SCAN KUDU [tpch_kudu.orders] -| | kudu predicates: o_orderdate >= '1993-10-01', o_orderdate < '1994-01-01' +| | kudu predicates: o_orderdate < '1994-01-01', o_orderdate >= '1993-10-01' | | | 02:SCAN KUDU [tpch_kudu.lineitem] | kudu predicates: l_returnflag = 'R' @@ -702,7 +702,7 @@ order by | |--01:SCAN KUDU [tpch_kudu.lineitem] | predicates: l_shipmode IN ('MAIL', 'SHIP'), l_commitdate < l_receiptdate, l_shipdate < l_commitdate -| kudu predicates: l_receiptdate >= '1994-01-01', l_receiptdate < '1995-01-01' +| kudu predicates: l_receiptdate < '1995-01-01', l_receiptdate >= '1994-01-01' | 00:SCAN KUDU [tpch_kudu.orders] ==== @@ -771,7 +771,7 @@ where |--01:SCAN KUDU [tpch_kudu.part] | 00:SCAN KUDU [tpch_kudu.lineitem] - kudu predicates: l_shipdate >= '1995-09-01', l_shipdate < '1995-10-01' + kudu predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' ==== # Q15 - Top Supplier Query with revenue_view as ( @@ -819,7 +819,7 @@ order by | | group by: l_suppkey | | | 03:SCAN KUDU [tpch_kudu.lineitem] -| kudu predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| kudu predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN] | hash predicates: s_suppkey = l_suppkey @@ -829,7 +829,7 @@ order by | | group by: l_suppkey | | | 01:SCAN KUDU [tpch_kudu.lineitem] -| kudu predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| kudu predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 00:SCAN KUDU [tpch_kudu.supplier] ==== @@ -1095,7 +1095,7 @@ order by | 00:SCAN KUDU [tpch_kudu.supplier] | 07:HASH JOIN [RIGHT SEMI JOIN] -| hash predicates: l_suppkey = ps_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey | other join predicates: ps_availqty > 0.5 * sum(l_quantity) | |--06:HASH JOIN [LEFT SEMI JOIN] @@ -1111,7 +1111,7 @@ order by | group by: l_partkey, l_suppkey | 04:SCAN KUDU [tpch_kudu.lineitem] - kudu predicates: l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' + kudu predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' ==== # Q21 - Suppliers Who Kept Orders Waiting Query select http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/1a5c43ef/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test index 4354814..caa3420 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test @@ -100,8 +100,8 @@ limit 100 | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC | 25:HASH JOIN [LEFT SEMI JOIN] -| hash predicates: ps_supplycost = min(ps_supplycost), p_partkey = ps_partkey -| runtime filters: RF001 <- ps_partkey +| hash predicates: p_partkey = ps_partkey, ps_supplycost = min(ps_supplycost) +| runtime filters: RF000 <- ps_partkey | |--22:AGGREGATE [FINALIZE] | | output: min(ps_supplycost) @@ -158,7 +158,7 @@ limit 100 |--05:SCAN HDFS [tpch_nested_parquet.part p] | partitions=1/1 files=1 size=6.20MB | predicates: p_size = 15, p_type LIKE '%BRASS' -| runtime filters: RF001 -> p_partkey +| runtime filters: RF000 -> p_partkey | 01:SUBPLAN | @@ -181,8 +181,8 @@ limit 100 | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC | 25:HASH JOIN [LEFT SEMI JOIN, BROADCAST] -| hash predicates: ps_supplycost = min(ps_supplycost), p_partkey = ps_partkey -| runtime filters: RF001 <- ps_partkey +| hash predicates: p_partkey = ps_partkey, ps_supplycost = min(ps_supplycost) +| runtime filters: RF000 <- ps_partkey | |--32:EXCHANGE [BROADCAST] | | @@ -253,7 +253,7 @@ limit 100 | 05:SCAN HDFS [tpch_nested_parquet.part p] | partitions=1/1 files=1 size=6.20MB | predicates: p_size = 15, p_type LIKE '%BRASS' -| runtime filters: RF001 -> p_partkey +| runtime filters: RF000 -> p_partkey | 01:SUBPLAN | @@ -499,8 +499,8 @@ order by | predicates: r_name = 'ASIA', !empty(r.r_nations) | 15:HASH JOIN [INNER JOIN] -| hash predicates: l_suppkey = s_suppkey, c_nationkey = s_nationkey -| runtime filters: RF002 <- s_nationkey +| hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey +| runtime filters: RF001 <- s_nationkey | |--09:SCAN HDFS [tpch_nested_parquet.supplier s] | partitions=1/1 files=1 size=111.08MB @@ -526,7 +526,7 @@ order by partitions=1/1 files=4 size=577.87MB predicates: !empty(c.c_orders) predicates on o: !empty(o.o_lineitems), o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01' - runtime filters: RF000 -> c.c_nationkey, RF002 -> c_nationkey + runtime filters: RF000 -> c.c_nationkey, RF001 -> c_nationkey ---- DISTRIBUTEDPLAN 23:MERGING-EXCHANGE [UNPARTITIONED] | order by: sum(l_extendedprice * (1 - l_discount)) DESC @@ -563,8 +563,8 @@ order by | predicates: r_name = 'ASIA', !empty(r.r_nations) | 15:HASH JOIN [INNER JOIN, BROADCAST] -| hash predicates: l_suppkey = s_suppkey, c_nationkey = s_nationkey -| runtime filters: RF002 <- s_nationkey +| hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey +| runtime filters: RF001 <- s_nationkey | |--19:EXCHANGE [BROADCAST] | | @@ -592,7 +592,7 @@ order by partitions=1/1 files=4 size=577.87MB predicates: !empty(c.c_orders) predicates on o: !empty(o.o_lineitems), o_orderdate >= '1994-01-01', o_orderdate < '1995-01-01' - runtime filters: RF000 -> c.c_nationkey, RF002 -> c_nationkey + runtime filters: RF000 -> c.c_nationkey, RF001 -> c_nationkey ==== # TPCH-Q6 # Q6 - Forecasting Revenue Change Query @@ -610,8 +610,8 @@ where | output: sum(l_extendedprice * l_discount) | 00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems] - partitions=1/1 files=4 size=577.87MB - predicates: l_discount >= 0.05, l_discount <= 0.07, l_quantity < 24, l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' + partitions=1/1 files=4 size=292.35MB + predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' ---- DISTRIBUTEDPLAN 03:AGGREGATE [FINALIZE] | output: sum:merge(l_extendedprice * l_discount) @@ -622,8 +622,8 @@ where | output: sum(l_extendedprice * l_discount) | 00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems] - partitions=1/1 files=4 size=577.87MB - predicates: l_discount >= 0.05, l_discount <= 0.07, l_quantity < 24, l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' + partitions=1/1 files=4 size=292.35MB + predicates: l_discount <= 0.07, l_discount >= 0.05, l_quantity < 24, l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' ==== # TPCH-Q7 # Q7 - Volume Shipping Query @@ -1023,7 +1023,7 @@ order by | predicates: p_name LIKE '%green%' | 12:HASH JOIN [INNER JOIN] -| hash predicates: l_suppkey = s_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = s_suppkey | |--06:SUBPLAN | | @@ -1085,7 +1085,7 @@ order by | predicates: p_name LIKE '%green%' | 12:HASH JOIN [INNER JOIN, BROADCAST] -| hash predicates: l_suppkey = s_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = s_suppkey | |--17:EXCHANGE [BROADCAST] | | @@ -1588,7 +1588,7 @@ where | 00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] partitions=1/1 files=4 size=577.87MB - predicates: l_shipdate >= '1995-09-01', l_shipdate < '1995-10-01' + predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' runtime filters: RF000 -> l_partkey ---- DISTRIBUTEDPLAN 06:AGGREGATE [FINALIZE] @@ -1610,7 +1610,7 @@ where | 00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] partitions=1/1 files=4 size=577.87MB - predicates: l_shipdate >= '1995-09-01', l_shipdate < '1995-10-01' + predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01' runtime filters: RF000 -> l_partkey ==== # TPCH-Q15 @@ -1661,7 +1661,7 @@ order by | | | 03:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] | partitions=1/1 files=4 size=577.87MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN] | hash predicates: l_suppkey = s_suppkey @@ -1676,7 +1676,7 @@ order by | 01:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] partitions=1/1 files=4 size=577.87MB - predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' + predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' runtime filters: RF000 -> l.l_suppkey ---- DISTRIBUTEDPLAN 17:MERGING-EXCHANGE [UNPARTITIONED] @@ -1710,7 +1710,7 @@ order by | | | 03:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] | partitions=1/1 files=4 size=577.87MB -| predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' +| predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN, PARTITIONED] | hash predicates: l_suppkey = s_suppkey @@ -1733,7 +1733,7 @@ order by | 01:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] partitions=1/1 files=4 size=577.87MB - predicates: l_shipdate >= '1996-01-01', l_shipdate < '1996-04-01' + predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01' runtime filters: RF000 -> l.l_suppkey ==== # TPCH-Q16 @@ -2117,9 +2117,9 @@ order by | group by: s_name, s_address | 11:HASH JOIN [RIGHT SEMI JOIN] -| hash predicates: l_suppkey = s_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = s_suppkey | other join predicates: ps_availqty > 0.5 * sum(l_quantity) -| runtime filters: RF000 <- s_suppkey, RF001 <- ps_partkey +| runtime filters: RF000 <- ps_partkey, RF001 <- s_suppkey | |--10:HASH JOIN [LEFT SEMI JOIN] | | hash predicates: ps_partkey = p_partkey @@ -2155,8 +2155,8 @@ order by | 07:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] partitions=1/1 files=4 size=577.87MB - predicates: l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' - runtime filters: RF000 -> l.l_suppkey, RF001 -> l.l_partkey + predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' + runtime filters: RF000 -> l.l_partkey, RF001 -> l.l_suppkey ---- DISTRIBUTEDPLAN 21:MERGING-EXCHANGE [UNPARTITIONED] | order by: s_name ASC @@ -2173,9 +2173,9 @@ order by | group by: s_name, s_address | 11:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED] -| hash predicates: l_suppkey = s_suppkey, l_partkey = ps_partkey +| hash predicates: l_partkey = ps_partkey, l_suppkey = s_suppkey | other join predicates: ps_availqty > 0.5 * sum(l_quantity) -| runtime filters: RF000 <- s_suppkey, RF001 <- ps_partkey +| runtime filters: RF000 <- ps_partkey, RF001 <- s_suppkey | |--18:EXCHANGE [HASH(ps_partkey,s_suppkey)] | | @@ -2223,8 +2223,8 @@ order by | 07:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l] partitions=1/1 files=4 size=577.87MB - predicates: l_shipdate >= '1994-01-01', l_shipdate < '1995-01-01' - runtime filters: RF000 -> l.l_suppkey, RF001 -> l.l_partkey + predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01' + runtime filters: RF000 -> l.l_partkey, RF001 -> l.l_suppkey ==== # TPCH-Q21 # Q21 - Suppliers Who Kept Orders Waiting Query http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/1a5c43ef/testdata/workloads/functional-planner/queries/PlannerTest/tpch-views.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-views.test b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-views.test index 69e5ecc..96409e2 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-views.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-views.test @@ -84,8 +84,8 @@ limit 100 | order by: s_acctbal DESC, n_name ASC, s_name ASC, p_partkey ASC | 17:HASH JOIN [RIGHT SEMI JOIN] -| hash predicates: min(ps_supplycost) = tpch.partsupp.ps_supplycost, ps_partkey = tpch.part.p_partkey -| runtime filters: RF001 <- tpch.part.p_partkey +| hash predicates: ps_partkey = tpch.part.p_partkey, min(ps_supplycost) = tpch.partsupp.ps_supplycost +| runtime filters: RF000 <- tpch.part.p_partkey | |--16:HASH JOIN [INNER JOIN] | | hash predicates: tpch.nation.n_regionkey = tpch.region.r_regionkey @@ -153,7 +153,7 @@ limit 100 | 05:SCAN HDFS [tpch.partsupp] partitions=1/1 files=1 size=112.71MB - runtime filters: RF001 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey + runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey ==== # TPCH-Q3 # Q3 - Shipping Priority Query @@ -247,7 +247,7 @@ order by | |--00:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: tpch.orders.o_orderdate >= '1993-07-01', tpch.orders.o_orderdate < '1993-10-01' +| predicates: tpch.orders.o_orderdate < '1993-10-01', tpch.orders.o_orderdate >= '1993-07-01' | 01:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB @@ -305,8 +305,8 @@ order by | runtime filters: RF000 -> tpch.nation.n_regionkey | 08:HASH JOIN [INNER JOIN] -| hash predicates: tpch.lineitem.l_suppkey = tpch.supplier.s_suppkey, tpch.customer.c_nationkey = tpch.supplier.s_nationkey -| runtime filters: RF002 <- tpch.supplier.s_suppkey, RF003 <- tpch.supplier.s_nationkey +| hash predicates: tpch.customer.c_nationkey = tpch.supplier.s_nationkey, tpch.lineitem.l_suppkey = tpch.supplier.s_suppkey +| runtime filters: RF002 <- tpch.supplier.s_nationkey, RF003 <- tpch.supplier.s_suppkey | |--03:SCAN HDFS [tpch.supplier] | partitions=1/1 files=1 size=1.33MB @@ -318,7 +318,7 @@ order by | |--00:SCAN HDFS [tpch.customer] | partitions=1/1 files=1 size=23.08MB -| runtime filters: RF001 -> tpch.customer.c_nationkey, RF003 -> tpch.customer.c_nationkey +| runtime filters: RF001 -> tpch.customer.c_nationkey, RF002 -> tpch.customer.c_nationkey | 06:HASH JOIN [INNER JOIN] | hash predicates: tpch.lineitem.l_orderkey = tpch.orders.o_orderkey @@ -326,12 +326,12 @@ order by | |--01:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: tpch.orders.o_orderdate >= '1994-01-01', tpch.orders.o_orderdate < '1995-01-01' +| predicates: tpch.orders.o_orderdate < '1995-01-01', tpch.orders.o_orderdate >= '1994-01-01' | runtime filters: RF004 -> tpch.orders.o_custkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF002 -> tpch.lineitem.l_suppkey, RF005 -> tpch.lineitem.l_orderkey + runtime filters: RF003 -> tpch.lineitem.l_suppkey, RF005 -> tpch.lineitem.l_orderkey ==== # TPCH-Q6 # Q6 - Forecasting Revenue Change Query @@ -350,7 +350,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: tpch.lineitem.l_discount >= 0.05, tpch.lineitem.l_discount <= 0.07, tpch.lineitem.l_quantity < 24, tpch.lineitem.l_shipdate >= '1994-01-01', tpch.lineitem.l_shipdate < '1995-01-01' + predicates: tpch.lineitem.l_discount <= 0.07, tpch.lineitem.l_discount >= 0.05, tpch.lineitem.l_quantity < 24, tpch.lineitem.l_shipdate < '1995-01-01', tpch.lineitem.l_shipdate >= '1994-01-01' ==== # TPCH-Q7 # Q7 - Volume Shipping Query @@ -441,7 +441,7 @@ order by | 01:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: tpch.lineitem.l_shipdate >= '1995-01-01', tpch.lineitem.l_shipdate <= '1996-12-31' + predicates: tpch.lineitem.l_shipdate <= '1996-12-31', tpch.lineitem.l_shipdate >= '1995-01-01' runtime filters: RF003 -> tpch.lineitem.l_suppkey, RF004 -> tpch.lineitem.l_orderkey ==== # TPCH-Q8 @@ -544,7 +544,7 @@ order by | | | 03:SCAN HDFS [tpch.orders] | partitions=1/1 files=1 size=162.56MB -| predicates: tpch.orders.o_orderdate >= '1995-01-01', tpch.orders.o_orderdate <= '1996-12-31' +| predicates: tpch.orders.o_orderdate <= '1996-12-31', tpch.orders.o_orderdate >= '1995-01-01' | runtime filters: RF005 -> tpch.orders.o_orderkey | 04:SCAN HDFS [tpch.customer] @@ -600,8 +600,8 @@ order by | partitions=1/1 files=1 size=2.15KB | 09:HASH JOIN [INNER JOIN] -| hash predicates: tpch.lineitem.l_suppkey = tpch.partsupp.ps_suppkey, tpch.lineitem.l_partkey = tpch.partsupp.ps_partkey -| runtime filters: RF001 <- tpch.partsupp.ps_suppkey, RF002 <- tpch.partsupp.ps_partkey +| hash predicates: tpch.lineitem.l_partkey = tpch.partsupp.ps_partkey, tpch.lineitem.l_suppkey = tpch.partsupp.ps_suppkey +| runtime filters: RF001 <- tpch.partsupp.ps_partkey, RF002 <- tpch.partsupp.ps_suppkey | |--03:SCAN HDFS [tpch.partsupp] | partitions=1/1 files=1 size=112.71MB @@ -612,7 +612,7 @@ order by | |--01:SCAN HDFS [tpch.supplier] | partitions=1/1 files=1 size=1.33MB -| runtime filters: RF000 -> tpch.supplier.s_nationkey, RF001 -> tpch.supplier.s_suppkey +| runtime filters: RF000 -> tpch.supplier.s_nationkey, RF002 -> tpch.supplier.s_suppkey | 07:HASH JOIN [INNER JOIN] | hash predicates: tpch.lineitem.l_orderkey = tpch.orders.o_orderkey @@ -628,11 +628,11 @@ order by |--00:SCAN HDFS [tpch.part] | partitions=1/1 files=1 size=22.83MB | predicates: tpch.part.p_name LIKE '%green%' -| runtime filters: RF002 -> tpch.part.p_partkey +| runtime filters: RF001 -> tpch.part.p_partkey | 02:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - runtime filters: RF001 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey, RF003 -> tpch.lineitem.l_suppkey, RF004 -> tpch.lineitem.l_orderkey, RF005 -> tpch.lineitem.l_partkey + runtime filters: RF001 -> tpch.lineitem.l_partkey, RF002 -> tpch.lineitem.l_suppkey, RF003 -> tpch.lineitem.l_suppkey, RF004 -> tpch.lineitem.l_orderkey, RF005 -> tpch.lineitem.l_partkey ==== # TPCH-Q10 # Q10 - Returned Item Reporting Query @@ -694,7 +694,7 @@ limit 20 | | | |--01:SCAN HDFS [tpch.orders] | | partitions=1/1 files=1 size=162.56MB -| | predicates: tpch.orders.o_orderdate >= '1993-10-01', tpch.orders.o_orderdate < '1994-01-01' +| | predicates: tpch.orders.o_orderdate < '1994-01-01', tpch.orders.o_orderdate >= '1993-10-01' | | | 02:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB @@ -838,7 +838,7 @@ order by | |--01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: tpch.lineitem.l_shipmode IN ('MAIL', 'SHIP'), tpch.lineitem.l_commitdate < tpch.lineitem.l_receiptdate, tpch.lineitem.l_shipdate < tpch.lineitem.l_commitdate, tpch.lineitem.l_receiptdate >= '1994-01-01', tpch.lineitem.l_receiptdate < '1995-01-01' +| predicates: tpch.lineitem.l_shipmode IN ('MAIL', 'SHIP'), tpch.lineitem.l_commitdate < tpch.lineitem.l_receiptdate, tpch.lineitem.l_receiptdate < '1995-01-01', tpch.lineitem.l_receiptdate >= '1994-01-01', tpch.lineitem.l_shipdate < tpch.lineitem.l_commitdate | 00:SCAN HDFS [tpch.orders] partitions=1/1 files=1 size=162.56MB @@ -918,7 +918,7 @@ where | 00:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: tpch.lineitem.l_shipdate >= '1995-09-01', tpch.lineitem.l_shipdate < '1995-10-01' + predicates: tpch.lineitem.l_shipdate < '1995-10-01', tpch.lineitem.l_shipdate >= '1995-09-01' runtime filters: RF000 -> tpch.lineitem.l_partkey ==== # TPCH-Q15 @@ -969,7 +969,7 @@ order by | | | 03:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: tpch.lineitem.l_shipdate >= '1996-01-01', tpch.lineitem.l_shipdate < '1996-04-01' +| predicates: tpch.lineitem.l_shipdate < '1996-04-01', tpch.lineitem.l_shipdate >= '1996-01-01' | 06:HASH JOIN [INNER JOIN] | hash predicates: tpch.supplier.s_suppkey = l_suppkey @@ -981,7 +981,7 @@ order by | | | 01:SCAN HDFS [tpch.lineitem] | partitions=1/1 files=1 size=718.94MB -| predicates: tpch.lineitem.l_shipdate >= '1996-01-01', tpch.lineitem.l_shipdate < '1996-04-01' +| predicates: tpch.lineitem.l_shipdate < '1996-04-01', tpch.lineitem.l_shipdate >= '1996-01-01' | 00:SCAN HDFS [tpch.supplier] partitions=1/1 files=1 size=1.33MB @@ -1285,9 +1285,9 @@ order by | runtime filters: RF004 -> tpch.supplier.s_nationkey | 07:HASH JOIN [RIGHT SEMI JOIN] -| hash predicates: l_suppkey = tpch.partsupp.ps_suppkey, l_partkey = tpch.partsupp.ps_partkey +| hash predicates: l_partkey = tpch.partsupp.ps_partkey, l_suppkey = tpch.partsupp.ps_suppkey | other join predicates: tpch.partsupp.ps_availqty > 0.5 * sum(l_quantity) -| runtime filters: RF001 <- tpch.partsupp.ps_suppkey, RF002 <- tpch.partsupp.ps_partkey +| runtime filters: RF001 <- tpch.partsupp.ps_partkey, RF002 <- tpch.partsupp.ps_suppkey | |--06:HASH JOIN [LEFT SEMI JOIN] | | hash predicates: tpch.partsupp.ps_partkey = tpch.part.p_partkey @@ -1307,8 +1307,8 @@ order by | 04:SCAN HDFS [tpch.lineitem] partitions=1/1 files=1 size=718.94MB - predicates: tpch.lineitem.l_shipdate >= '1994-01-01', tpch.lineitem.l_shipdate < '1995-01-01' - runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey + predicates: tpch.lineitem.l_shipdate < '1995-01-01', tpch.lineitem.l_shipdate >= '1994-01-01' + runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF001 -> tpch.lineitem.l_partkey, RF002 -> tpch.lineitem.l_suppkey ==== # TPCH-Q21 # Q21 - Suppliers Who Kept Orders Waiting Query http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/1a5c43ef/testdata/workloads/functional-planner/queries/PlannerTest/union.test ---------------------------------------------------------------------- diff --git a/testdata/workloads/functional-planner/queries/PlannerTest/union.test b/testdata/workloads/functional-planner/queries/PlannerTest/union.test index 7e9549a..84053a9 100644 --- a/testdata/workloads/functional-planner/queries/PlannerTest/union.test +++ b/testdata/workloads/functional-planner/queries/PlannerTest/union.test @@ -2413,11 +2413,11 @@ where a + b < 100 and c > 20 and d > 50 | |--02:SCAN HDFS [functional.alltypes] | partitions=24/24 files=24 size=478.45KB -| predicates: functional.alltypes.smallint_col > 20, functional.alltypes.bigint_col > 50, functional.alltypes.tinyint_col + functional.alltypes.int_col < 100 +| predicates: functional.alltypes.bigint_col > 50, functional.alltypes.smallint_col > 20, functional.alltypes.tinyint_col + functional.alltypes.int_col < 100 | 01:SCAN HDFS [functional.alltypestiny] partitions=4/4 files=4 size=460B - predicates: functional.alltypestiny.int_col > 20, functional.alltypestiny.bigint_col > 50 + predicates: functional.alltypestiny.bigint_col > 50, functional.alltypestiny.int_col > 20 ==== # Test union where all operands are dropped because of constant conjuncts. select * from
