Package org.apache.iceberg.spark
Class ScanTaskSetManager
- java.lang.Object
-
- org.apache.iceberg.spark.ScanTaskSetManager
-
public class ScanTaskSetManager 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)
<T extends ScanTask>
java.util.List<T>fetchTasks(Table table, java.lang.String setId)
static ScanTaskSetManager
get()
<T extends ScanTask>
java.util.List<T>removeTasks(Table table, java.lang.String setId)
<T extends ScanTask>
voidstageTasks(Table table, java.lang.String setId, java.util.List<T> tasks)
-
-
-
Method Detail
-
get
public static ScanTaskSetManager get()
-
stageTasks
public <T extends ScanTask> void stageTasks(Table table, java.lang.String setId, java.util.List<T> tasks)
-
fetchTasks
public <T extends ScanTask> java.util.List<T> fetchTasks(Table table, java.lang.String setId)
-
removeTasks
public <T extends ScanTask> java.util.List<T> removeTasks(Table table, java.lang.String setId)
-
fetchSetIds
public java.util.Set<java.lang.String> fetchSetIds(Table table)
-
-