impala-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tarmstr...@apache.org
Subject [02/16] incubator-impala git commit: IMPALA-4252: Min-max runtime filters for Kudu
Date Sat, 18 Nov 2017 00:31:45 GMT
http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/2510fe0a/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 f36751d..da2c745 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-all.test
@@ -137,7 +137,7 @@ PLAN-ROOT SINK
 |
 |--16:HASH JOIN [INNER JOIN]
 |  |  hash predicates: n_regionkey = r_regionkey
-|  |  runtime filters: RF005 <- r_regionkey
+|  |  runtime filters: RF010 <- r_regionkey
 |  |
 |  |--04:SCAN HDFS [tpch.region]
 |  |     partitions=1/1 files=1 size=384B
@@ -145,19 +145,19 @@ PLAN-ROOT SINK
 |  |
 |  15:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF006 <- n_nationkey
+|  |  runtime filters: RF012 <- n_nationkey
 |  |
 |  |--03:SCAN HDFS [tpch.nation]
 |  |     partitions=1/1 files=1 size=2.15KB
-|  |     runtime filters: RF005 -> n_regionkey
+|  |     runtime filters: RF010 -> n_regionkey
 |  |
 |  14:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_suppkey = ps_suppkey
-|  |  runtime filters: RF007 <- ps_suppkey
+|  |  runtime filters: RF014 <- ps_suppkey
 |  |
 |  |--13:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: ps_partkey = p_partkey
-|  |  |  runtime filters: RF008 <- p_partkey
+|  |  |  runtime filters: RF016 <- p_partkey
 |  |  |
 |  |  |--00:SCAN HDFS [tpch.part]
 |  |  |     partitions=1/1 files=1 size=22.83MB
@@ -165,11 +165,11 @@ PLAN-ROOT SINK
 |  |  |
 |  |  02:SCAN HDFS [tpch.partsupp]
 |  |     partitions=1/1 files=1 size=112.71MB
-|  |     runtime filters: RF008 -> ps_partkey
+|  |     runtime filters: RF016 -> ps_partkey
 |  |
 |  01:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF006 -> s_nationkey, RF007 -> s_suppkey
+|     runtime filters: RF012 -> s_nationkey, RF014 -> s_suppkey
 |
 12:AGGREGATE [FINALIZE]
 |  output: min(ps_supplycost)
@@ -177,7 +177,7 @@ PLAN-ROOT SINK
 |
 11:HASH JOIN [INNER JOIN]
 |  hash predicates: n_regionkey = r_regionkey
-|  runtime filters: RF002 <- r_regionkey
+|  runtime filters: RF004 <- r_regionkey
 |
 |--08:SCAN HDFS [tpch.region]
 |     partitions=1/1 files=1 size=384B
@@ -185,23 +185,23 @@ PLAN-ROOT SINK
 |
 10:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF003 <- n_nationkey
+|  runtime filters: RF006 <- n_nationkey
 |
 |--07:SCAN HDFS [tpch.nation]
 |     partitions=1/1 files=1 size=2.15KB
-|     runtime filters: RF002 -> n_regionkey
+|     runtime filters: RF004 -> n_regionkey
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: ps_suppkey = s_suppkey
-|  runtime filters: RF004 <- s_suppkey
+|  runtime filters: RF008 <- s_suppkey
 |
 |--06:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF003 -> s_nationkey
+|     runtime filters: RF006 -> s_nationkey
 |
 05:SCAN HDFS [tpch.partsupp]
    partitions=1/1 files=1 size=112.71MB
-   runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey
+   runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF008 -> ps_suppkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -220,7 +220,7 @@ PLAN-ROOT SINK
 |  |
 |  16:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: n_regionkey = r_regionkey
-|  |  runtime filters: RF005 <- r_regionkey
+|  |  runtime filters: RF010 <- r_regionkey
 |  |
 |  |--27:EXCHANGE [BROADCAST]
 |  |  |
@@ -230,23 +230,23 @@ PLAN-ROOT SINK
 |  |
 |  15:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF006 <- n_nationkey
+|  |  runtime filters: RF012 <- n_nationkey
 |  |
 |  |--26:EXCHANGE [BROADCAST]
 |  |  |
 |  |  03:SCAN HDFS [tpch.nation]
 |  |     partitions=1/1 files=1 size=2.15KB
-|  |     runtime filters: RF005 -> n_regionkey
+|  |     runtime filters: RF010 -> n_regionkey
 |  |
 |  14:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_suppkey = ps_suppkey
-|  |  runtime filters: RF007 <- ps_suppkey
+|  |  runtime filters: RF014 <- ps_suppkey
 |  |
 |  |--25:EXCHANGE [BROADCAST]
 |  |  |
 |  |  13:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  |  hash predicates: ps_partkey = p_partkey
-|  |  |  runtime filters: RF008 <- p_partkey
+|  |  |  runtime filters: RF016 <- p_partkey
 |  |  |
 |  |  |--24:EXCHANGE [BROADCAST]
 |  |  |  |
@@ -256,11 +256,11 @@ PLAN-ROOT SINK
 |  |  |
 |  |  02:SCAN HDFS [tpch.partsupp]
 |  |     partitions=1/1 files=1 size=112.71MB
-|  |     runtime filters: RF008 -> ps_partkey
+|  |     runtime filters: RF016 -> ps_partkey
 |  |
 |  01:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF006 -> s_nationkey, RF007 -> s_suppkey
+|     runtime filters: RF012 -> s_nationkey, RF014 -> s_suppkey
 |
 28:EXCHANGE [HASH(ps_partkey,min(ps_supplycost))]
 |
@@ -276,7 +276,7 @@ PLAN-ROOT SINK
 |
 11:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: n_regionkey = r_regionkey
-|  runtime filters: RF002 <- r_regionkey
+|  runtime filters: RF004 <- r_regionkey
 |
 |--21:EXCHANGE [BROADCAST]
 |  |
@@ -286,27 +286,27 @@ PLAN-ROOT SINK
 |
 10:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF003 <- n_nationkey
+|  runtime filters: RF006 <- n_nationkey
 |
 |--20:EXCHANGE [BROADCAST]
 |  |
 |  07:SCAN HDFS [tpch.nation]
 |     partitions=1/1 files=1 size=2.15KB
-|     runtime filters: RF002 -> n_regionkey
+|     runtime filters: RF004 -> n_regionkey
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: ps_suppkey = s_suppkey
-|  runtime filters: RF004 <- s_suppkey
+|  runtime filters: RF008 <- s_suppkey
 |
 |--19:EXCHANGE [BROADCAST]
 |  |
 |  06:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF003 -> s_nationkey
+|     runtime filters: RF006 -> s_nationkey
 |
 05:SCAN HDFS [tpch.partsupp]
    partitions=1/1 files=1 size=112.71MB
-   runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey
+   runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF008 -> ps_suppkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -329,7 +329,7 @@ PLAN-ROOT SINK
 |  |
 |  16:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: n_regionkey = r_regionkey
-|  |  runtime filters: RF005 <- r_regionkey
+|  |  runtime filters: RF010 <- r_regionkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=01 plan-id=02 cohort-id=02
@@ -343,7 +343,7 @@ PLAN-ROOT SINK
 |  |
 |  15:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF006 <- n_nationkey
+|  |  runtime filters: RF012 <- n_nationkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=02 plan-id=03 cohort-id=02
@@ -353,11 +353,11 @@ PLAN-ROOT SINK
 |  |  |
 |  |  03:SCAN HDFS [tpch.nation]
 |  |     partitions=1/1 files=1 size=2.15KB
-|  |     runtime filters: RF005 -> n_regionkey
+|  |     runtime filters: RF010 -> n_regionkey
 |  |
 |  14:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_suppkey = ps_suppkey
-|  |  runtime filters: RF007 <- ps_suppkey
+|  |  runtime filters: RF014 <- ps_suppkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=03 plan-id=04 cohort-id=02
@@ -367,7 +367,7 @@ PLAN-ROOT SINK
 |  |  |
 |  |  13:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  |  hash predicates: ps_partkey = p_partkey
-|  |  |  runtime filters: RF008 <- p_partkey
+|  |  |  runtime filters: RF016 <- p_partkey
 |  |  |
 |  |  |--JOIN BUILD
 |  |  |  |  join-table-id=04 plan-id=05 cohort-id=03
@@ -381,11 +381,11 @@ PLAN-ROOT SINK
 |  |  |
 |  |  02:SCAN HDFS [tpch.partsupp]
 |  |     partitions=1/1 files=1 size=112.71MB
-|  |     runtime filters: RF008 -> ps_partkey
+|  |     runtime filters: RF016 -> ps_partkey
 |  |
 |  01:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF006 -> s_nationkey, RF007 -> s_suppkey
+|     runtime filters: RF012 -> s_nationkey, RF014 -> s_suppkey
 |
 28:EXCHANGE [HASH(ps_partkey,min(ps_supplycost))]
 |
@@ -401,7 +401,7 @@ PLAN-ROOT SINK
 |
 11:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: n_regionkey = r_regionkey
-|  runtime filters: RF002 <- r_regionkey
+|  runtime filters: RF004 <- r_regionkey
 |
 |--JOIN BUILD
 |  |  join-table-id=05 plan-id=06 cohort-id=01
@@ -415,7 +415,7 @@ PLAN-ROOT SINK
 |
 10:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF003 <- n_nationkey
+|  runtime filters: RF006 <- n_nationkey
 |
 |--JOIN BUILD
 |  |  join-table-id=06 plan-id=07 cohort-id=01
@@ -425,11 +425,11 @@ PLAN-ROOT SINK
 |  |
 |  07:SCAN HDFS [tpch.nation]
 |     partitions=1/1 files=1 size=2.15KB
-|     runtime filters: RF002 -> n_regionkey
+|     runtime filters: RF004 -> n_regionkey
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: ps_suppkey = s_suppkey
-|  runtime filters: RF004 <- s_suppkey
+|  runtime filters: RF008 <- s_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=07 plan-id=08 cohort-id=01
@@ -439,11 +439,11 @@ PLAN-ROOT SINK
 |  |
 |  06:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF003 -> s_nationkey
+|     runtime filters: RF006 -> s_nationkey
 |
 05:SCAN HDFS [tpch.partsupp]
    partitions=1/1 files=1 size=112.71MB
-   runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF004 -> ps_suppkey
+   runtime filters: RF000 -> tpch.partsupp.ps_partkey, RF008 -> ps_suppkey
 ====
 # TPCH-Q3
 # Q3 - Shipping Priority Query
@@ -490,7 +490,7 @@ PLAN-ROOT SINK
 |
 03:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF001 <- o_orderkey
+|  runtime filters: RF002 <- o_orderkey
 |
 |--01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
@@ -500,7 +500,7 @@ PLAN-ROOT SINK
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_shipdate > '1995-03-15'
-   runtime filters: RF001 -> l_orderkey
+   runtime filters: RF002 -> l_orderkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -533,7 +533,7 @@ PLAN-ROOT SINK
 |
 03:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF001 <- o_orderkey
+|  runtime filters: RF002 <- o_orderkey
 |
 |--07:EXCHANGE [BROADCAST]
 |  |
@@ -545,7 +545,7 @@ PLAN-ROOT SINK
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_shipdate > '1995-03-15'
-   runtime filters: RF001 -> l_orderkey
+   runtime filters: RF002 -> l_orderkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -582,7 +582,7 @@ PLAN-ROOT SINK
 |
 03:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF001 <- o_orderkey
+|  runtime filters: RF002 <- o_orderkey
 |
 |--JOIN BUILD
 |  |  join-table-id=01 plan-id=02 cohort-id=01
@@ -598,7 +598,7 @@ PLAN-ROOT SINK
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_shipdate > '1995-03-15'
-   runtime filters: RF001 -> l_orderkey
+   runtime filters: RF002 -> l_orderkey
 ====
 # TPCH-Q4
 # Q4 - Order Priority Checking Query
