mrcnc commented on code in PR #11565:
URL: https://github.com/apache/iceberg/pull/11565#discussion_r1866849501
##########
gcp/src/main/java/org/apache/iceberg/gcp/gcs/GCSFileIO.java:
##########
@@ -242,4 +250,116 @@ private void internalDeleteFiles(Stream<BlobId>
blobIdsToDelete) {
Streams.stream(Iterators.partition(blobIdsToDelete.iterator(),
gcpProperties.deleteBatchSize()))
.forEach(batch -> client().delete(batch));
}
+
+ @Override
+ public boolean recoverFile(String path) {
+ Preconditions.checkArgument(
+ !Strings.isNullOrEmpty(path), "Cannot recover file: path must not be
null or empty");
+
+ try {
+ BlobId blobId = BlobId.fromGsUtilUri(path);
+
+ // first attempt to restore with soft-delete
+ if (recoverSoftDeletedObject(blobId)) {
+ return true;
+ }
+
+ // fallback to restoring by copying the latest version
+ if (recoverLatestVersion(blobId)) {
+ return true;
+ }
+
+ } catch (IllegalArgumentException e) {
+ LOG.warn("Invalid GCS path format: {}", path, e);
+ }
+
+ return false;
+ }
+
+ /**
+ * Attempts to restore a soft-deleted object.
+ *
+ * <p>Requires {@code storage.objects.restore} permission
+ *
+ * <p>See <a
+ *
href="https://cloud.google.com/storage/docs/use-soft-deleted-objects#restore";>docs</a>
+ *
+ * @param blobId the blob identifier
+ * @return {@code true} if blob was recovered, {@code false} if not
+ */
+ protected boolean recoverSoftDeletedObject(BlobId blobId) {
+ try {
+ BucketInfo.SoftDeletePolicy policy =
client().get(blobId.getBucket()).getSoftDeletePolicy();
+ if (Duration.ofSeconds(0).equals(policy.getRetentionDuration())) {
Review Comment:
Also did the same for the bucket versioning check in
https://github.com/apache/iceberg/pull/11565/commits/360eadd351a803f24c901560c461d9ab37d150e6
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
