public class DefaultImplementation extends Object implements Implementation
Modifier and Type | Field and Description |
---|---|
static String |
COMPLETE_TRANSFORMATION_NAME
The complete TC name for kickstart.
|
static String |
DERIVATION_NAME
The logical name of the transformation that creates directories on the
remote execution pools.
|
static String |
DERIVATION_NAMESPACE
The derivation namespace for the create dir jobs.
|
static String |
DERIVATION_VERSION
The version number for the derivations for create dir jobs.
|
static String |
EXECUTABLE_BASENAME
The basename of the pegasus cleanup executable.
|
protected LogManager |
mLogger
The handle to the logging object.
|
protected PegasusProperties |
mProps
The handle to the pegasus properties.
|
protected SiteStore |
mSiteStore
The handle to the SiteStore.
|
protected TransformationCatalog |
mTCHandle
The handle to the transformation catalog.
|
protected boolean |
mUseMkdir
Whether we want to use dirmanager or mkdir directly.
|
static String |
PATH_VALUE
The path to be set for create dir jobs.
|
static String |
POSTSCRIPT_ARGUMENTS_FOR_ONLY_ROTATING_LOG_FILE
The arguments for pegasus-exitcode when you only want the log files to be rotated.
|
static String |
TRANSFORMATION_NAME
The logical name of the transformation that creates directories on the
remote execution pools.
|
static String |
TRANSFORMATION_NAMESPACE
The transformation namespace for the create dir jobs.
|
static String |
TRANSFORMATION_VERSION
The version number for the derivations for create dir jobs.
|
VERSION
Constructor and Description |
---|
DefaultImplementation() |
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
defaultTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected String |
getCreateDirJobExecutionSite(String site,
String directoryURL)
Determines the site where the create dir job should be run , looking at the
directory URL passed.
|
void |
initialize(PegasusBag bag)
Intializes the class.
|
Job |
makeCreateDirJob(String site,
String name,
String directoryURL)
It creates a make directoryURL job that creates a directoryURL on the remote pool
using the perl executable that Gaurang wrote.
|
public static final String TRANSFORMATION_NAMESPACE
public static final String TRANSFORMATION_NAME
public static final String TRANSFORMATION_VERSION
public static final String EXECUTABLE_BASENAME
public static final String PATH_VALUE
public static final String POSTSCRIPT_ARGUMENTS_FOR_ONLY_ROTATING_LOG_FILE
public static final String COMPLETE_TRANSFORMATION_NAME
public static final String DERIVATION_NAMESPACE
public static final String DERIVATION_NAME
public static final String DERIVATION_VERSION
protected TransformationCatalog mTCHandle
protected SiteStore mSiteStore
protected LogManager mLogger
protected PegasusProperties mProps
protected boolean mUseMkdir
public void initialize(PegasusBag bag)
initialize
in interface Implementation
bag
- bag of initialization objectspublic Job makeCreateDirJob(String site, String name, String directoryURL)
makeCreateDirJob
in interface Implementation
site
- the site for which the create dir job is to be created.name
- the name that is to be assigned to the job.directoryURL
- the externally accessible URL to the directoryURL that is
createdprivate TransformationCatalogEntry defaultTCEntry(String site)
site
- the site for which the default entry is required.protected String getCreateDirJobExecutionSite(String site, String directoryURL)
site
- the site where the directory is to be createddirectoryURL
- the URL to the directory.