public class BasicClustering extends java.lang.Object implements ClusteringInterface
| Constructor and Description |
|---|
BasicClustering()
Initialize a BasicClustering object
|
| Modifier and Type | Method and Description |
|---|---|
void |
addClustDelay()
For a clustered job, we should add clustering delay (by default it is
zero)
|
Task |
addRoot() |
protected Job |
addTasks2Job(java.util.List taskList)
Add a list of task to a new job
|
protected Job |
addTasks2Job(Task task)
Add a task to a new job
|
void |
clean()
Delete the root task
|
java.util.List<Job> |
getJobList()
Gets the job list
|
java.util.Map |
getTask2Job()
Gets the map from task to job
|
java.util.List<File> |
getTaskFiles()
Gets the files
|
java.util.List<Task> |
getTaskList()
Gets the task list
|
void |
run()
The main function of BasicClustering
|
void |
setTaskList(java.util.List<Task> list)
Sets the task list
|
protected void |
updateDependencies()
Update the dependency issues between tasks/jobs
|
public final java.util.List<File> getTaskFiles()
getTaskFiles in interface ClusteringInterfacepublic final void setTaskList(java.util.List<Task> list)
setTaskList in interface ClusteringInterfacelist - task listpublic final java.util.List<Job> getJobList()
getJobList in interface ClusteringInterfacepublic final java.util.List<Task> getTaskList()
getTaskList in interface ClusteringInterfacepublic final java.util.Map getTask2Job()
public void run()
run in interface ClusteringInterfaceprotected final Job addTasks2Job(Task task)
task - the taskprotected final Job addTasks2Job(java.util.List taskList)
taskList - the task listpublic void addClustDelay()
protected final void updateDependencies()
public Task addRoot()
public void clean()