public class Cleanup extends java.lang.Object implements CleanupImplementation
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DERIVATION_NAME
The name of the underlying derivation.
|
static java.lang.String |
DERIVATION_NAMESPACE
The derivation namespace for the job.
|
static java.lang.String |
DERIVATION_VERSION
The derivation version number for the job.
|
static java.lang.String |
DESCRIPTION
A short description of the transfer implementation.
|
static java.lang.String |
EXECUTABLE_BASENAME
The basename of the pegasus cleanup executable.
|
private LogManager |
mLogger
The handle to the logger.
|
protected PlannerCache |
mPlannerCache
Handle to the transient replica catalog.
|
private PegasusProperties |
mProps
The handle to the properties passed to Pegasus.
|
protected SiteStore |
mSiteStore
Handle to the stagingSite catalog.
|
private java.lang.String |
mSubmitDirectory
The submit directory where the output files have to be written.
|
protected TransformationCatalog |
mTCHandle
The handle to the transformation catalog.
|
static java.lang.String |
TRANSFORMATION_NAME
The name of the underlying transformation that is queried for in the
Transformation Catalog.
|
static java.lang.String |
TRANSFORMATION_NAMESPACE
The transformation namespace for the job.
|
static java.lang.String |
TRANSFORMATION_VERSION
The version number for the job.
|
DEFAULT_CLEANUP_CATEGORY_KEY, VERSION
Constructor and Description |
---|
Cleanup()
The default constructor.
|
Modifier and Type | Method and Description |
---|---|
Job |
createCleanupJob(java.lang.String id,
java.util.List files,
Job job)
Creates a cleanup job that removes the files from remote working directory.
|
private TransformationCatalogEntry |
defaultTCEntry(java.lang.String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
static java.lang.String |
getCompleteTranformationName()
A convenience method to return the complete transformation name being
used to construct jobs in this class.
|
protected TransformationCatalogEntry |
getTCEntry(java.lang.String site)
Returns the TCEntry object for the rm executable on a grid stagingSite.
|
void |
initialize(PegasusBag bag)
Creates a new instance of InPlace
|
public static final java.lang.String TRANSFORMATION_NAMESPACE
public static final java.lang.String TRANSFORMATION_NAME
public static final java.lang.String TRANSFORMATION_VERSION
public static final java.lang.String DERIVATION_NAMESPACE
public static final java.lang.String DERIVATION_NAME
public static final java.lang.String DERIVATION_VERSION
public static final java.lang.String EXECUTABLE_BASENAME
public static final java.lang.String DESCRIPTION
protected TransformationCatalog mTCHandle
protected SiteStore mSiteStore
protected PlannerCache mPlannerCache
private PegasusProperties mProps
private java.lang.String mSubmitDirectory
private LogManager mLogger
public static java.lang.String getCompleteTranformationName()
public void initialize(PegasusBag bag)
initialize
in interface CleanupImplementation
bag
- the bag of initialization objects.public Job createCleanupJob(java.lang.String id, java.util.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(java.lang.String site)
stagingSite
- the stagingSite corresponding to which the entry is required.private TransformationCatalogEntry defaultTCEntry(java.lang.String site)
stagingSite
- the stagingSite for which the default entry is required.