Core: Generalize Util.blockLocations (#11053)

apache · Dec 4, 2024 · 8c04bcb · 8c04bcb
1 parent 3278b69
commit 8c04bcb
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/core/src/main/java/org/apache/iceberg/hadoop/Util.java b/core/src/main/java/org/apache/iceberg/hadoop/Util.java
@@ -59,9 +59,18 @@ public static FileSystem getFs(Path path, Configuration conf) {
     }
   }
 
+  /**
+   * @deprecated since 1.8.0, will be removed in 1.9.0; use {@link
+   *     Util#blockLocations(ScanTaskGroup, Configuration)} instead.
+   */
+  @Deprecated
   public static String[] blockLocations(CombinedScanTask task, Configuration conf) {
+    return blockLocations((ScanTaskGroup<FileScanTask>) task, conf);
+  }
+
+  public static String[] blockLocations(ScanTaskGroup<FileScanTask> taskGroup, Configuration conf) {
     Set<String> locationSets = Sets.newHashSet();
-    for (FileScanTask f : task.files()) {
+    for (FileScanTask f : taskGroup.tasks()) {
       Path path = new Path(f.file().location());
       try {
         FileSystem fs = path.getFileSystem(conf);