@@ -766,7 +766,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF001 <- n_nationkey
+|  runtime filters: RF002 <- n_nationkey
 |
 |--04:SCAN HDFS [tpch.nation]
 |     partitions=1/1 files=1 size=2.15KB
@@ -774,32 +774,32 @@ PLAN-ROOT SINK
 |
 08:HASH JOIN [INNER JOIN]
 |  hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey
-|  runtime filters: RF002 <- s_nationkey, RF003 <- s_suppkey
+|  runtime filters: RF004 <- s_nationkey, RF005 <- s_suppkey
 |
 |--03:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 07:HASH JOIN [INNER JOIN]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF004 <- c_custkey
+|  runtime filters: RF008 <- c_custkey
 |
 |--00:SCAN HDFS [tpch.customer]
 |     partitions=1/1 files=1 size=23.08MB
-|     runtime filters: RF001 -> tpch.customer.c_nationkey, RF002 -> c_nationkey
+|     runtime filters: RF002 -> tpch.customer.c_nationkey, RF004 -> c_nationkey
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF005 <- o_orderkey
+|  runtime filters: RF010 <- o_orderkey
 |
 |--01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01'
-|     runtime filters: RF004 -> o_custkey
+|     runtime filters: RF008 -> o_custkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF003 -> l_suppkey, RF005 -> l_orderkey
+   runtime filters: RF005 -> l_suppkey, RF010 -> l_orderkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -831,7 +831,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF001 <- n_nationkey
+|  runtime filters: RF002 <- n_nationkey
 |
 |--16:EXCHANGE [BROADCAST]
 |  |
@@ -841,38 +841,38 @@ PLAN-ROOT SINK
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey
-|  runtime filters: RF002 <- s_nationkey, RF003 <- s_suppkey
+|  runtime filters: RF004 <- s_nationkey, RF005 <- s_suppkey
 |
 |--15:EXCHANGE [BROADCAST]
 |  |
 |  03:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 07:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF004 <- c_custkey
+|  runtime filters: RF008 <- c_custkey
 |
 |--14:EXCHANGE [BROADCAST]
 |  |
 |  00:SCAN HDFS [tpch.customer]
 |     partitions=1/1 files=1 size=23.08MB
-|     runtime filters: RF001 -> tpch.customer.c_nationkey, RF002 -> c_nationkey
+|     runtime filters: RF002 -> tpch.customer.c_nationkey, RF004 -> c_nationkey
 |
 06:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF005 <- o_orderkey
+|  runtime filters: RF010 <- o_orderkey
 |
 |--13:EXCHANGE [BROADCAST]
 |  |
 |  01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01'
-|     runtime filters: RF004 -> o_custkey
+|     runtime filters: RF008 -> o_custkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF003 -> l_suppkey, RF005 -> l_orderkey
+   runtime filters: RF005 -> l_suppkey, RF010 -> l_orderkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -908,7 +908,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF001 <- n_nationkey
+|  runtime filters: RF002 <- n_nationkey
 |
 |--JOIN BUILD
 |  |  join-table-id=01 plan-id=02 cohort-id=01
@@ -922,7 +922,7 @@ PLAN-ROOT SINK
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey
-|  runtime filters: RF002 <- s_nationkey, RF003 <- s_suppkey
+|  runtime filters: RF004 <- s_nationkey, RF005 <- s_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=02 plan-id=03 cohort-id=01
@@ -932,11 +932,11 @@ PLAN-ROOT SINK
 |  |
 |  03:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 07:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF004 <- c_custkey
+|  runtime filters: RF008 <- c_custkey
 |
 |--JOIN BUILD
 |  |  join-table-id=03 plan-id=04 cohort-id=01
@@ -946,11 +946,11 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.customer]
 |     partitions=1/1 files=1 size=23.08MB
-|     runtime filters: RF001 -> tpch.customer.c_nationkey, RF002 -> c_nationkey
+|     runtime filters: RF002 -> tpch.customer.c_nationkey, RF004 -> c_nationkey
 |
 06:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF005 <- o_orderkey
+|  runtime filters: RF010 <- o_orderkey
 |
 |--JOIN BUILD
 |  |  join-table-id=04 plan-id=05 cohort-id=01
@@ -961,11 +961,11 @@ PLAN-ROOT SINK
 |  01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01'
-|     runtime filters: RF004 -> o_custkey
+|     runtime filters: RF008 -> o_custkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF003 -> l_suppkey, RF005 -> l_orderkey
+   runtime filters: RF005 -> l_suppkey, RF010 -> l_orderkey
 ====
 # TPCH-Q6
 # Q6 - Forecasting Revenue Change Query
@@ -1076,14 +1076,14 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n1.n_nationkey
-|  runtime filters: RF001 <- n1.n_nationkey
+|  runtime filters: RF002 <- n1.n_nationkey
 |
 |--04:SCAN HDFS [tpch.nation n1]
 |     partitions=1/1 files=1 size=2.15KB
 |
 08:HASH JOIN [INNER JOIN]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF002 <- c_custkey
+|  runtime filters: RF004 <- c_custkey
 |
 |--03:SCAN HDFS [tpch.customer]
 |     partitions=1/1 files=1 size=23.08MB
@@ -1091,24 +1091,24 @@ PLAN-ROOT SINK
 |
 07:HASH JOIN [INNER JOIN]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF003 <- s_suppkey
+|  runtime filters: RF006 <- s_suppkey
 |
 |--00:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF004 <- o_orderkey
+|  runtime filters: RF008 <- o_orderkey
 |
 |--02:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
-|     runtime filters: RF002 -> o_custkey
+|     runtime filters: RF004 -> o_custkey
 |
 01:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
-   runtime filters: RF003 -> l_suppkey, RF004 -> l_orderkey
+   runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -1140,7 +1140,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n1.n_nationkey
-|  runtime filters: RF001 <- n1.n_nationkey
+|  runtime filters: RF002 <- n1.n_nationkey
 |
 |--17:EXCHANGE [BROADCAST]
 |  |
@@ -1149,7 +1149,7 @@ PLAN-ROOT SINK
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF002 <- c_custkey
+|  runtime filters: RF004 <- c_custkey
 |
 |--16:EXCHANGE [BROADCAST]
 |  |
@@ -1159,30 +1159,30 @@ PLAN-ROOT SINK
 |
 07:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF003 <- s_suppkey
+|  runtime filters: RF006 <- s_suppkey
 |
 |--15:EXCHANGE [BROADCAST]
 |  |
 |  00:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 06:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF004 <- o_orderkey
+|  runtime filters: RF008 <- o_orderkey
 |
 |--14:EXCHANGE [HASH(o_orderkey)]
 |  |
 |  02:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
-|     runtime filters: RF002 -> o_custkey
+|     runtime filters: RF004 -> o_custkey
 |
 13:EXCHANGE [HASH(l_orderkey)]
 |
 01:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
-   runtime filters: RF003 -> l_suppkey, RF004 -> l_orderkey
+   runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -1218,7 +1218,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n1.n_nationkey
-|  runtime filters: RF001 <- n1.n_nationkey
+|  runtime filters: RF002 <- n1.n_nationkey
 |
 |--JOIN BUILD
 |  |  join-table-id=01 plan-id=02 cohort-id=01
@@ -1231,7 +1231,7 @@ PLAN-ROOT SINK
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF002 <- c_custkey
+|  runtime filters: RF004 <- c_custkey
 |
 |--JOIN BUILD
 |  |  join-table-id=02 plan-id=03 cohort-id=01
@@ -1245,7 +1245,7 @@ PLAN-ROOT SINK
 |
 07:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF003 <- s_suppkey
+|  runtime filters: RF006 <- s_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=03 plan-id=04 cohort-id=01
@@ -1255,11 +1255,11 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 06:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF004 <- o_orderkey
+|  runtime filters: RF008 <- o_orderkey
 |
 |--JOIN BUILD
 |  |  join-table-id=04 plan-id=05 cohort-id=01
@@ -1269,14 +1269,14 @@ PLAN-ROOT SINK
 |  |
 |  02:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
-|     runtime filters: RF002 -> o_custkey
+|     runtime filters: RF004 -> o_custkey
 |
 13:EXCHANGE [HASH(l_orderkey)]
 |
 01:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
-   runtime filters: RF003 -> l_suppkey, RF004 -> l_orderkey
+   runtime filters: RF006 -> l_suppkey, RF008 -> l_orderkey
 ====
 # TPCH-Q8
 # Q8 - National Market Share Query
@@ -1336,7 +1336,7 @@ PLAN-ROOT SINK
 |
 13:HASH JOIN [INNER JOIN]
 |  hash predicates: n1.n_regionkey = r_regionkey
-|  runtime filters: RF001 <- r_regionkey
+|  runtime filters: RF002 <- r_regionkey
 |
 |--07:SCAN HDFS [tpch.region]
 |     partitions=1/1 files=1 size=384B
@@ -1344,19 +1344,19 @@ PLAN-ROOT SINK
 |
 12:HASH JOIN [INNER JOIN]
 |  hash predicates: c_nationkey = n1.n_nationkey
-|  runtime filters: RF002 <- n1.n_nationkey
+|  runtime filters: RF004 <- n1.n_nationkey
 |
 |--05:SCAN HDFS [tpch.nation n1]
 |     partitions=1/1 files=1 size=2.15KB
-|     runtime filters: RF001 -> n1.n_regionkey
+|     runtime filters: RF002 -> n1.n_regionkey
 |
 11:HASH JOIN [INNER JOIN]
 |  hash predicates: c_custkey = o_custkey
-|  runtime filters: RF003 <- o_custkey
+|  runtime filters: RF006 <- o_custkey
 |
 |--10:HASH JOIN [INNER JOIN]
 |  |  hash predicates: l_suppkey = s_suppkey
-|  |  runtime filters: RF004 <- s_suppkey
+|  |  runtime filters: RF008 <- s_suppkey
 |  |
 |  |--01:SCAN HDFS [tpch.supplier]
 |  |     partitions=1/1 files=1 size=1.33MB
@@ -1364,11 +1364,11 @@ PLAN-ROOT SINK
 |  |
 |  09:HASH JOIN [INNER JOIN]
 |  |  hash predicates: o_orderkey = l_orderkey
-|  |  runtime filters: RF005 <- l_orderkey
+|  |  runtime filters: RF010 <- l_orderkey
 |  |
 |  |--08:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: l_partkey = p_partkey
-|  |  |  runtime filters: RF006 <- p_partkey
+|  |  |  runtime filters: RF012 <- p_partkey
 |  |  |
 |  |  |--00:SCAN HDFS [tpch.part]
 |  |  |     partitions=1/1 files=1 size=22.83MB
@@ -1376,16 +1376,16 @@ PLAN-ROOT SINK
 |  |  |
 |  |  02:SCAN HDFS [tpch.lineitem]
 |  |     partitions=1/1 files=1 size=718.94MB
-|  |     runtime filters: RF004 -> l_suppkey, RF006 -> l_partkey
+|  |     runtime filters: RF008 -> l_suppkey, RF012 -> l_partkey
 |  |
 |  03:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01'
-|     runtime filters: RF005 -> o_orderkey
+|     runtime filters: RF010 -> o_orderkey
 |
 04:SCAN HDFS [tpch.customer]
    partitions=1/1 files=1 size=23.08MB
-   runtime filters: RF002 -> c_nationkey, RF003 -> c_custkey
+   runtime filters: RF004 -> c_nationkey, RF006 -> c_custkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -1416,7 +1416,7 @@ PLAN-ROOT SINK
 |
 13:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: n1.n_regionkey = r_regionkey
-|  runtime filters: RF001 <- r_regionkey
+|  runtime filters: RF002 <- r_regionkey
 |
 |--25:EXCHANGE [BROADCAST]
 |  |
@@ -1426,29 +1426,29 @@ PLAN-ROOT SINK
 |
 12:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: c_nationkey = n1.n_nationkey
-|  runtime filters: RF002 <- n1.n_nationkey
+|  runtime filters: RF004 <- n1.n_nationkey
 |
 |--24:EXCHANGE [BROADCAST]
 |  |
 |  05:SCAN HDFS [tpch.nation n1]
 |     partitions=1/1 files=1 size=2.15KB
