public class RM extends Object implements CleanupImplementation
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_PRIORITY_KEY
The default priority key associated with the cleanup jobs.
|
static String |
DEFAULT_RM_LOCATION
The default path to rm executable.
|
static String |
DEFAULT_RM_LOGICAL_NAME
The default logical name to rm executable.
|
private PegasusProperties |
mProps
The handle to the properties passed to Pegasus.
|
protected SiteStore |
mSiteStore
Handle to the site catalog.
|
protected TransformationCatalog |
mTCHandle
The handle to the transformation catalog.
|
DEFAULT_CLEANUP_CATEGORY_KEY, VERSION
Constructor and Description |
---|
RM()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
Job |
createCleanupJob(String id,
List files,
Job job)
Creates a cleanup job that removes the files from remote working directory.
|
private static TransformationCatalogEntry |
defaultTCEntry()
Returns a default TransformationCatalogEntry object for the rm executable.
|
protected TransformationCatalogEntry |
getTCEntry(String site)
Returns the TCEntry object for the rm executable on a grid site.
|
void |
initialize(PegasusBag bag)
Intializes the class.
|
public static final String DEFAULT_RM_LOGICAL_NAME
public static final String DEFAULT_RM_LOCATION
public static final String DEFAULT_PRIORITY_KEY
protected TransformationCatalog mTCHandle
protected SiteStore mSiteStore
private PegasusProperties mProps
public void initialize(PegasusBag bag)
initialize
in interface CleanupImplementation
bag
- bag of initialization objectspublic Job createCleanupJob(String id, List files, Job job)
createCleanupJob
in interface CleanupImplementation
id
- the identifier to be assigned to the job.files
- the list of PegasusFile
that need to be
cleaned up.job
- the primary compute job with which this cleanup job is associated.protected TransformationCatalogEntry getTCEntry(String site)
site
- the site corresponding to which the entry is required.private static TransformationCatalogEntry defaultTCEntry()
TransformationCatalogEntry