This is an automated email from the ASF dual-hosted git repository.
huaxingao pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new 0011a85e4d Spark: Migrate RollBackStageTable to use SupportsDeleteV2
(#16211)
0011a85e4d is described below
commit 0011a85e4d28b7bc8ff670a3a0d32a8331d87d0f
Author: drexler-sky <[email protected]>
AuthorDate: Tue May 5 18:06:35 2026 -0700
Spark: Migrate RollBackStageTable to use SupportsDeleteV2 (#16211)
---
.../java/org/apache/iceberg/spark/RollbackStagedTable.java | 10 +++++-----
.../java/org/apache/iceberg/spark/RollbackStagedTable.java | 10 +++++-----
.../java/org/apache/iceberg/spark/RollbackStagedTable.java | 10 +++++-----
.../java/org/apache/iceberg/spark/RollbackStagedTable.java | 10 +++++-----
4 files changed, 20 insertions(+), 20 deletions(-)
diff --git
a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
index bc8a966488..f170927752 100644
---
a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
+++
b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
@@ -24,17 +24,17 @@ import java.util.function.Consumer;
import java.util.function.Function;
import org.apache.spark.sql.connector.catalog.Identifier;
import org.apache.spark.sql.connector.catalog.StagedTable;
-import org.apache.spark.sql.connector.catalog.SupportsDelete;
+import org.apache.spark.sql.connector.catalog.SupportsDeleteV2;
import org.apache.spark.sql.connector.catalog.SupportsRead;
import org.apache.spark.sql.connector.catalog.SupportsWrite;
import org.apache.spark.sql.connector.catalog.Table;
import org.apache.spark.sql.connector.catalog.TableCapability;
import org.apache.spark.sql.connector.catalog.TableCatalog;
import org.apache.spark.sql.connector.expressions.Transform;
+import org.apache.spark.sql.connector.expressions.filter.Predicate;
import org.apache.spark.sql.connector.read.ScanBuilder;
import org.apache.spark.sql.connector.write.LogicalWriteInfo;
import org.apache.spark.sql.connector.write.WriteBuilder;
-import org.apache.spark.sql.sources.Filter;
import org.apache.spark.sql.types.StructType;
import org.apache.spark.sql.util.CaseInsensitiveStringMap;
@@ -58,7 +58,7 @@ import org.apache.spark.sql.util.CaseInsensitiveStringMap;
* #capabilities()}.
*/
public class RollbackStagedTable
- implements StagedTable, SupportsRead, SupportsWrite, SupportsDelete {
+ implements StagedTable, SupportsRead, SupportsWrite, SupportsDeleteV2 {
private final TableCatalog catalog;
private final Identifier ident;
private final Table table;
@@ -106,8 +106,8 @@ public class RollbackStagedTable
}
@Override
- public void deleteWhere(Filter[] filters) {
- call(SupportsDelete.class, t -> t.deleteWhere(filters));
+ public void deleteWhere(Predicate[] predicates) {
+ call(SupportsDeleteV2.class, t -> t.deleteWhere(predicates));
}
@Override
diff --git
a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
index bc8a966488..f170927752 100644
---
a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
+++
b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
@@ -24,17 +24,17 @@ import java.util.function.Consumer;
import java.util.function.Function;
import org.apache.spark.sql.connector.catalog.Identifier;
import org.apache.spark.sql.connector.catalog.StagedTable;
-import org.apache.spark.sql.connector.catalog.SupportsDelete;
+import org.apache.spark.sql.connector.catalog.SupportsDeleteV2;
import org.apache.spark.sql.connector.catalog.SupportsRead;
import org.apache.spark.sql.connector.catalog.SupportsWrite;
import org.apache.spark.sql.connector.catalog.Table;
import org.apache.spark.sql.connector.catalog.TableCapability;
import org.apache.spark.sql.connector.catalog.TableCatalog;
import org.apache.spark.sql.connector.expressions.Transform;
+import org.apache.spark.sql.connector.expressions.filter.Predicate;
import org.apache.spark.sql.connector.read.ScanBuilder;
import org.apache.spark.sql.connector.write.LogicalWriteInfo;
import org.apache.spark.sql.connector.write.WriteBuilder;
-import org.apache.spark.sql.sources.Filter;
import org.apache.spark.sql.types.StructType;
import org.apache.spark.sql.util.CaseInsensitiveStringMap;
@@ -58,7 +58,7 @@ import org.apache.spark.sql.util.CaseInsensitiveStringMap;
* #capabilities()}.
*/
public class RollbackStagedTable
- implements StagedTable, SupportsRead, SupportsWrite, SupportsDelete {
+ implements StagedTable, SupportsRead, SupportsWrite, SupportsDeleteV2 {
private final TableCatalog catalog;
private final Identifier ident;
private final Table table;
@@ -106,8 +106,8 @@ public class RollbackStagedTable
}
@Override
- public void deleteWhere(Filter[] filters) {
- call(SupportsDelete.class, t -> t.deleteWhere(filters));
+ public void deleteWhere(Predicate[] predicates) {
+ call(SupportsDeleteV2.class, t -> t.deleteWhere(predicates));
}
@Override
diff --git
a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
index bc8a966488..f170927752 100644
---
a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
+++
b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
@@ -24,17 +24,17 @@ import java.util.function.Consumer;
import java.util.function.Function;
import org.apache.spark.sql.connector.catalog.Identifier;
import org.apache.spark.sql.connector.catalog.StagedTable;
-import org.apache.spark.sql.connector.catalog.SupportsDelete;
+import org.apache.spark.sql.connector.catalog.SupportsDeleteV2;
import org.apache.spark.sql.connector.catalog.SupportsRead;
import org.apache.spark.sql.connector.catalog.SupportsWrite;
import org.apache.spark.sql.connector.catalog.Table;
import org.apache.spark.sql.connector.catalog.TableCapability;
import org.apache.spark.sql.connector.catalog.TableCatalog;
import org.apache.spark.sql.connector.expressions.Transform;
+import org.apache.spark.sql.connector.expressions.filter.Predicate;
import org.apache.spark.sql.connector.read.ScanBuilder;
import org.apache.spark.sql.connector.write.LogicalWriteInfo;
import org.apache.spark.sql.connector.write.WriteBuilder;
-import org.apache.spark.sql.sources.Filter;
import org.apache.spark.sql.types.StructType;
import org.apache.spark.sql.util.CaseInsensitiveStringMap;
@@ -58,7 +58,7 @@ import org.apache.spark.sql.util.CaseInsensitiveStringMap;
* #capabilities()}.
*/
public class RollbackStagedTable
- implements StagedTable, SupportsRead, SupportsWrite, SupportsDelete {
+ implements StagedTable, SupportsRead, SupportsWrite, SupportsDeleteV2 {
private final TableCatalog catalog;
private final Identifier ident;
private final Table table;
@@ -106,8 +106,8 @@ public class RollbackStagedTable
}
@Override
- public void deleteWhere(Filter[] filters) {
- call(SupportsDelete.class, t -> t.deleteWhere(filters));
+ public void deleteWhere(Predicate[] predicates) {
+ call(SupportsDeleteV2.class, t -> t.deleteWhere(predicates));
}
@Override
diff --git
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
index bc8a966488..f170927752 100644
---
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
+++
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/RollbackStagedTable.java
@@ -24,17 +24,17 @@ import java.util.function.Consumer;
import java.util.function.Function;
import org.apache.spark.sql.connector.catalog.Identifier;
import org.apache.spark.sql.connector.catalog.StagedTable;
-import org.apache.spark.sql.connector.catalog.SupportsDelete;
+import org.apache.spark.sql.connector.catalog.SupportsDeleteV2;
import org.apache.spark.sql.connector.catalog.SupportsRead;
import org.apache.spark.sql.connector.catalog.SupportsWrite;
import org.apache.spark.sql.connector.catalog.Table;
import org.apache.spark.sql.connector.catalog.TableCapability;
import org.apache.spark.sql.connector.catalog.TableCatalog;
import org.apache.spark.sql.connector.expressions.Transform;
+import org.apache.spark.sql.connector.expressions.filter.Predicate;
import org.apache.spark.sql.connector.read.ScanBuilder;
import org.apache.spark.sql.connector.write.LogicalWriteInfo;
import org.apache.spark.sql.connector.write.WriteBuilder;
-import org.apache.spark.sql.sources.Filter;
import org.apache.spark.sql.types.StructType;
import org.apache.spark.sql.util.CaseInsensitiveStringMap;
@@ -58,7 +58,7 @@ import org.apache.spark.sql.util.CaseInsensitiveStringMap;
* #capabilities()}.
*/
public class RollbackStagedTable
- implements StagedTable, SupportsRead, SupportsWrite, SupportsDelete {
+ implements StagedTable, SupportsRead, SupportsWrite, SupportsDeleteV2 {
private final TableCatalog catalog;
private final Identifier ident;
private final Table table;
@@ -106,8 +106,8 @@ public class RollbackStagedTable
}
@Override
- public void deleteWhere(Filter[] filters) {
- call(SupportsDelete.class, t -> t.deleteWhere(filters));
+ public void deleteWhere(Predicate[] predicates) {
+ call(SupportsDeleteV2.class, t -> t.deleteWhere(predicates));
}
@Override