-|     runtime filters: RF001 -> n1.n_regionkey
+|     runtime filters: RF002 -> n1.n_regionkey
 |
 11:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF003 <- c_custkey
+|  runtime filters: RF006 <- c_custkey
 |
 |--23:EXCHANGE [HASH(c_custkey)]
 |  |
 |  04:SCAN HDFS [tpch.customer]
 |     partitions=1/1 files=1 size=23.08MB
-|     runtime filters: RF002 -> c_nationkey
+|     runtime filters: RF004 -> c_nationkey
 |
 22:EXCHANGE [HASH(o_custkey)]
 |
 10:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF004 <- s_suppkey
+|  runtime filters: RF008 <- s_suppkey
 |
 |--21:EXCHANGE [HASH(s_suppkey)]
 |  |
@@ -1460,20 +1460,20 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF005 <- o_orderkey
+|  runtime filters: RF010 <- o_orderkey
 |
 |--19:EXCHANGE [HASH(o_orderkey)]
 |  |
 |  03:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01'
-|     runtime filters: RF003 -> o_custkey
+|     runtime filters: RF006 -> o_custkey
 |
 18:EXCHANGE [HASH(l_orderkey)]
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_partkey = p_partkey
-|  runtime filters: RF006 <- p_partkey
+|  runtime filters: RF012 <- p_partkey
 |
 |--17:EXCHANGE [BROADCAST]
 |  |
@@ -1483,7 +1483,7 @@ PLAN-ROOT SINK
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF004 -> l_suppkey, RF005 -> l_orderkey, RF006 -> l_partkey
+   runtime filters: RF008 -> l_suppkey, RF010 -> l_orderkey, RF012 -> l_partkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -1518,7 +1518,7 @@ PLAN-ROOT SINK
 |
 13:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: n1.n_regionkey = r_regionkey
-|  runtime filters: RF001 <- r_regionkey
+|  runtime filters: RF002 <- r_regionkey
 |
 |--JOIN BUILD
 |  |  join-table-id=01 plan-id=02 cohort-id=01
@@ -1532,7 +1532,7 @@ PLAN-ROOT SINK
 |
 12:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: c_nationkey = n1.n_nationkey
-|  runtime filters: RF002 <- n1.n_nationkey
+|  runtime filters: RF004 <- n1.n_nationkey
 |
 |--JOIN BUILD
 |  |  join-table-id=02 plan-id=03 cohort-id=01
@@ -1542,11 +1542,11 @@ PLAN-ROOT SINK
 |  |
 |  05:SCAN HDFS [tpch.nation n1]
 |     partitions=1/1 files=1 size=2.15KB
-|     runtime filters: RF001 -> n1.n_regionkey
+|     runtime filters: RF002 -> n1.n_regionkey
 |
 11:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF003 <- c_custkey
+|  runtime filters: RF006 <- c_custkey
 |
 |--JOIN BUILD
 |  |  join-table-id=03 plan-id=04 cohort-id=01
@@ -1556,13 +1556,13 @@ PLAN-ROOT SINK
 |  |
 |  04:SCAN HDFS [tpch.customer]
 |     partitions=1/1 files=1 size=23.08MB
-|     runtime filters: RF002 -> c_nationkey
+|     runtime filters: RF004 -> c_nationkey
 |
 22:EXCHANGE [HASH(o_custkey)]
 |
 10:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF004 <- s_suppkey
+|  runtime filters: RF008 <- s_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=04 plan-id=05 cohort-id=01
@@ -1578,7 +1578,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF005 <- o_orderkey
+|  runtime filters: RF010 <- o_orderkey
 |
 |--JOIN BUILD
 |  |  join-table-id=05 plan-id=06 cohort-id=01
@@ -1589,13 +1589,13 @@ PLAN-ROOT SINK
 |  03:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01'
-|     runtime filters: RF003 -> o_custkey
+|     runtime filters: RF006 -> o_custkey
 |
 18:EXCHANGE [HASH(l_orderkey)]
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_partkey = p_partkey
-|  runtime filters: RF006 <- p_partkey
+|  runtime filters: RF012 <- p_partkey
 |
 |--JOIN BUILD
 |  |  join-table-id=06 plan-id=07 cohort-id=01
@@ -1609,7 +1609,7 @@ PLAN-ROOT SINK
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF004 -> l_suppkey, RF005 -> l_orderkey, RF006 -> l_partkey
+   runtime filters: RF008 -> l_suppkey, RF010 -> l_orderkey, RF012 -> l_partkey
 ====
 # TPCH-Q9
 # Q9 - Product Type Measure Query
@@ -1663,38 +1663,38 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
-|  runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey
+|  runtime filters: RF002 <- ps_partkey, RF003 <- ps_suppkey
 |
 |--03:SCAN HDFS [tpch.partsupp]
 |     partitions=1/1 files=1 size=112.71MB
 |
 08:HASH JOIN [INNER JOIN]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF003 <- s_suppkey
+|  runtime filters: RF006 <- s_suppkey
 |
 |--01:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF000 -> s_nationkey, RF002 -> tpch.supplier.s_suppkey
+|     runtime filters: RF000 -> s_nationkey, RF003 -> tpch.supplier.s_suppkey
 |
 07:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF004 <- o_orderkey
+|  runtime filters: RF008 <- o_orderkey
 |
 |--04:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: l_partkey = p_partkey
-|  runtime filters: RF005 <- p_partkey
+|  runtime filters: RF010 <- p_partkey
 |
 |--00:SCAN HDFS [tpch.part]
 |     partitions=1/1 files=1 size=22.83MB
 |     predicates: p_name LIKE '%green%'
-|     runtime filters: RF001 -> tpch.part.p_partkey
+|     runtime filters: RF002 -> tpch.part.p_partkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF001 -> l_partkey, RF002 -> l_suppkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey
+   runtime filters: RF002 -> l_partkey, RF003 -> l_suppkey, RF006 -> l_suppkey, RF008 -> l_orderkey, RF010 -> l_partkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -1725,7 +1725,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
-|  runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey
+|  runtime filters: RF002 <- ps_partkey, RF003 <- ps_suppkey
 |
 |--17:EXCHANGE [BROADCAST]
 |  |
@@ -1734,17 +1734,17 @@ PLAN-ROOT SINK
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF003 <- s_suppkey
+|  runtime filters: RF006 <- s_suppkey
 |
 |--16:EXCHANGE [BROADCAST]
 |  |
 |  01:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF000 -> s_nationkey, RF002 -> tpch.supplier.s_suppkey
+|     runtime filters: RF000 -> s_nationkey, RF003 -> tpch.supplier.s_suppkey
 |
 07:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF004 <- o_orderkey
+|  runtime filters: RF008 <- o_orderkey
 |
 |--15:EXCHANGE [HASH(o_orderkey)]
 |  |
@@ -1755,18 +1755,18 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_partkey = p_partkey
-|  runtime filters: RF005 <- p_partkey
+|  runtime filters: RF010 <- p_partkey
 |
 |--13:EXCHANGE [BROADCAST]
 |  |
 |  00:SCAN HDFS [tpch.part]
 |     partitions=1/1 files=1 size=22.83MB
 |     predicates: p_name LIKE '%green%'
-|     runtime filters: RF001 -> tpch.part.p_partkey
+|     runtime filters: RF002 -> tpch.part.p_partkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF001 -> l_partkey, RF002 -> l_suppkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey
+   runtime filters: RF002 -> l_partkey, RF003 -> l_suppkey, RF006 -> l_suppkey, RF008 -> l_orderkey, RF010 -> l_partkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -1801,7 +1801,7 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
-|  runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey
+|  runtime filters: RF002 <- ps_partkey, RF003 <- ps_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=01 plan-id=02 cohort-id=01
@@ -1814,7 +1814,7 @@ PLAN-ROOT SINK
 |
 08:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_suppkey = s_suppkey
-|  runtime filters: RF003 <- s_suppkey
+|  runtime filters: RF006 <- s_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=02 plan-id=03 cohort-id=01
@@ -1824,11 +1824,11 @@ PLAN-ROOT SINK
 |  |
 |  01:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF000 -> s_nationkey, RF002 -> tpch.supplier.s_suppkey
+|     runtime filters: RF000 -> s_nationkey, RF003 -> tpch.supplier.s_suppkey
 |
 07:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF004 <- o_orderkey
+|  runtime filters: RF008 <- o_orderkey
 |
 |--JOIN BUILD
 |  |  join-table-id=03 plan-id=04 cohort-id=01
@@ -1843,7 +1843,7 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_partkey = p_partkey
-|  runtime filters: RF005 <- p_partkey
+|  runtime filters: RF010 <- p_partkey
 |
 |--JOIN BUILD
 |  |  join-table-id=04 plan-id=05 cohort-id=01
@@ -1854,11 +1854,11 @@ PLAN-ROOT SINK
 |  00:SCAN HDFS [tpch.part]
 |     partitions=1/1 files=1 size=22.83MB
 |     predicates: p_name LIKE '%green%'
-|     runtime filters: RF001 -> tpch.part.p_partkey
+|     runtime filters: RF002 -> tpch.part.p_partkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF001 -> l_partkey, RF002 -> l_suppkey, RF003 -> l_suppkey, RF004 -> l_orderkey, RF005 -> l_partkey
+   runtime filters: RF002 -> l_partkey, RF003 -> l_suppkey, RF006 -> l_suppkey, RF008 -> l_orderkey, RF010 -> l_partkey
 ====
 # TPCH-Q10
 # Q10 - Returned Item Reporting Query
@@ -1914,11 +1914,11 @@ PLAN-ROOT SINK
 |
 05:HASH JOIN [INNER JOIN]
 |  hash predicates: c_custkey = o_custkey
-|  runtime filters: RF001 <- o_custkey
+|  runtime filters: RF002 <- o_custkey
 |
 |--04:HASH JOIN [INNER JOIN]
 |  |  hash predicates: l_orderkey = o_orderkey
-|  |  runtime filters: RF002 <- o_orderkey
+|  |  runtime filters: RF004 <- o_orderkey
 |  |
 |  |--01:SCAN HDFS [tpch.orders]
 |  |     partitions=1/1 files=1 size=162.56MB
@@ -1927,11 +1927,11 @@ PLAN-ROOT SINK
 |  02:SCAN HDFS [tpch.lineitem]
 |     partitions=1/1 files=1 size=718.94MB
 |     predicates: l_returnflag = 'R'
-|     runtime filters: RF002 -> l_orderkey
+|     runtime filters: RF004 -> l_orderkey
 |
 00:SCAN HDFS [tpch.customer]
    partitions=1/1 files=1 size=23.08MB
-   runtime filters: RF000 -> c_nationkey, RF001 -> c_custkey
+   runtime filters: RF000 -> c_nationkey, RF002 -> c_custkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -1963,7 +1963,7 @@ PLAN-ROOT SINK
 |
 05:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF001 <- c_custkey
+|  runtime filters: RF002 <- c_custkey
 |
 |--11:EXCHANGE [HASH(c_custkey)]
 |  |
@@ -1975,19 +1975,19 @@ PLAN-ROOT SINK
 |
 04:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF002 <- o_orderkey
+|  runtime filters: RF004 <- o_orderkey
 |
 |--09:EXCHANGE [BROADCAST]
 |  |
 |  01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate < '1994-01-01', o_orderdate >= '1993-10-01'
-|     runtime filters: RF001 -> o_custkey
+|     runtime filters: RF002 -> o_custkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_returnflag = 'R'
-   runtime filters: RF002 -> l_orderkey
+   runtime filters: RF004 -> l_orderkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -2023,7 +2023,7 @@ PLAN-ROOT SINK
 |
 05:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF001 <- c_custkey
+|  runtime filters: RF002 <- c_custkey
 |
 |--JOIN BUILD
 |  |  join-table-id=01 plan-id=02 cohort-id=01
