singhpk234 commented on code in PR #15501:
URL: https://github.com/apache/iceberg/pull/15501#discussion_r2882673729
##########
core/src/main/java/org/apache/iceberg/CatalogUtil.java:
##########
@@ -202,6 +203,18 @@ private static void deleteFiles(FileIO io,
Set<ManifestFile> allManifests) {
});
}
+ /**
+ * Helper to delete files. Bulk deletion is used if possible, otherwise
deletions are done
+ * concurrently for non-bulk FileIO.
+ *
+ * @param io FileIO for deletes
+ * @param files files to delete
+ * @param type type of files being deleted
+ */
+ public static void deleteFiles(FileIO io, Iterable<String> files, String
type) {
Review Comment:
minor: do we need a **new** function which always pass true in concurrent ?
we do have an API which takes all 4 args
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
