Package org.apache.iceberg.spark
Class FileScanTaskSetManager
- java.lang.Object
-
- org.apache.iceberg.spark.FileScanTaskSetManager
-
public class FileScanTaskSetManager extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.Set<java.lang.String>
fetchSetIDs(Table table)
java.util.List<FileScanTask>
fetchTasks(Table table, java.lang.String setID)
static FileScanTaskSetManager
get()
java.util.List<FileScanTask>
removeTasks(Table table, java.lang.String setID)
void
stageTasks(Table table, java.lang.String setID, java.util.List<FileScanTask> tasks)
-
-
-
Method Detail
-
get
public static FileScanTaskSetManager get()
-
stageTasks
public void stageTasks(Table table, java.lang.String setID, java.util.List<FileScanTask> tasks)
-
fetchTasks
public java.util.List<FileScanTask> fetchTasks(Table table, java.lang.String setID)
-
removeTasks
public java.util.List<FileScanTask> removeTasks(Table table, java.lang.String setID)
-
fetchSetIDs
public java.util.Set<java.lang.String> fetchSetIDs(Table table)
-
-