@@ -2039,7 +2039,7 @@ PLAN-ROOT SINK
 |
 04:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF002 <- o_orderkey
+|  runtime filters: RF004 <- o_orderkey
 |
 |--JOIN BUILD
 |  |  join-table-id=02 plan-id=03 cohort-id=01
@@ -2050,12 +2050,12 @@ PLAN-ROOT SINK
 |  01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
 |     predicates: o_orderdate < '1994-01-01', o_orderdate >= '1993-10-01'
-|     runtime filters: RF001 -> o_custkey
+|     runtime filters: RF002 -> o_custkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    predicates: l_returnflag = 'R'
-   runtime filters: RF002 -> l_orderkey
+   runtime filters: RF004 -> l_orderkey
 ====
 # TPCH-Q11
 # Q11 - Important Stock Identification
@@ -2106,7 +2106,7 @@ PLAN-ROOT SINK
 |  |
 |  10:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF002 <- n_nationkey
+|  |  runtime filters: RF004 <- n_nationkey
 |  |
 |  |--08:SCAN HDFS [tpch.nation]
 |  |     partitions=1/1 files=1 size=2.15KB
@@ -2114,15 +2114,15 @@ PLAN-ROOT SINK
 |  |
 |  09:HASH JOIN [INNER JOIN]
 |  |  hash predicates: ps_suppkey = s_suppkey
-|  |  runtime filters: RF003 <- s_suppkey
+|  |  runtime filters: RF006 <- s_suppkey
 |  |
 |  |--07:SCAN HDFS [tpch.supplier]
 |  |     partitions=1/1 files=1 size=1.33MB
-|  |     runtime filters: RF002 -> s_nationkey
+|  |     runtime filters: RF004 -> s_nationkey
 |  |
 |  06:SCAN HDFS [tpch.partsupp]
 |     partitions=1/1 files=1 size=112.71MB
-|     runtime filters: RF003 -> ps_suppkey
+|     runtime filters: RF006 -> ps_suppkey
 |
 05:AGGREGATE [FINALIZE]
 |  output: sum(ps_supplycost * ps_availqty)
@@ -2138,7 +2138,7 @@ PLAN-ROOT SINK
 |
 03:HASH JOIN [INNER JOIN]
 |  hash predicates: ps_suppkey = s_suppkey
-|  runtime filters: RF001 <- s_suppkey
+|  runtime filters: RF002 <- s_suppkey
 |
 |--01:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
@@ -2146,7 +2146,7 @@ PLAN-ROOT SINK
 |
 00:SCAN HDFS [tpch.partsupp]
    partitions=1/1 files=1 size=112.71MB
-   runtime filters: RF001 -> ps_suppkey
+   runtime filters: RF002 -> ps_suppkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -2171,7 +2171,7 @@ PLAN-ROOT SINK
 |  |
 |  10:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF002 <- n_nationkey
+|  |  runtime filters: RF004 <- n_nationkey
 |  |
 |  |--19:EXCHANGE [BROADCAST]
 |  |  |
@@ -2181,17 +2181,17 @@ PLAN-ROOT SINK
 |  |
 |  09:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: ps_suppkey = s_suppkey
-|  |  runtime filters: RF003 <- s_suppkey
+|  |  runtime filters: RF006 <- s_suppkey
 |  |
 |  |--18:EXCHANGE [BROADCAST]
 |  |  |
 |  |  07:SCAN HDFS [tpch.supplier]
 |  |     partitions=1/1 files=1 size=1.33MB
-|  |     runtime filters: RF002 -> s_nationkey
+|  |     runtime filters: RF004 -> s_nationkey
 |  |
 |  06:SCAN HDFS [tpch.partsupp]
 |     partitions=1/1 files=1 size=112.71MB
-|     runtime filters: RF003 -> ps_suppkey
+|     runtime filters: RF006 -> ps_suppkey
 |
 17:AGGREGATE [FINALIZE]
 |  output: sum:merge(ps_supplycost * ps_availqty)
@@ -2215,7 +2215,7 @@ PLAN-ROOT SINK
 |
 03:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: ps_suppkey = s_suppkey
-|  runtime filters: RF001 <- s_suppkey
+|  runtime filters: RF002 <- s_suppkey
 |
 |--14:EXCHANGE [BROADCAST]
 |  |
@@ -2225,7 +2225,7 @@ PLAN-ROOT SINK
 |
 00:SCAN HDFS [tpch.partsupp]
    partitions=1/1 files=1 size=112.71MB
-   runtime filters: RF001 -> ps_suppkey
+   runtime filters: RF002 -> ps_suppkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -2254,7 +2254,7 @@ PLAN-ROOT SINK
 |  |
 |  10:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF002 <- n_nationkey
+|  |  runtime filters: RF004 <- n_nationkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=01 plan-id=02 cohort-id=02
@@ -2268,7 +2268,7 @@ PLAN-ROOT SINK
 |  |
 |  09:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: ps_suppkey = s_suppkey
-|  |  runtime filters: RF003 <- s_suppkey
+|  |  runtime filters: RF006 <- s_suppkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=02 plan-id=03 cohort-id=02
@@ -2278,11 +2278,11 @@ PLAN-ROOT SINK
 |  |  |
 |  |  07:SCAN HDFS [tpch.supplier]
 |  |     partitions=1/1 files=1 size=1.33MB
-|  |     runtime filters: RF002 -> s_nationkey
+|  |     runtime filters: RF004 -> s_nationkey
 |  |
 |  06:SCAN HDFS [tpch.partsupp]
 |     partitions=1/1 files=1 size=112.71MB
-|     runtime filters: RF003 -> ps_suppkey
+|     runtime filters: RF006 -> ps_suppkey
 |
 17:AGGREGATE [FINALIZE]
 |  output: sum:merge(ps_supplycost * ps_availqty)
@@ -2310,7 +2310,7 @@ PLAN-ROOT SINK
 |
 03:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: ps_suppkey = s_suppkey
-|  runtime filters: RF001 <- s_suppkey
+|  runtime filters: RF002 <- s_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=04 plan-id=05 cohort-id=01
@@ -2324,7 +2324,7 @@ PLAN-ROOT SINK
 |
 00:SCAN HDFS [tpch.partsupp]
    partitions=1/1 files=1 size=112.71MB
-   runtime filters: RF001 -> ps_suppkey
+   runtime filters: RF002 -> ps_suppkey
 ====
 # TPCH-Q12
 # Q12 - Shipping Mode and Order Priority Query
@@ -3063,7 +3063,7 @@ PLAN-ROOT SINK
 |
 |--04:HASH JOIN [INNER JOIN]
 |  |  hash predicates: l_partkey = p_partkey
-|  |  runtime filters: RF001 <- p_partkey
+|  |  runtime filters: RF002 <- p_partkey
 |  |
 |  |--01:SCAN HDFS [tpch.part]
 |  |     partitions=1/1 files=1 size=22.83MB
@@ -3071,7 +3071,7 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.lineitem]
 |     partitions=1/1 files=1 size=718.94MB
-|     runtime filters: RF001 -> l_partkey
+|     runtime filters: RF002 -> l_partkey
 |
 03:AGGREGATE [FINALIZE]
 |  output: avg(l_quantity)
@@ -3100,7 +3100,7 @@ PLAN-ROOT SINK
 |  |
 |  04:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: l_partkey = p_partkey
-|  |  runtime filters: RF001 <- p_partkey
+|  |  runtime filters: RF002 <- p_partkey
 |  |
 |  |--09:EXCHANGE [BROADCAST]
 |  |  |
@@ -3110,7 +3110,7 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.lineitem]
 |     partitions=1/1 files=1 size=718.94MB
-|     runtime filters: RF001 -> l_partkey
+|     runtime filters: RF002 -> l_partkey
 |
 08:AGGREGATE [FINALIZE]
 |  output: avg:merge(l_quantity)
@@ -3149,7 +3149,7 @@ PLAN-ROOT SINK
 |  |
 |  04:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: l_partkey = p_partkey
-|  |  runtime filters: RF001 <- p_partkey
+|  |  runtime filters: RF002 <- p_partkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=01 plan-id=02 cohort-id=02
@@ -3163,7 +3163,7 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.lineitem]
 |     partitions=1/1 files=1 size=718.94MB
-|     runtime filters: RF001 -> l_partkey
+|     runtime filters: RF002 -> l_partkey
 |
 08:AGGREGATE [FINALIZE]
 |  output: avg:merge(l_quantity)
@@ -3239,22 +3239,22 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF001 <- c_custkey
+|  runtime filters: RF002 <- c_custkey
 |
 |--00:SCAN HDFS [tpch.customer]
 |     partitions=1/1 files=1 size=23.08MB
 |
 05:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF002 <- o_orderkey
+|  runtime filters: RF004 <- o_orderkey
 |
 |--01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
-|     runtime filters: RF000 -> o_orderkey, RF001 -> o_custkey
+|     runtime filters: RF000 -> o_orderkey, RF002 -> o_custkey
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF002 -> l_orderkey
+   runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF004 -> l_orderkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -3295,7 +3295,7 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF001 <- c_custkey
+|  runtime filters: RF002 <- c_custkey
 |
 |--12:EXCHANGE [BROADCAST]
 |  |
@@ -3304,19 +3304,19 @@ PLAN-ROOT SINK
 |
 05:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF002 <- o_orderkey
+|  runtime filters: RF004 <- o_orderkey
 |
 |--11:EXCHANGE [HASH(o_orderkey)]
 |  |
 |  01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
-|     runtime filters: RF000 -> o_orderkey, RF001 -> o_custkey
+|     runtime filters: RF000 -> o_orderkey, RF002 -> o_custkey
 |
 10:EXCHANGE [HASH(l_orderkey)]
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF002 -> l_orderkey
+   runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF004 -> l_orderkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -3361,7 +3361,7 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: o_custkey = c_custkey
-|  runtime filters: RF001 <- c_custkey
+|  runtime filters: RF002 <- c_custkey
 |
 |--JOIN BUILD
 |  |  join-table-id=01 plan-id=02 cohort-id=01
@@ -3374,7 +3374,7 @@ PLAN-ROOT SINK
 |
 05:HASH JOIN [INNER JOIN, PARTITIONED]
 |  hash predicates: l_orderkey = o_orderkey
-|  runtime filters: RF002 <- o_orderkey
+|  runtime filters: RF004 <- o_orderkey
 |
 |--JOIN BUILD
 |  |  join-table-id=02 plan-id=03 cohort-id=01
@@ -3384,13 +3384,13 @@ PLAN-ROOT SINK
 |  |
 |  01:SCAN HDFS [tpch.orders]
 |     partitions=1/1 files=1 size=162.56MB
-|     runtime filters: RF000 -> o_orderkey, RF001 -> o_custkey
+|     runtime filters: RF000 -> o_orderkey, RF002 -> o_custkey
 |
 10:EXCHANGE [HASH(l_orderkey)]
 |
 02:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
-   runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF002 -> l_orderkey
+   runtime filters: RF000 -> tpch.lineitem.l_orderkey, RF004 -> l_orderkey
 ====
 # TPCH-Q19
 # Q19 - Discounted Revenue Query
@@ -3556,7 +3556,7 @@ PLAN-ROOT SINK
 |
 |--08:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF004 <- n_nationkey
+|  |  runtime filters: RF008 <- n_nationkey
 |  |
 |  |--01:SCAN HDFS [tpch.nation]
 |  |     partitions=1/1 files=1 size=2.15KB
@@ -3564,16 +3564,16 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF004 -> s_nationkey
+|     runtime filters: RF008 -> s_nationkey
 |
 07:HASH JOIN [RIGHT SEMI JOIN]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
 |  other join predicates: ps_availqty > 0.5 * sum(l_quantity)
-|  runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey
+|  runtime filters: RF002 <- ps_partkey, RF003 <- ps_suppkey
 |
 |--06:HASH JOIN [LEFT SEMI JOIN]
 |  |  hash predicates: ps_partkey = p_partkey
