This is an automated email from the ASF dual-hosted git repository.
apurtell pushed a commit to branch PHOENIX-7876-feature
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/PHOENIX-7876-feature by this
push:
new e177c4c4a4 PHOENIX-7892 Fix MutableIndexIT EXPLAIN assertions for
projection filters (#2511)
e177c4c4a4 is described below
commit e177c4c4a46f4ff81c8d5e03667559421a49837f
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
