public class Cleanup extends Object implements CleanupImplementation
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_CLEANUP_CATEGORY_KEY
Default category for registration jobs
|
static String |
DERIVATION_NAME
The name of the underlying derivation.
|
static String |
DERIVATION_NAMESPACE
The derivation namespace for the job.
|
static String |
DERIVATION_VERSION
The derivation version number for the job.
|
static String |
DESCRIPTION
A short description of the transfer implementation.
|
static String |
EXECUTABLE_BASENAME
The basename of the pegasus cleanup executable.
|
static String |
FILE_URL_SCHEME
The scheme name for file url.
|
private LogManager |
mLogger
The handle to the logger.
|
private PegasusProperties |
mProps
The handle to the properties passed to Pegasus.
|
protected SiteStore |
mSiteStore
Handle to the stagingSite catalog.
|
private String |
mSubmitDirectory
The submit directory where the output files have to be written.
|
protected TransformationCatalog |
mTCHandle
The handle to the transformation catalog.
|
protected ReplicaCatalog |
mTransientRC
Handle to the transient replica catalog.
|
static String |
TRANSFORMATION_NAME
The name of the underlying transformation that is queried for in the
Transformation Catalog.
|
static String |
TRANSFORMATION_NAMESPACE
The transformation namespace for the job.
|
static String |
TRANSFORMATION_VERSION
The version number for the job.
|
VERSION
Constructor and Description |
---|
Cleanup()
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 TransformationCatalogEntry |
defaultTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
static String |
getCompleteTranformationName()
A convenience method to return the complete transformation name being
used to construct jobs in this class.
|
protected TransformationCatalogEntry |
getTCEntry(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 String FILE_URL_SCHEME
public static final String DEFAULT_CLEANUP_CATEGORY_KEY
public static final String TRANSFORMATION_NAMESPACE
public static final String TRANSFORMATION_NAME
public static final String TRANSFORMATION_VERSION
public static final String DERIVATION_NAMESPACE
public static final String DERIVATION_NAME
public static final String DERIVATION_VERSION
public static final String EXECUTABLE_BASENAME
public static final String DESCRIPTION
protected TransformationCatalog mTCHandle
protected SiteStore mSiteStore
protected ReplicaCatalog mTransientRC
private PegasusProperties mProps
private String mSubmitDirectory
private LogManager mLogger
public static String getCompleteTranformationName()
public void initialize(PegasusBag bag)
initialize
in interface CleanupImplementation
bag
- the bag of initialization objects.public 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)
stagingSite
- the stagingSite corresponding to which the entry is required.private TransformationCatalogEntry defaultTCEntry(String site)
stagingSite
- the stagingSite for which the default entry is required.Copyright © 2011 The University of Southern California. All Rights Reserved.