This is an automated email from the ASF dual-hosted git repository. asf-gitbox-commits pushed a commit to branch PHOENIX-7876-feature in repository https://gitbox.apache.org/repos/asf/phoenix.git
commit 5884624fd1d88b03ece4c2cc256e4b4bdc343f5f Author: Andrew Purtell <[email protected]> AuthorDate: Wed Jun 10 11:55:40 2026 -0700 PHOENIX-7892 Fix MutableIndexIT EXPLAIN assertions for projection filters (#2511) Co-authored-by: Claude Opus 4.8[1m] <[email protected]> --- .../org/apache/phoenix/end2end/index/MutableIndexIT.java | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexIT.java index 450eafbce8..39225c97e4 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/index/MutableIndexIT.java @@ -408,13 +408,10 @@ public class MutableIndexIT extends ParallelStatsDisabledIT { if (localIndex) { assertPlan(conn, query).iteratorType("PARALLEL 1-WAY").scanType("RANGE SCAN") .table(fullIndexName + "(" + fullTableName + ")").keyRanges(" [1]") - .serverWhereFilter( - "SERVER FILTER BY " + (columnEncoded ? "FIRST KEY" : "EMPTY COLUMN") + " ONLY") - .clientSortAlgo("CLIENT MERGE SORT"); + .serverProjectionFilter(columnEncoded).clientSortAlgo("CLIENT MERGE SORT"); } else { assertPlan(conn, query).iteratorType("PARALLEL 1-WAY").scanType("FULL SCAN") - .table(fullIndexName).serverWhereFilter( - "SERVER FILTER BY " + (columnEncoded ? "FIRST KEY" : "EMPTY COLUMN") + " ONLY"); + .table(fullIndexName).serverProjectionFilter(columnEncoded); } // make sure the data table looks like what we expect rs = conn.createStatement().executeQuery(query); @@ -537,13 +534,10 @@ public class MutableIndexIT extends ParallelStatsDisabledIT { if (localIndex) { assertPlan(conn, query).iteratorType("PARALLEL 1-WAY").scanType("RANGE SCAN") .table(fullIndexName + "(" + fullTableName + ")").keyRanges(" [1]") - .serverWhereFilter( - "SERVER FILTER BY " + (columnEncoded ? "FIRST KEY" : "EMPTY COLUMN") + " ONLY") - .clientSortAlgo("CLIENT MERGE SORT"); + .serverProjectionFilter(columnEncoded).clientSortAlgo("CLIENT MERGE SORT"); } else { assertPlan(conn, query).iteratorType("PARALLEL 1-WAY").scanType("FULL SCAN") - .table(fullIndexName).serverWhereFilter( - "SERVER FILTER BY " + (columnEncoded ? "FIRST KEY" : "EMPTY COLUMN") + " ONLY"); + .table(fullIndexName).serverProjectionFilter(columnEncoded); } // check that the data table matches as expected
