You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ap...@apache.org on 2026/06/10 18:55:45 UTC
(phoenix) branch PHOENIX-7876-feature updated: PHOENIX-7892 Fix MutableIndexIT EXPLAIN assertions for projection filters (#2511)
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 <ap...@apache.org>
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] <no...@anthropic.com>
---
.../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