-|  |  runtime filters: RF003 <- p_partkey
+|  |  runtime filters: RF006 <- p_partkey
 |  |
 |  |--03:SCAN HDFS [tpch.part]
 |  |     partitions=1/1 files=1 size=22.83MB
@@ -3581,7 +3581,7 @@ PLAN-ROOT SINK
 |  |
 |  02:SCAN HDFS [tpch.partsupp]
 |     partitions=1/1 files=1 size=112.71MB
-|     runtime filters: RF000 -> ps_suppkey, RF003 -> ps_partkey
+|     runtime filters: RF000 -> ps_suppkey, RF006 -> ps_partkey
 |
 05:AGGREGATE [FINALIZE]
 |  output: sum(l_quantity)
@@ -3590,7 +3590,7 @@ PLAN-ROOT SINK
 04:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    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
+   runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey, RF003 -> tpch.lineitem.l_suppkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -3608,7 +3608,7 @@ PLAN-ROOT SINK
 |  |
 |  08:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF004 <- n_nationkey
+|  |  runtime filters: RF008 <- n_nationkey
 |  |
 |  |--15:EXCHANGE [BROADCAST]
 |  |  |
@@ -3618,20 +3618,20 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF004 -> s_nationkey
+|     runtime filters: RF008 -> s_nationkey
 |
 16:EXCHANGE [HASH(ps_suppkey)]
 |
 07:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
 |  other join predicates: ps_availqty > 0.5 * sum(l_quantity)
-|  runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey
+|  runtime filters: RF002 <- ps_partkey, RF003 <- ps_suppkey
 |
 |--14:EXCHANGE [HASH(ps_partkey,ps_suppkey)]
 |  |
 |  06:HASH JOIN [LEFT SEMI JOIN, BROADCAST]
 |  |  hash predicates: ps_partkey = p_partkey
-|  |  runtime filters: RF003 <- p_partkey
+|  |  runtime filters: RF006 <- p_partkey
 |  |
 |  |--13:EXCHANGE [BROADCAST]
 |  |  |
@@ -3641,7 +3641,7 @@ PLAN-ROOT SINK
 |  |
 |  02:SCAN HDFS [tpch.partsupp]
 |     partitions=1/1 files=1 size=112.71MB
-|     runtime filters: RF000 -> ps_suppkey, RF003 -> ps_partkey
+|     runtime filters: RF000 -> ps_suppkey, RF006 -> ps_partkey
 |
 12:AGGREGATE [FINALIZE]
 |  output: sum:merge(l_quantity)
@@ -3656,7 +3656,7 @@ PLAN-ROOT SINK
 04:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    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
+   runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey, RF003 -> tpch.lineitem.l_suppkey
 ---- PARALLELPLANS
 PLAN-ROOT SINK
 |
@@ -3678,7 +3678,7 @@ PLAN-ROOT SINK
 |  |
 |  08:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF004 <- n_nationkey
+|  |  runtime filters: RF008 <- n_nationkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=01 plan-id=02 cohort-id=02
@@ -3692,14 +3692,14 @@ PLAN-ROOT SINK
 |  |
 |  00:SCAN HDFS [tpch.supplier]
 |     partitions=1/1 files=1 size=1.33MB
-|     runtime filters: RF004 -> s_nationkey
+|     runtime filters: RF008 -> s_nationkey
 |
 16:EXCHANGE [HASH(ps_suppkey)]
 |
 07:HASH JOIN [RIGHT SEMI JOIN, PARTITIONED]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
 |  other join predicates: ps_availqty > 0.5 * sum(l_quantity)
-|  runtime filters: RF001 <- ps_partkey, RF002 <- ps_suppkey
+|  runtime filters: RF002 <- ps_partkey, RF003 <- ps_suppkey
 |
 |--JOIN BUILD
 |  |  join-table-id=02 plan-id=03 cohort-id=01
@@ -3709,7 +3709,7 @@ PLAN-ROOT SINK
 |  |
 |  06:HASH JOIN [LEFT SEMI JOIN, BROADCAST]
 |  |  hash predicates: ps_partkey = p_partkey
-|  |  runtime filters: RF003 <- p_partkey
+|  |  runtime filters: RF006 <- p_partkey
 |  |
 |  |--JOIN BUILD
 |  |  |  join-table-id=03 plan-id=04 cohort-id=03
@@ -3723,7 +3723,7 @@ PLAN-ROOT SINK
 |  |
 |  02:SCAN HDFS [tpch.partsupp]
 |     partitions=1/1 files=1 size=112.71MB
-|     runtime filters: RF000 -> ps_suppkey, RF003 -> ps_partkey
+|     runtime filters: RF000 -> ps_suppkey, RF006 -> ps_partkey
 |
 12:AGGREGATE [FINALIZE]
 |  output: sum:merge(l_quantity)
@@ -3738,7 +3738,7 @@ PLAN-ROOT SINK
 04:SCAN HDFS [tpch.lineitem]
    partitions=1/1 files=1 size=718.94MB
    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
+   runtime filters: RF000 -> tpch.lineitem.l_suppkey, RF002 -> tpch.lineitem.l_partkey, RF003 -> tpch.lineitem.l_suppkey
 ====
 # TPCH-Q21
 # Q21 - Suppliers Who Kept Orders Waiting Query
@@ -3803,7 +3803,7 @@ PLAN-ROOT SINK
 |  |
 |  |--08:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: s_nationkey = n_nationkey
-|  |  |  runtime filters: RF001 <- n_nationkey
+|  |  |  runtime filters: RF002 <- n_nationkey
 |  |  |
 |  |  |--03:SCAN HDFS [tpch.nation]
 |  |  |     partitions=1/1 files=1 size=2.15KB
@@ -3811,15 +3811,15 @@ PLAN-ROOT SINK
 |  |  |
 |  |  07:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: l1.l_suppkey = s_suppkey
-|  |  |  runtime filters: RF002 <- s_suppkey
+|  |  |  runtime filters: RF004 <- s_suppkey
 |  |  |
 |  |  |--00:SCAN HDFS [tpch.supplier]
 |  |  |     partitions=1/1 files=1 size=1.33MB
-|  |  |     runtime filters: RF001 -> s_nationkey
+|  |  |     runtime filters: RF002 -> s_nationkey
 |  |  |
 |  |  06:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: l1.l_orderkey = o_orderkey
-|  |  |  runtime filters: RF003 <- o_orderkey
+|  |  |  runtime filters: RF006 <- o_orderkey
 |  |  |
 |  |  |--02:SCAN HDFS [tpch.orders]
 |  |  |     partitions=1/1 files=1 size=162.56MB
@@ -3828,7 +3828,7 @@ PLAN-ROOT SINK
 |  |  01:SCAN HDFS [tpch.lineitem l1]
 |  |     partitions=1/1 files=1 size=718.94MB
 |  |     predicates: l1.l_receiptdate > l1.l_commitdate
-|  |     runtime filters: RF002 -> l1.l_suppkey, RF003 -> l1.l_orderkey
+|  |     runtime filters: RF004 -> l1.l_suppkey, RF006 -> l1.l_orderkey
 |  |
 |  04:SCAN HDFS [tpch.lineitem l2]
 |     partitions=1/1 files=1 size=718.94MB
@@ -3868,7 +3868,7 @@ PLAN-ROOT SINK
 |  |
 |  |--08:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  |  hash predicates: s_nationkey = n_nationkey
-|  |  |  runtime filters: RF001 <- n_nationkey
+|  |  |  runtime filters: RF002 <- n_nationkey
 |  |  |
 |  |  |--16:EXCHANGE [BROADCAST]
 |  |  |  |
@@ -3878,17 +3878,17 @@ PLAN-ROOT SINK
 |  |  |
 |  |  07:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  |  hash predicates: l1.l_suppkey = s_suppkey
-|  |  |  runtime filters: RF002 <- s_suppkey
+|  |  |  runtime filters: RF004 <- s_suppkey
 |  |  |
 |  |  |--15:EXCHANGE [BROADCAST]
 |  |  |  |
 |  |  |  00:SCAN HDFS [tpch.supplier]
 |  |  |     partitions=1/1 files=1 size=1.33MB
-|  |  |     runtime filters: RF001 -> s_nationkey
+|  |  |     runtime filters: RF002 -> s_nationkey
 |  |  |
 |  |  06:HASH JOIN [INNER JOIN, PARTITIONED]
 |  |  |  hash predicates: l1.l_orderkey = o_orderkey
-|  |  |  runtime filters: RF003 <- o_orderkey
+|  |  |  runtime filters: RF006 <- o_orderkey
 |  |  |
 |  |  |--14:EXCHANGE [HASH(o_orderkey)]
 |  |  |  |
@@ -3901,7 +3901,7 @@ PLAN-ROOT SINK
 |  |  01:SCAN HDFS [tpch.lineitem l1]
 |  |     partitions=1/1 files=1 size=718.94MB
 |  |     predicates: l1.l_receiptdate > l1.l_commitdate
-|  |     runtime filters: RF002 -> l1.l_suppkey, RF003 -> l1.l_orderkey
+|  |     runtime filters: RF004 -> l1.l_suppkey, RF006 -> l1.l_orderkey
 |  |
 |  17:EXCHANGE [HASH(l2.l_orderkey)]
 |  |
@@ -3953,7 +3953,7 @@ PLAN-ROOT SINK
 |  |  |
 |  |  08:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  |  hash predicates: s_nationkey = n_nationkey
-|  |  |  runtime filters: RF001 <- n_nationkey
+|  |  |  runtime filters: RF002 <- n_nationkey
 |  |  |
 |  |  |--JOIN BUILD
 |  |  |  |  join-table-id=02 plan-id=03 cohort-id=03
@@ -3967,7 +3967,7 @@ PLAN-ROOT SINK
 |  |  |
 |  |  07:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  |  hash predicates: l1.l_suppkey = s_suppkey
-|  |  |  runtime filters: RF002 <- s_suppkey
+|  |  |  runtime filters: RF004 <- s_suppkey
 |  |  |
 |  |  |--JOIN BUILD
 |  |  |  |  join-table-id=03 plan-id=04 cohort-id=03
@@ -3977,11 +3977,11 @@ PLAN-ROOT SINK
 |  |  |  |
 |  |  |  00:SCAN HDFS [tpch.supplier]
 |  |  |     partitions=1/1 files=1 size=1.33MB
-|  |  |     runtime filters: RF001 -> s_nationkey
+|  |  |     runtime filters: RF002 -> s_nationkey
 |  |  |
 |  |  06:HASH JOIN [INNER JOIN, PARTITIONED]
 |  |  |  hash predicates: l1.l_orderkey = o_orderkey
-|  |  |  runtime filters: RF003 <- o_orderkey
+|  |  |  runtime filters: RF006 <- o_orderkey
 |  |  |
 |  |  |--JOIN BUILD
 |  |  |  |  join-table-id=04 plan-id=05 cohort-id=03
@@ -3998,7 +3998,7 @@ PLAN-ROOT SINK
 |  |  01:SCAN HDFS [tpch.lineitem l1]
 |  |     partitions=1/1 files=1 size=718.94MB
 |  |     predicates: l1.l_receiptdate > l1.l_commitdate
-|  |     runtime filters: RF002 -> l1.l_suppkey, RF003 -> l1.l_orderkey
+|  |     runtime filters: RF004 -> l1.l_suppkey, RF006 -> l1.l_orderkey
 |  |
 |  17:EXCHANGE [HASH(l2.l_orderkey)]
 |  |

http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/2510fe0a/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 2dde552..9c4da19 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-kudu.test
@@ -86,31 +86,39 @@ PLAN-ROOT SINK
 |
 17:HASH JOIN [RIGHT SEMI JOIN]
 |  hash predicates: ps_partkey = p_partkey, min(ps_supplycost) = ps_supplycost
+|  runtime filters: RF002 <- p_partkey
 |
 |--16:HASH JOIN [INNER JOIN]
 |  |  hash predicates: n_regionkey = r_regionkey
