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 f5bbb9256c Spark: Deprecate constructor with branch in
SparkReadConf/SparkWriteConf (#15591)
f5bbb9256c is described below
commit f5bbb9256c70cb66b662458b3c0b36bfa803471a
Author: Yuya Ebihara <[email protected]>
AuthorDate: Tue Mar 17 09:08:33 2026 +0900
Spark: Deprecate constructor with branch in SparkReadConf/SparkWriteConf
(#15591)
---
.../src/main/java/org/apache/iceberg/spark/SparkReadConf.java | 9 +++++----
.../src/main/java/org/apache/iceberg/spark/SparkWriteConf.java | 5 +++++
2 files changed, 10 insertions(+), 4 deletions(-)
diff --git
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkReadConf.java
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkReadConf.java
index 309d7c4fd1..d5ec726f5b 100644
--- a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkReadConf.java
+++ b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkReadConf.java
@@ -57,8 +57,6 @@ public class SparkReadConf {
private final SparkSession spark;
private final Table table;
- private final String branch;
- private final CaseInsensitiveStringMap options;
private final SparkConfParser confParser;
public SparkReadConf(SparkSession spark, Table table) {
@@ -69,12 +67,15 @@ public class SparkReadConf {
this(spark, table, null, options);
}
+ /**
+ * @deprecated since 1.11.0, will be removed in 1.12.0. Use {@link
#SparkReadConf(SparkSession,
+ * Table, CaseInsensitiveStringMap)} instead.
+ */
+ @Deprecated
public SparkReadConf(
SparkSession spark, Table table, String branch, CaseInsensitiveStringMap
options) {
this.spark = spark;
this.table = table;
- this.branch = branch;
- this.options = options;
this.confParser = new SparkConfParser(spark, table, options);
}
diff --git
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
index 5ad2545ca6..8a629d3a6d 100644
---
a/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
+++
b/spark/v4.1/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
@@ -98,6 +98,11 @@ public class SparkWriteConf {
this(spark, table, null, options);
}
+ /**
+ * @deprecated since 1.11.0, will be removed in 1.12.0. Use {@link
#SparkWriteConf(SparkSession,
+ * Table, CaseInsensitiveStringMap)} instead.
+ */
+ @Deprecated
public SparkWriteConf(
SparkSession spark, Table table, String branch, CaseInsensitiveStringMap
options) {
this.spark = spark;