| java.lang.Object
 org.griphyn.cPlanner.engine.cleanup.InPlace
| InPlace | | public class InPlace implements Strategy(Code) | | This generates cleanup jobs in the workflow itself.
author:
Arun ramakrishnan
author:
Karan Vahi
version:
$Revision: 50 $ |
| Field Summary | |
| final public static String | CLEANUP_JOB_PREFIX
The prefix for CLEANUP_JOB ID i.e prefix+the parent compute_job ID becomes
ID of the cleanup job. |
| Method Summary | |
| public Graph | addCleanupJobs(Graph workflow)
Adds cleanup jobs to the workflow.
Parameters:
workflow - the workflow to add cleanup jobs to. | | protected void | applyJobPriorities(Graph workflow)
Adds job priorities to the jobs in the workflow on the basis of
the levels in the traversal order given by the iterator. | | protected String | generateCleanupID(SubInfo job)
Returns the identifier that is to be assigned to cleanup job.
Parameters:
job - the job with which the cleanup job is primarily associated. | | protected void | reset()
Resets the internal data structures. | | protected boolean | typeNeedsCleanUp(int type)
Checks to see which job types are required to be looked at for cleanup.
COMPUTE_JOB , STAGE_OUT_JOB , INTER_POOL_JOB are the ones that need
cleanup
Parameters:
type - the type of the job. |
| CLEANUP_JOB_PREFIX | | final public static String CLEANUP_JOB_PREFIX(Code) | | The prefix for CLEANUP_JOB ID i.e prefix+the parent compute_job ID becomes
ID of the cleanup job.
|
| InPlace | | public InPlace(PegasusProperties properties, PlannerOptions options)(Code) | | Creates a new instance of InPlace
Parameters:
properties - the properties passed to the planner.
Parameters:
options - the options passed to the planner. |
| addCleanupJobs | | public Graph addCleanupJobs(Graph workflow)(Code) | | Adds cleanup jobs to the workflow.
Parameters:
workflow - the workflow to add cleanup jobs to. the workflow with cleanup jobs added to it. |
| applyJobPriorities | | protected void applyJobPriorities(Graph workflow)(Code) | | Adds job priorities to the jobs in the workflow on the basis of
the levels in the traversal order given by the iterator. Later on
this would be a separate refiner.
Parameters:
workflow - the workflow on which to apply job priorities. |
| generateCleanupID | | protected String generateCleanupID(SubInfo job)(Code) | | Returns the identifier that is to be assigned to cleanup job.
Parameters:
job - the job with which the cleanup job is primarily associated. the identifier for a cleanup job. |
| reset | | protected void reset()(Code) | | Resets the internal data structures.
|
| typeNeedsCleanUp | | protected boolean typeNeedsCleanUp(int type)(Code) | | Checks to see which job types are required to be looked at for cleanup.
COMPUTE_JOB , STAGE_OUT_JOB , INTER_POOL_JOB are the ones that need
cleanup
Parameters:
type - the type of the job. boolean |
|
|