+|  |  runtime filters: RF011 <- r_regionkey
 |  |
 |  |--04:SCAN KUDU [tpch_kudu.region]
 |  |     kudu predicates: r_name = 'EUROPE'
 |  |
 |  15:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
+|  |  runtime filters: RF013 <- n_nationkey
 |  |
 |  |--03:SCAN KUDU [tpch_kudu.nation]
+|  |     runtime filters: RF011 -> n_regionkey
 |  |
 |  14:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_suppkey = ps_suppkey
+|  |  runtime filters: RF015 <- ps_suppkey
 |  |
 |  |--13:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: ps_partkey = p_partkey
+|  |  |  runtime filters: RF017 <- p_partkey
 |  |  |
 |  |  |--00:SCAN KUDU [tpch_kudu.part]
 |  |  |     predicates: p_type LIKE '%BRASS'
 |  |  |     kudu predicates: p_size = 15
 |  |  |
 |  |  02:SCAN KUDU [tpch_kudu.partsupp]
+|  |     runtime filters: RF017 -> ps_partkey
 |  |
 |  01:SCAN KUDU [tpch_kudu.supplier]
+|     runtime filters: RF013 -> s_nationkey, RF015 -> s_suppkey
 |
 12:AGGREGATE [FINALIZE]
 |  output: min(ps_supplycost)
@@ -118,21 +126,27 @@ PLAN-ROOT SINK
 |
 11:HASH JOIN [INNER JOIN]
 |  hash predicates: n_regionkey = r_regionkey
+|  runtime filters: RF005 <- r_regionkey
 |
 |--08:SCAN KUDU [tpch_kudu.region]
 |     kudu predicates: r_name = 'EUROPE'
 |
 10:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n_nationkey
+|  runtime filters: RF007 <- n_nationkey
 |
 |--07:SCAN KUDU [tpch_kudu.nation]
+|     runtime filters: RF005 -> n_regionkey
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: ps_suppkey = s_suppkey
+|  runtime filters: RF009 <- s_suppkey
 |
 |--06:SCAN KUDU [tpch_kudu.supplier]
+|     runtime filters: RF007 -> s_nationkey
 |
 05:SCAN KUDU [tpch_kudu.partsupp]
+   runtime filters: RF002 -> tpch_kudu.partsupp.ps_partkey, RF009 -> ps_suppkey
 ====
 # Q3 - Shipping Priority Query
 select
@@ -170,18 +184,22 @@ PLAN-ROOT SINK
 |
 04:HASH JOIN [INNER JOIN]
 |  hash predicates: o_custkey = c_custkey
+|  runtime filters: RF001 <- c_custkey
 |
 |--00:SCAN KUDU [tpch_kudu.customer]
 |     kudu predicates: c_mktsegment = 'BUILDING'
 |
 03:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
+|  runtime filters: RF003 <- o_orderkey
 |
 |--01:SCAN KUDU [tpch_kudu.orders]
 |     kudu predicates: o_orderdate < '1995-03-15'
+|     runtime filters: RF001 -> o_custkey
 |
 02:SCAN KUDU [tpch_kudu.lineitem]
    kudu predicates: l_shipdate > '1995-03-15'
+   runtime filters: RF003 -> l_orderkey
 ====
 # Q4 - Order Priority Checking Query
 select
@@ -217,12 +235,14 @@ PLAN-ROOT SINK
 |
 02:HASH JOIN [RIGHT SEMI JOIN]
 |  hash predicates: l_orderkey = o_orderkey
+|  runtime filters: RF001 <- o_orderkey
 |
 |--00:SCAN KUDU [tpch_kudu.orders]
 |     kudu predicates: o_orderdate < '1993-10-01', o_orderdate >= '1993-07-01'
 |
 01:SCAN KUDU [tpch_kudu.lineitem]
    predicates: l_commitdate < l_receiptdate
+   runtime filters: RF001 -> l_orderkey
 ====
 # Q5 - Local Supplier Volume Query
 select
@@ -261,32 +281,42 @@ PLAN-ROOT SINK
 |
 10:HASH JOIN [INNER JOIN]
 |  hash predicates: n_regionkey = r_regionkey
+|  runtime filters: RF001 <- r_regionkey
 |
 |--05:SCAN KUDU [tpch_kudu.region]
 |     kudu predicates: r_name = 'ASIA'
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n_nationkey
+|  runtime filters: RF003 <- n_nationkey
 |
 |--04:SCAN KUDU [tpch_kudu.nation]
+|     runtime filters: RF001 -> n_regionkey
 |
 08:HASH JOIN [INNER JOIN]
 |  hash predicates: c_nationkey = s_nationkey, l_suppkey = s_suppkey
+|  runtime filters: RF006 <- s_nationkey, RF007 <- s_suppkey
 |
 |--03:SCAN KUDU [tpch_kudu.supplier]
+|     runtime filters: RF003 -> s_nationkey
 |
 07:HASH JOIN [INNER JOIN]
 |  hash predicates: o_custkey = c_custkey
+|  runtime filters: RF009 <- c_custkey
 |
 |--00:SCAN KUDU [tpch_kudu.customer]
+|     runtime filters: RF003 -> tpch_kudu.customer.c_nationkey, RF006 -> c_nationkey
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
+|  runtime filters: RF011 <- o_orderkey
 |
 |--01:SCAN KUDU [tpch_kudu.orders]
 |     kudu predicates: o_orderdate < '1995-01-01', o_orderdate >= '1994-01-01'
+|     runtime filters: RF009 -> o_custkey
 |
 02:SCAN KUDU [tpch_kudu.lineitem]
+   runtime filters: RF007 -> l_suppkey, RF011 -> l_orderkey
 ====
 # Q6 - Forecasting Revenue Change Query
 select
@@ -359,31 +389,40 @@ PLAN-ROOT SINK
 10:HASH JOIN [INNER JOIN]
 |  hash predicates: c_nationkey = n2.n_nationkey
 |  other predicates: ((n1.n_name = 'FRANCE' AND n2.n_name = 'GERMANY') OR (n1.n_name = 'GERMANY' AND n2.n_name = 'FRANCE'))
+|  runtime filters: RF001 <- n2.n_nationkey
 |
 |--05:SCAN KUDU [tpch_kudu.nation n2]
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n1.n_nationkey
+|  runtime filters: RF003 <- n1.n_nationkey
 |
 |--04:SCAN KUDU [tpch_kudu.nation n1]
 |
 08:HASH JOIN [INNER JOIN]
 |  hash predicates: o_custkey = c_custkey
+|  runtime filters: RF005 <- c_custkey
 |
 |--03:SCAN KUDU [tpch_kudu.customer]
+|     runtime filters: RF001 -> c_nationkey
 |
 07:HASH JOIN [INNER JOIN]
 |  hash predicates: l_suppkey = s_suppkey
+|  runtime filters: RF007 <- s_suppkey
 |
 |--00:SCAN KUDU [tpch_kudu.supplier]
+|     runtime filters: RF003 -> s_nationkey
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
+|  runtime filters: RF009 <- o_orderkey
 |
 |--02:SCAN KUDU [tpch_kudu.orders]
+|     runtime filters: RF005 -> o_custkey
 |
 01:SCAN KUDU [tpch_kudu.lineitem]
    kudu predicates: l_shipdate <= '1996-12-31', l_shipdate >= '1995-01-01'
+   runtime filters: RF007 -> l_suppkey, RF009 -> l_orderkey
 ====
 # Q8 - National Market Share Query
 select
@@ -435,43 +474,55 @@ PLAN-ROOT SINK
 |
 14:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n2.n_nationkey
+|  runtime filters: RF001 <- n2.n_nationkey
 |
 |--06:SCAN KUDU [tpch_kudu.nation n2]
 |
 13:HASH JOIN [INNER JOIN]
 |  hash predicates: n1.n_regionkey = r_regionkey
+|  runtime filters: RF003 <- r_regionkey
 |
 |--07:SCAN KUDU [tpch_kudu.region]
 |     kudu predicates: r_name = 'AMERICA'
 |
 12:HASH JOIN [INNER JOIN]
 |  hash predicates: c_nationkey = n1.n_nationkey
+|  runtime filters: RF005 <- n1.n_nationkey
 |
 |--05:SCAN KUDU [tpch_kudu.nation n1]
+|     runtime filters: RF003 -> n1.n_regionkey
 |
 11:HASH JOIN [INNER JOIN]
 |  hash predicates: c_custkey = o_custkey
+|  runtime filters: RF007 <- o_custkey
 |
 |--10:HASH JOIN [INNER JOIN]
 |  |  hash predicates: l_suppkey = s_suppkey
+|  |  runtime filters: RF009 <- s_suppkey
 |  |
 |  |--01:SCAN KUDU [tpch_kudu.supplier]
+|  |     runtime filters: RF001 -> s_nationkey
 |  |
 |  09:HASH JOIN [INNER JOIN]
 |  |  hash predicates: o_orderkey = l_orderkey
+|  |  runtime filters: RF011 <- l_orderkey
 |  |
 |  |--08:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: l_partkey = p_partkey
+|  |  |  runtime filters: RF013 <- p_partkey
 |  |  |
 |  |  |--00:SCAN KUDU [tpch_kudu.part]
 |  |  |     kudu predicates: p_type = 'ECONOMY ANODIZED STEEL'
 |  |  |
 |  |  02:SCAN KUDU [tpch_kudu.lineitem]
+|  |     runtime filters: RF009 -> l_suppkey, RF013 -> l_partkey
 |  |
 |  03:SCAN KUDU [tpch_kudu.orders]
 |     kudu predicates: o_orderdate <= '1996-12-31', o_orderdate >= '1995-01-01'
+|     runtime filters: RF011 -> o_orderkey
 |
 04:SCAN KUDU [tpch_kudu.customer]
+   runtime filters: RF005 -> c_nationkey, RF007 -> c_custkey
 ====
 # Q9 - Product Type Measure Query
 select
@@ -517,31 +568,39 @@ PLAN-ROOT SINK
 |
 10:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n_nationkey
+|  runtime filters: RF001 <- n_nationkey
 |
 |--05:SCAN KUDU [tpch_kudu.nation]
 |
 09:HASH JOIN [INNER JOIN]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
+|  runtime filters: RF004 <- ps_partkey, RF005 <- ps_suppkey
 |
 |--03:SCAN KUDU [tpch_kudu.partsupp]
 |
 08:HASH JOIN [INNER JOIN]
 |  hash predicates: l_suppkey = s_suppkey
+|  runtime filters: RF007 <- s_suppkey
 |
 |--01:SCAN KUDU [tpch_kudu.supplier]
+|     runtime filters: RF001 -> s_nationkey, RF005 -> tpch_kudu.supplier.s_suppkey
 |
 07:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
+|  runtime filters: RF009 <- o_orderkey
 |
 |--04:SCAN KUDU [tpch_kudu.orders]
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: l_partkey = p_partkey
+|  runtime filters: RF011 <- p_partkey
 |
 |--00:SCAN KUDU [tpch_kudu.part]
 |     predicates: p_name LIKE '%green%'
+|     runtime filters: RF004 -> tpch_kudu.part.p_partkey
 |
 02:SCAN KUDU [tpch_kudu.lineitem]
+   runtime filters: RF004 -> l_partkey, RF005 -> l_suppkey, RF007 -> l_suppkey, RF009 -> l_orderkey, RF011 -> l_partkey
 ====
 # Q10 - Returned Item Reporting Query
 # Converted select from multiple tables to joins
@@ -589,22 +648,27 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: c_nationkey = n_nationkey
+|  runtime filters: RF001 <- n_nationkey
 |
 |--03:SCAN KUDU [tpch_kudu.nation]
 |
 05:HASH JOIN [INNER JOIN]
 |  hash predicates: c_custkey = o_custkey
+|  runtime filters: RF003 <- o_custkey
 |
 |--04:HASH JOIN [INNER JOIN]
 |  |  hash predicates: l_orderkey = o_orderkey
