You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@impala.apache.org by ta...@apache.org on 2016/10/18 16:43:31 UTC
[08/32] incubator-impala git commit: IMPALA-3644 Make predicate order
deterministic
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