This is an automated email from the ASF dual-hosted git repository.
etudenhoefner 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 329a901487 Core: Restrict visibility of spec-by-id API for scan
planning responses (#14485)
329a901487 is described below
commit 329a9014875f1c4ee9fc5071639cf12f281f20de
Author: Prashant Singh <[email protected]>
AuthorDate: Tue Nov 4 13:03:32 2025 +0530
Core: Restrict visibility of spec-by-id API for scan planning responses
(#14485)
---
.../apache/iceberg/rest/responses/BaseScanTaskResponse.java | 12 ++++++++++++
.../rest/responses/FetchPlanningResultResponseParser.java | 1 +
.../iceberg/rest/responses/FetchScanTasksResponseParser.java | 1 +
.../iceberg/rest/responses/PlanTableScanResponseParser.java | 1 +
4 files changed, 15 insertions(+)
diff --git
a/core/src/main/java/org/apache/iceberg/rest/responses/BaseScanTaskResponse.java
b/core/src/main/java/org/apache/iceberg/rest/responses/BaseScanTaskResponse.java
index b7649618e8..f98a24cf79 100644
---
a/core/src/main/java/org/apache/iceberg/rest/responses/BaseScanTaskResponse.java
+++
b/core/src/main/java/org/apache/iceberg/rest/responses/BaseScanTaskResponse.java
@@ -55,6 +55,10 @@ public abstract class BaseScanTaskResponse implements
RESTResponse {
return deleteFiles;
}
+ /**
+ * @deprecated since 1.11.0, visibility will be reduced in 1.12.0.
+ */
+ @Deprecated
public Map<Integer, PartitionSpec> specsById() {
return specsById;
}
@@ -87,6 +91,10 @@ public abstract class BaseScanTaskResponse implements
RESTResponse {
return self();
}
+ /**
+ * @deprecated since 1.11.0, visibility will be reduced in 1.12.0.
+ */
+ @Deprecated
public B withSpecsById(Map<Integer, PartitionSpec> specs) {
this.specsById = specs;
return self();
@@ -104,6 +112,10 @@ public abstract class BaseScanTaskResponse implements
RESTResponse {
return deleteFiles;
}
+ /**
+ * @deprecated since 1.11.0, visibility will be reduced in 1.12.0.
+ */
+ @Deprecated
public Map<Integer, PartitionSpec> specsById() {
return specsById;
}
diff --git
a/core/src/main/java/org/apache/iceberg/rest/responses/FetchPlanningResultResponseParser.java
b/core/src/main/java/org/apache/iceberg/rest/responses/FetchPlanningResultResponseParser.java
index 925e0f5746..a507d16ab5 100644
---
a/core/src/main/java/org/apache/iceberg/rest/responses/FetchPlanningResultResponseParser.java
+++
b/core/src/main/java/org/apache/iceberg/rest/responses/FetchPlanningResultResponseParser.java
@@ -87,6 +87,7 @@ public class FetchPlanningResultResponseParser {
.withPlanTasks(planTasks)
.withFileScanTasks(fileScanTasks)
.withDeleteFiles(deleteFiles)
+ .withSpecsById(specsById)
.build();
}
}
diff --git
a/core/src/main/java/org/apache/iceberg/rest/responses/FetchScanTasksResponseParser.java
b/core/src/main/java/org/apache/iceberg/rest/responses/FetchScanTasksResponseParser.java
index bfc8a08b90..14ef77b39f 100644
---
a/core/src/main/java/org/apache/iceberg/rest/responses/FetchScanTasksResponseParser.java
+++
b/core/src/main/java/org/apache/iceberg/rest/responses/FetchScanTasksResponseParser.java
@@ -77,6 +77,7 @@ public class FetchScanTasksResponseParser {
TableScanResponseParser.parseFileScanTasks(json, deleteFiles,
specsById, caseSensitive);
return FetchScanTasksResponse.builder()
.withPlanTasks(planTasks)
+ .withSpecsById(specsById)
.withFileScanTasks(fileScanTasks)
.withDeleteFiles(deleteFiles)
.build();
diff --git
a/core/src/main/java/org/apache/iceberg/rest/responses/PlanTableScanResponseParser.java
b/core/src/main/java/org/apache/iceberg/rest/responses/PlanTableScanResponseParser.java
index b99cd369d8..ae07c0074d 100644
---
a/core/src/main/java/org/apache/iceberg/rest/responses/PlanTableScanResponseParser.java
+++
b/core/src/main/java/org/apache/iceberg/rest/responses/PlanTableScanResponseParser.java
@@ -98,6 +98,7 @@ public class PlanTableScanResponseParser {
.withPlanTasks(planTasks)
.withFileScanTasks(fileScanTasks)
.withDeleteFiles(deleteFiles)
+ .withSpecsById(specsById)
.build();
}
}