+|  |  runtime filters: RF005 <- o_orderkey
 |  |
 |  |--01:SCAN KUDU [tpch_kudu.orders]
 |  |     kudu predicates: o_orderdate < '1994-01-01', o_orderdate >= '1993-10-01'
 |  |
 |  02:SCAN KUDU [tpch_kudu.lineitem]
 |     kudu predicates: l_returnflag = 'R'
+|     runtime filters: RF005 -> l_orderkey
 |
 00:SCAN KUDU [tpch_kudu.customer]
+   runtime filters: RF001 -> c_nationkey, RF003 -> c_custkey
 ====
 # Q11 - Important Stock Identification
 # Modifications: query was rewritten to not have a subquery in the having clause
@@ -654,16 +718,20 @@ PLAN-ROOT SINK
 |  |
 |  10:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
+|  |  runtime filters: RF005 <- n_nationkey
 |  |
 |  |--08:SCAN KUDU [tpch_kudu.nation]
 |  |     kudu predicates: n_name = 'GERMANY'
 |  |
 |  09:HASH JOIN [INNER JOIN]
 |  |  hash predicates: ps_suppkey = s_suppkey
+|  |  runtime filters: RF007 <- s_suppkey
 |  |
 |  |--07:SCAN KUDU [tpch_kudu.supplier]
+|  |     runtime filters: RF005 -> s_nationkey
 |  |
 |  06:SCAN KUDU [tpch_kudu.partsupp]
+|     runtime filters: RF007 -> ps_suppkey
 |
 05:AGGREGATE [FINALIZE]
 |  output: sum(ps_supplycost * ps_availqty)
@@ -671,16 +739,20 @@ PLAN-ROOT SINK
 |
 04:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n_nationkey
+|  runtime filters: RF001 <- n_nationkey
 |
 |--02:SCAN KUDU [tpch_kudu.nation]
 |     kudu predicates: n_name = 'GERMANY'
 |
 03:HASH JOIN [INNER JOIN]
 |  hash predicates: ps_suppkey = s_suppkey
+|  runtime filters: RF003 <- s_suppkey
 |
 |--01:SCAN KUDU [tpch_kudu.supplier]
+|     runtime filters: RF001 -> s_nationkey
 |
 00:SCAN KUDU [tpch_kudu.partsupp]
+   runtime filters: RF003 -> ps_suppkey
 ====
 # Q12 - Shipping Mode and Order Priority Query
 select
@@ -723,12 +795,14 @@ PLAN-ROOT SINK
 |
 02:HASH JOIN [INNER JOIN]
 |  hash predicates: o_orderkey = l_orderkey
+|  runtime filters: RF001 <- l_orderkey
 |
 |--01:SCAN KUDU [tpch_kudu.lineitem]
 |     predicates: l_commitdate < l_receiptdate, l_shipdate < l_commitdate
 |     kudu predicates: l_shipmode IN ('MAIL', 'SHIP'), l_receiptdate < '1995-01-01', l_receiptdate >= '1994-01-01'
 |
 00:SCAN KUDU [tpch_kudu.orders]
+   runtime filters: RF001 -> o_orderkey
 ====
 # Q13 - Customer Distribution Query
 select
@@ -767,11 +841,13 @@ PLAN-ROOT SINK
 |
 02:HASH JOIN [RIGHT OUTER JOIN]
 |  hash predicates: o_custkey = c_custkey
+|  runtime filters: RF001 <- c_custkey
 |
 |--00:SCAN KUDU [tpch_kudu.customer]
 |
 01:SCAN KUDU [tpch_kudu.orders]
    predicates: NOT o_comment LIKE '%special%requests%'
+   runtime filters: RF001 -> o_custkey
 ====
 # Q14 - Promotion Effect
 select
@@ -795,11 +871,13 @@ PLAN-ROOT SINK
 |
 02:HASH JOIN [INNER JOIN]
 |  hash predicates: l_partkey = p_partkey
+|  runtime filters: RF001 <- p_partkey
 |
 |--01:SCAN KUDU [tpch_kudu.part]
 |
 00:SCAN KUDU [tpch_kudu.lineitem]
    kudu predicates: l_shipdate < '1995-10-01', l_shipdate >= '1995-09-01'
+   runtime filters: RF001 -> l_partkey
 ====
 # Q15 - Top Supplier Query
 with revenue_view as (
@@ -853,6 +931,7 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: s_suppkey = l_suppkey
+|  runtime filters: RF001 <- l_suppkey
 |
 |--02:AGGREGATE [FINALIZE]
 |  |  output: sum(l_extendedprice * (1 - l_discount))
@@ -862,6 +941,7 @@ PLAN-ROOT SINK
 |     kudu predicates: l_shipdate < '1996-04-01', l_shipdate >= '1996-01-01'
 |
 00:SCAN KUDU [tpch_kudu.supplier]
+   runtime filters: RF001 -> s_suppkey
 ====
 # Q16 - Parts/Supplier Relation Query
 select
@@ -915,12 +995,14 @@ PLAN-ROOT SINK
 |
 03:HASH JOIN [INNER JOIN]
 |  hash predicates: ps_partkey = p_partkey
+|  runtime filters: RF001 <- p_partkey
 |
 |--01:SCAN KUDU [tpch_kudu.part]
 |     predicates: p_brand != 'Brand#45', NOT p_type LIKE 'MEDIUM POLISHED%'
 |     kudu predicates: p_size IN (49, 14, 23, 45, 19, 3, 36, 9)
 |
 00:SCAN KUDU [tpch_kudu.partsupp]
+   runtime filters: RF001 -> ps_partkey
 ====
 # Q17 - Small-Quantity-Order Revenue Query
 select
@@ -949,20 +1031,24 @@ PLAN-ROOT SINK
 05:HASH JOIN [RIGHT SEMI JOIN]
 |  hash predicates: l_partkey = p_partkey
 |  other join predicates: l_quantity < round(0.2 * avg(l_quantity), 2)
+|  runtime filters: RF001 <- p_partkey
 |
 |--04:HASH JOIN [INNER JOIN]
 |  |  hash predicates: l_partkey = p_partkey
+|  |  runtime filters: RF003 <- p_partkey
 |  |
 |  |--01:SCAN KUDU [tpch_kudu.part]
 |  |     kudu predicates: p_container = 'MED BOX', p_brand = 'Brand#23'
 |  |
 |  00:SCAN KUDU [tpch_kudu.lineitem]
+|     runtime filters: RF003 -> l_partkey
 |
 03:AGGREGATE [FINALIZE]
 |  output: avg(l_quantity)
 |  group by: l_partkey
 |
 02:SCAN KUDU [tpch_kudu.lineitem]
+   runtime filters: RF001 -> tpch_kudu.lineitem.l_partkey
 ====
 # Q18 - Large Value tpch_kudu.customer Query
 select
@@ -1011,6 +1097,7 @@ PLAN-ROOT SINK
 |
 07:HASH JOIN [LEFT SEMI JOIN]
 |  hash predicates: o_orderkey = l_orderkey
+|  runtime filters: RF001 <- l_orderkey
 |
 |--04:AGGREGATE [FINALIZE]
 |  |  output: sum(l_quantity)
@@ -1021,15 +1108,19 @@ PLAN-ROOT SINK
 |
 06:HASH JOIN [INNER JOIN]
 |  hash predicates: o_custkey = c_custkey
+|  runtime filters: RF003 <- c_custkey
 |
 |--00:SCAN KUDU [tpch_kudu.customer]
 |
 05:HASH JOIN [INNER JOIN]
 |  hash predicates: l_orderkey = o_orderkey
+|  runtime filters: RF005 <- o_orderkey
 |
 |--01:SCAN KUDU [tpch_kudu.orders]
+|     runtime filters: RF001 -> o_orderkey, RF003 -> o_custkey
 |
 02:SCAN KUDU [tpch_kudu.lineitem]
+   runtime filters: RF001 -> tpch_kudu.lineitem.l_orderkey, RF005 -> l_orderkey
 ====
 # Q19 - Discounted Revenue Query
 select
@@ -1076,12 +1167,14 @@ PLAN-ROOT SINK
 02:HASH JOIN [INNER JOIN]
 |  hash predicates: l_partkey = p_partkey
 |  other predicates: ((p_brand = 'Brand#12' AND p_container IN ('SM CASE', 'SM BOX', 'SM PACK', 'SM PKG') AND l_quantity >= 1 AND l_quantity <= 11 AND p_size <= 5) OR (p_brand = 'Brand#23' AND p_container IN ('MED BAG', 'MED BOX', 'MED PKG', 'MED PACK') AND l_quantity >= 10 AND l_quantity <= 20 AND p_size <= 10) OR (p_brand = 'Brand#34' AND p_container IN ('LG CASE', 'LG BOX', 'LG PACK', 'LG PKG') AND l_quantity >= 20 AND l_quantity <= 30 AND p_size <= 15))
+|  runtime filters: RF001 <- p_partkey
 |
 |--01:SCAN KUDU [tpch_kudu.part]
 |     kudu predicates: p_size >= 1
 |
 00:SCAN KUDU [tpch_kudu.lineitem]
    kudu predicates: l_shipmode IN ('AIR', 'AIR REG'), l_shipinstruct = 'DELIVER IN PERSON'
+   runtime filters: RF001 -> l_partkey
 ====
 # Q20 - Potential Part Promotion Query
 select
@@ -1128,26 +1221,32 @@ PLAN-ROOT SINK
 |
 09:HASH JOIN [RIGHT SEMI JOIN]
 |  hash predicates: ps_suppkey = s_suppkey
+|  runtime filters: RF001 <- s_suppkey
 |
 |--08:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
+|  |  runtime filters: RF009 <- n_nationkey
 |  |
 |  |--01:SCAN KUDU [tpch_kudu.nation]
 |  |     kudu predicates: n_name = 'CANADA'
 |  |
 |  00:SCAN KUDU [tpch_kudu.supplier]
+|     runtime filters: RF009 -> s_nationkey
 |
 07:HASH JOIN [RIGHT SEMI JOIN]
 |  hash predicates: l_partkey = ps_partkey, l_suppkey = ps_suppkey
 |  other join predicates: ps_availqty > 0.5 * sum(l_quantity)
+|  runtime filters: RF004 <- ps_partkey, RF005 <- ps_suppkey
 |
 |--06:HASH JOIN [LEFT SEMI JOIN]
 |  |  hash predicates: ps_partkey = p_partkey
+|  |  runtime filters: RF007 <- p_partkey
 |  |
 |  |--03:SCAN KUDU [tpch_kudu.part]
 |  |     predicates: p_name LIKE 'forest%'
 |  |
 |  02:SCAN KUDU [tpch_kudu.partsupp]
+|     runtime filters: RF001 -> ps_suppkey, RF007 -> ps_partkey
 |
 05:AGGREGATE [FINALIZE]
 |  output: sum(l_quantity)
@@ -1155,6 +1254,7 @@ PLAN-ROOT SINK
 |
 04:SCAN KUDU [tpch_kudu.lineitem]
    kudu predicates: l_shipdate < '1995-01-01', l_shipdate >= '1994-01-01'
+   runtime filters: RF001 -> tpch_kudu.lineitem.l_suppkey, RF004 -> tpch_kudu.lineitem.l_partkey, RF005 -> tpch_kudu.lineitem.l_suppkey
 ====
 # Q21 - Suppliers Who Kept Orders Waiting Query
 select
@@ -1214,28 +1314,35 @@ PLAN-ROOT SINK
 |--09:HASH JOIN [RIGHT SEMI JOIN]
 |  |  hash predicates: l2.l_orderkey = l1.l_orderkey
 |  |  other join predicates: l2.l_suppkey != l1.l_suppkey
+|  |  runtime filters: RF001 <- l1.l_orderkey
 |  |
 |  |--08:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: s_nationkey = n_nationkey
+|  |  |  runtime filters: RF003 <- n_nationkey
 |  |  |
 |  |  |--03:SCAN KUDU [tpch_kudu.nation]
 |  |  |     kudu predicates: n_name = 'SAUDI ARABIA'
 |  |  |
 |  |  07:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: l1.l_suppkey = s_suppkey
+|  |  |  runtime filters: RF005 <- s_suppkey
 |  |  |
 |  |  |--00:SCAN KUDU [tpch_kudu.supplier]
+|  |  |     runtime filters: RF003 -> s_nationkey
 |  |  |
 |  |  06:HASH JOIN [INNER JOIN]
 |  |  |  hash predicates: l1.l_orderkey = o_orderkey
+|  |  |  runtime filters: RF007 <- o_orderkey
 |  |  |
 |  |  |--02:SCAN KUDU [tpch_kudu.orders]
 |  |  |     kudu predicates: o_orderstatus = 'F'
 |  |  |
 |  |  01:SCAN KUDU [tpch_kudu.lineitem l1]
 |  |     predicates: l1.l_receiptdate > l1.l_commitdate
+|  |     runtime filters: RF005 -> l1.l_suppkey, RF007 -> l1.l_orderkey
 |  |
 |  04:SCAN KUDU [tpch_kudu.lineitem l2]
+|     runtime filters: RF001 -> l2.l_orderkey
 |
 05:SCAN KUDU [tpch_kudu.lineitem l3]
    predicates: l3.l_receiptdate > l3.l_commitdate

http://git-wip-us.apache.org/repos/asf/incubator-impala/blob/2510fe0a/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 aad75e0..1aaabce 100644
--- a/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test
+++ b/testdata/workloads/functional-planner/queries/PlannerTest/tpch-nested.test
@@ -115,7 +115,7 @@ PLAN-ROOT SINK
 |  |
 |  21:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF004 <- n_nationkey
+|  |  runtime filters: RF008 <- n_nationkey
 |  |
 |  |--17:SUBPLAN
 |  |  |
@@ -140,11 +140,11 @@ PLAN-ROOT SINK
 |  11:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
 |     predicates: !empty(s.s_partsupps)
-|     runtime filters: RF004 -> s_nationkey
+|     runtime filters: RF008 -> s_nationkey
 |
 24:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF002 <- n_nationkey
+|  runtime filters: RF004 <- n_nationkey
 |
 |--07:SUBPLAN
 |  |
@@ -177,7 +177,7 @@ PLAN-ROOT SINK
 00:SCAN HDFS [tpch_nested_parquet.supplier s]
    partitions=1/1 files=1 size=43.00MB
    predicates: !empty(s.s_partsupps)
-   runtime filters: RF002 -> s_nationkey
+   runtime filters: RF004 -> s_nationkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -206,7 +206,7 @@ PLAN-ROOT SINK
 |  |
 |  21:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF004 <- n_nationkey
+|  |  runtime filters: RF008 <- n_nationkey
 |  |
 |  |--29:EXCHANGE [BROADCAST]
 |  |  |
@@ -233,11 +233,11 @@ PLAN-ROOT SINK
 |  11:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
 |     predicates: !empty(s.s_partsupps)
-|     runtime filters: RF004 -> s_nationkey
+|     runtime filters: RF008 -> s_nationkey
 |
 24:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n_nationkey
-|  runtime filters: RF002 <- n_nationkey
+|  runtime filters: RF004 <- n_nationkey
 |
 |--28:EXCHANGE [BROADCAST]
 |  |
@@ -274,7 +274,7 @@ PLAN-ROOT SINK
 00:SCAN HDFS [tpch_nested_parquet.supplier s]
    partitions=1/1 files=1 size=43.00MB
    predicates: !empty(s.s_partsupps)
-   runtime filters: RF002 -> s_nationkey
+   runtime filters: RF004 -> s_nationkey
 ====
 # TPCH-Q3
 # Q3 - Shipping Priority Query
@@ -509,7 +509,7 @@ PLAN-ROOT SINK
 |
 15:HASH JOIN [INNER JOIN]
 |  hash predicates: c.c_nationkey = n.n_nationkey
-|  runtime filters: RF002 <- n.n_nationkey
+|  runtime filters: RF004 <- n.n_nationkey
 |
 |--11:SUBPLAN
 |  |
@@ -543,7 +543,7 @@ PLAN-ROOT SINK
    partitions=1/1 files=4 size=292.36MB
    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_nationkey, RF002 -> c.c_nationkey
+   runtime filters: RF000 -> c_nationkey, RF004 -> c.c_nationkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -574,7 +574,7 @@ PLAN-ROOT SINK
 |
 15:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: c.c_nationkey = n.n_nationkey
-|  runtime filters: RF002 <- n.n_nationkey
+|  runtime filters: RF004 <- n.n_nationkey
 |
 |--19:EXCHANGE [BROADCAST]
 |  |
@@ -610,7 +610,7 @@ PLAN-ROOT SINK
    partitions=1/1 files=4 size=292.36MB
    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_nationkey, RF002 -> c.c_nationkey
+   runtime filters: RF000 -> c_nationkey, RF004 -> c.c_nationkey
 ====
 # TPCH-Q6
 # Q6 - Forecasting Revenue Change Query
@@ -705,7 +705,7 @@ PLAN-ROOT SINK
 |
 13:HASH JOIN [INNER JOIN]
 |  hash predicates: s_nationkey = n1.n_nationkey
-|  runtime filters: RF001 <- n1.n_nationkey
+|  runtime filters: RF002 <- n1.n_nationkey
 |
 |--10:SCAN HDFS [tpch_nested_parquet.region.r_nations n1]
 |     partitions=1/1 files=1 size=3.24KB
@@ -715,7 +715,7 @@ PLAN-ROOT SINK
 |
 |--09:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 01:SUBPLAN
 |
@@ -770,7 +770,7 @@ PLAN-ROOT SINK
 |
 13:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: s_nationkey = n1.n_nationkey
-|  runtime filters: RF001 <- n1.n_nationkey
+|  runtime filters: RF002 <- n1.n_nationkey
 |
 |--18:EXCHANGE [BROADCAST]
 |  |
@@ -784,7 +784,7 @@ PLAN-ROOT SINK
 |  |
 |  09:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 01:SUBPLAN
 |
@@ -864,7 +864,7 @@ PLAN-ROOT SINK
 |
 19:HASH JOIN [INNER JOIN]
 |  hash predicates: c_nationkey = n1.n_nationkey
-|  runtime filters: RF001 <- n1.n_nationkey
+|  runtime filters: RF002 <- n1.n_nationkey
 |
 |--12:SUBPLAN
 |  |
@@ -912,7 +912,7 @@ PLAN-ROOT SINK
    partitions=1/1 files=4 size=292.36MB
    predicates: !empty(c.c_orders)
    predicates on o: !empty(o.o_lineitems), o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31'
-   runtime filters: RF001 -> c_nationkey
+   runtime filters: RF002 -> c_nationkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -943,7 +943,7 @@ PLAN-ROOT SINK
 |
 19:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: c_nationkey = n1.n_nationkey
-|  runtime filters: RF001 <- n1.n_nationkey
+|  runtime filters: RF002 <- n1.n_nationkey
 |
 |--25:EXCHANGE [BROADCAST]
 |  |
@@ -997,7 +997,7 @@ PLAN-ROOT SINK
    partitions=1/1 files=4 size=292.36MB
    predicates: !empty(c.c_orders)
    predicates on o: !empty(o.o_lineitems), o_orderdate >= '1995-01-01', o_orderdate <= '1996-12-31'
-   runtime filters: RF001 -> c_nationkey
+   runtime filters: RF002 -> c_nationkey
 ====
 # TPCH-Q9
 # Q9 - Product Type Measure Query
@@ -1319,7 +1319,7 @@ PLAN-ROOT SINK
 |  |
 |  14:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF001 <- n_nationkey
+|  |  runtime filters: RF002 <- n_nationkey
 |  |
 |  |--13:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
 |  |     partitions=1/1 files=1 size=3.24KB
@@ -1336,7 +1336,7 @@ PLAN-ROOT SINK
 |  08:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
 |     predicates: !empty(s.s_partsupps)
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 07:AGGREGATE [FINALIZE]
 |  output: sum(ps_supplycost * ps_availqty)
@@ -1386,7 +1386,7 @@ PLAN-ROOT SINK
 |  |
 |  14:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF001 <- n_nationkey
+|  |  runtime filters: RF002 <- n_nationkey
 |  |
 |  |--21:EXCHANGE [BROADCAST]
 |  |  |
@@ -1405,7 +1405,7 @@ PLAN-ROOT SINK
 |  08:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
 |     predicates: !empty(s.s_partsupps)
-|     runtime filters: RF001 -> s_nationkey
+|     runtime filters: RF002 -> s_nationkey
 |
 20:AGGREGATE [FINALIZE]
 |  output: sum:merge(ps_supplycost * ps_availqty)
@@ -1938,7 +1938,7 @@ PLAN-ROOT SINK
 |
 04:HASH JOIN [INNER JOIN]
 |  hash predicates: l_partkey = p_partkey
-|  runtime filters: RF001 <- p_partkey
+|  runtime filters: RF002 <- p_partkey
 |
 |--01:SCAN HDFS [tpch_nested_parquet.part p]
 |     partitions=1/1 files=1 size=6.24MB
@@ -1947,7 +1947,7 @@ PLAN-ROOT SINK
 |
 00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
    partitions=1/1 files=4 size=292.36MB
-   runtime filters: RF000 -> l.l_partkey, RF001 -> l_partkey
+   runtime filters: RF000 -> l.l_partkey, RF002 -> l_partkey
 ---- DISTRIBUTEDPLAN
 PLAN-ROOT SINK
 |
@@ -1981,7 +1981,7 @@ PLAN-ROOT SINK
 |
 04:HASH JOIN [INNER JOIN, BROADCAST]
 |  hash predicates: l_partkey = p_partkey
-|  runtime filters: RF001 <- p_partkey
+|  runtime filters: RF002 <- p_partkey
 |
 |--07:EXCHANGE [BROADCAST]
 |  |
@@ -1992,7 +1992,7 @@ PLAN-ROOT SINK
 |
 00:SCAN HDFS [tpch_nested_parquet.customer.c_orders.o_lineitems l]
    partitions=1/1 files=4 size=292.36MB
-   runtime filters: RF000 -> l.l_partkey, RF001 -> l_partkey
+   runtime filters: RF000 -> l.l_partkey, RF002 -> l_partkey
 ====
 # TPCH-Q18
 # Q18 - Large Value Customer Query
@@ -2216,7 +2216,7 @@ PLAN-ROOT SINK
 |  |
 |  09:HASH JOIN [INNER JOIN]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF003 <- n_nationkey
+|  |  runtime filters: RF006 <- n_nationkey
 |  |
 |  |--05:SCAN HDFS [tpch_nested_parquet.region.r_nations n]
 |  |     partitions=1/1 files=1 size=3.24KB
@@ -2233,7 +2233,7 @@ PLAN-ROOT SINK
 |  00:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
 |     predicates: !empty(s.s_partsupps)
-|     runtime filters: RF003 -> s_nationkey
+|     runtime filters: RF006 -> s_nationkey
 |
 08:AGGREGATE [FINALIZE]
 |  output: sum(l_quantity)
@@ -2278,7 +2278,7 @@ PLAN-ROOT SINK
 |  |
 |  09:HASH JOIN [INNER JOIN, BROADCAST]
 |  |  hash predicates: s_nationkey = n_nationkey
-|  |  runtime filters: RF003 <- n_nationkey
+|  |  runtime filters: RF006 <- n_nationkey
 |  |
 |  |--16:EXCHANGE [BROADCAST]
 |  |  |
@@ -2297,7 +2297,7 @@ PLAN-ROOT SINK
 |  00:SCAN HDFS [tpch_nested_parquet.supplier s]
 |     partitions=1/1 files=1 size=43.00MB
 |     predicates: !empty(s.s_partsupps)
-|     runtime filters: RF003 -> s_nationkey
+|     runtime filters: RF006 -> s_nationkey
 |
 15:AGGREGATE [FINALIZE]
 |  output: sum:merge(l_quantity)


Mime
View raw message