| Method Summary |
|
| public boolean | doStatWithKickstart()
Return a boolean indicating whether to turn the stat option for kickstart
on or not. |
| public boolean | executeOnWorkerNode()
Returns a boolean indicating whether to have jobs executing on worker
node tmp or not. |
| public boolean | generateKickstartExtraOptions()
Returns a boolean indicating whehter to pass extra options to kickstart
or not. |
| public boolean | generateLOFFiles()
Return a boolean indicating whether to generate the LOF files for the jobs
or not. |
| public String | getAllIgnoredSites()
Returns a comma separated list of sites, from which to ignore data
transfers for all sites. |
| public String | getAllPreferredSites()
Returns a comma separated list of sites, from which to prefer data
transfers for all sites. |
| public String | getChmodDisabledSites()
Returns the list of sites for which the chmod job creation has to be
disabled for executable staging. |
| public String | getClustererLabelKey()
Returns the key that is to be used as a label key, for labelled
clustering. |
| public String | getCollapseFactors()
Returns a comma separated list for the node collapsing criteria for the
execution pools. |
| public String | getCondorPeriodicReleaseValue()
Returns the number of release attempts that are written into the condor
submit files. |
| public String | getCondorPeriodicRemoveValue()
Returns the number of release attempts that are attempted before
Condor removes the job from the queue and marks it as failed. |
| public String | getCondorRetryValue()
Returns the number of times Condor should retry running a job in case
of failure. |
| public String | getCreateDirClass()
Returns the name of the class that the user wants, to insert the
create directory jobs in the graph in case of creating random
directories. |
| public String | getCredName()
Returns the credential name to be used for the stork transfer jobs. |
| public String | getDAXCallback()
Returns the DAXCallback that is to be used while parsing the DAX. |
| public String | getDAXSchemaLocation()
Returns the location of the schema for the DAX. |
| public String | getDAXSchemaLocation(String defaultLocation)
Returns the location of the schema for the DAX.
Referred to by the "pegasus.schema.dax" property.
Parameters:
defaultLocation - the default location to the schema. |
| public String | getDefaultPathToCondorKickstart()
Returns the default path to the condor kickstart. |
| public String | getDefaultPathToSC()
Returns the default path to the site catalog file. |
| public String | getDefaultPathToTC()
Returns the default path to the transformation catalog. |
| public String | getExecDirectory()
Returns the execution directory suffix or absolute specified
that is appended/replaced to the exec-mount-point specified in the
pool catalog for the various pools. |
| public String | getGridFTPTimeout()
Returns the timeout value in seconds after which to timeout in case of
opening sockets to grid ftp server. |
| public String | getGridStart()
Returns the GRIDSTART that is to be used to launch the jobs on the grid. |
| public long | getGridStartInvokeLength()
Returns the trigger value for invoking an application through kickstart
using kickstart. |
| public String | getHorizontalPartitionerBundleValue(String name)
Returns the bundle value for a particular transformation.
Referred to by the "pegasus.partitioner.horziontal.bundle.[txname]" property,
where [txname] is replaced by the name passed an input to this function.
Parameters:
name - the logical name of the transformation. |
| public String | getHorizontalPartitionerCollapseValue(String name)
Returns the collapse value for a particular transformation.
Referred to by the "pegasus.partitioner.horziontal.collapse.[txname]" property,
where [txname] is replaced by the name passed an input to this function.
Parameters:
name - the logical name of the transformation. |
| public static PegasusProperties | getInstance()
Returns an instance to this properties object. |
| public static PegasusProperties | getInstance(String propFileName)
Returns an instance to this properties object.
Parameters:
propFileName - name of the properties file to picked from$PEGASUS_HOME/etc/ directory. |
| public String | getJobAggregator()
Returns what job aggregator is to be used to aggregate multiple
compute jobs into a single condor job. |
| public String | getJobPriority()
Returns the default priority that needs to be applied to all job. |
| public String | getLocalPoolEnvVar()
Return returns the environment string specified for the local pool. |
| public String | getLog4JLogFile()
Returns the location of the local log file where you want the messages to
be logged. |
| public String | getLoggingFile()
Returns the file to which all the logging needs to be directed to. |
| public List | getMatchingProperties(String prefix, boolean system)
Returns the properties matching a particular prefix as a list of
sorted name value pairs, where name is the full name of the matching
property (including the prefix) and value is it's value in the properties
file.
Parameters:
prefix - the prefix for the property names.
Parameters:
system - boolean indicating whether to match only System propertiesor all including the ones in the property file. |
| public String | getMetricsLogFile()
Returns the path to the file that is used to be logging metrics
Referred to by the "pegasus.log.metrics.file" property. |
| public int | getMinimumRemoteSchedulerTime(String key)
Returns the minimum walltimes that need to be enforced.
Referred to by "pegasus.scheduler.remote.min.[key]" property.
Parameters:
key - the appropriate globus RSL key. |
| public String | getNumOfTransferProcesses()
It returns the number of processes of g-u-c that the transfer script needs to
spawn to do the transfers. |
| public String | getNumOfTransferStreams()
It returns the number of streams that each transfer process uses to do the
ftp transfer. |
| public String | getPDAXSchemaLocation(String defaultLocation)
Returns the location of the schema for the PDAX.
Referred to by the "pegasus.schema.pdax" property
Parameters:
defaultLocation - the default location to the schema. |
| public String | getPOSTScript()
Returns the postscript to use with the jobs in the workflow. |
| public String | getPOSTScriptArguments()
Returns the argument string containing the arguments by which exitcode is
invoked. |
| public String | getPOSTScriptPath(String value)
Returns the path to the exitcode executable to be used.
Referred to by the "pegasus.exitcode.path.[value]" property, where [value]
is replaced by the value passed an input to this function.
Parameters:
value - the short name of the postscript whose path we want. |
| public String | getPOSTScriptScope()
Returns the mode adding the postscripts for the jobs. |
| public String | getPartitionParsingMode()
Returns the mode for parsing the dax while writing out the partitioned
daxes. |
| public String | getPartitionerLabelKey()
Returns the key that is to be used as a label key, for labelled
partitioning. |
| public String | getPegasusHome()
Accessor: Obtains the root directory of the Pegasus runtime
system. |
| public String | getPoolFile()
Returns the path to the pool file. |
| public String | getPoolMode()
Returns the mode to be used for accessing the pool information. |
| public String | getPoolSchemaLocation()
Returns the location of the schema for the DAX. |
| public String | getPoolSchemaLocation(String defaultLocation)
Returns the location of the schema for the site catalog file.
Referred to by the "pegasus.schema.sc" property
Parameters:
defaultLocation - the default location where the schema should beif no other location is specified. |
| public String | getPrescriptArguments()
Returns the argument string containing the arguments by which prescript is
invoked. |
| public String | getPropertiesInSubmitDirectory()
Returns the path to the property file that has been writting out in
the submit directory. |
| public String | getProperty(String key)
It allows you to get any property from the property file without going
through the corresponding accesor function in this class. |
| public String | getRLIURL()
Returns the url to the RLI of the RLS. |
| public int | getRLSTimeout()
It returns the timeout value in seconds after which to timeout in case of
no activity from the RLS. |
| public String | getRefinementProvenanceStore()
Returns the provenance store to use to log the refiner actions. |
| public String | getRemoteSchedulerMaxWallTimes()
Returns the maxwalltimes for the various pools that need to be appended
to the RSL String while creating the submit files. |
| public String | getRemoteSchedulerProjects()
Returns the project names that need to be appended to the RSL String
while creating the submit files. |
| public String | getRemoteSchedulerQueues()
Returns the queue names that need to be appended to the RSL String while
creating the submit files. |
| public String | getReplicaMode()
Returns the replica mode. |
| public String | getReplicaSelector()
Returns the name of the selector to be used for selection amongst the
various replicas of a single lfn. |
| public String | getSLSTransferImplementation()
Returns the sls transfer implementation that is to be used for constructing
the transfer jobs. |
| public String | getSiteSelectorKeep()
Returns a value designating whether we need to keep the temporary files
that are passed to the external site selectors. |
| public String | getSiteSelectorMode()
Returns the class name of the site selector, that needs to be invoked to do
the site selection. |
| public String | getSiteSelectorPath()
Returns the path to the external site selector that needs to be called
out to make the decision of site selection. |
| public int | getSiteSelectorTimeout()
It returns the timeout value in seconds after which to timeout in case of
no activity from the external site selector. |
| public String | getStagingDelimiter()
Returns the delimiter to be used for constructing the staged executable
name, during transfer of executables to remote sites. |
| public String | getStorageDirectory()
Returns the storage directory suffix or absolute specified
that is appended/replaced to the storage-mount-point specified in the
pool catalog for the various pools. |
| public String | getSubmitMode()
Returns which submit mode to be used to submit the jobs on to the grid. |
| public File | getSysConfDir()
Accessor to $PEGASUS_HOME/etc. |
| public String | getTCMapperMode()
Returns the mode for loading the transformation mapper that sits in
front of the transformation catalog. |
| public String | getTCMode()
Returns the mode to be used for accessing the Transformation Catalog. |
| public String | getTCPath()
Returns the location of the transformation catalog. |
| public String | getTXSelectorMode()
Returns the mode for loading the transformation selector that selects
amongst the various candidate transformation catalog entry objects. |
| public String | getThirdPartySites(String property)
Returns the comma separated list of third party sites, specified in the
properties.
Parameters:
property - property name. |
| public String | getThirdPartySitesRemote(String property)
Returns the comma separated list of third party sites for which
the third party transfers are executed on the remote sites.
Parameters:
property - property name. |
| public String | getTransferArguments()
Returns the arguments with which the transfer executable needs
to be invoked. |
| public String | getTransferImplementation()
Returns the transfer implementation that is to be used for constructing
the transfer jobs. |
| public String | getTransferImplementation(String property)
Returns the transfer implementation.
Parameters:
property - property name. |
| public String | getTransferInterPriority()
Returns the priority to be set for the interpool transfer job. |
| public String | getTransferRefiner()
Returns the transfer refiner that is to be used for adding in the
transfer jobs in the workflow
Referred to by the "pegasus.transfer.refiner" property. |
| public String | getTransferStageInPriority()
Returns the priority to be set for the stage in transfer job. |
| public String | getTransferStageOutPriority()
Returns the priority to be set for the stage out transfer job. |
| public boolean | getUseOfSymbolicLinks()
It returns whether the use of symbolic links in case where the source
and destination files happen to be on the same file system. |
| public VDSProperties | getVDSProperties()
Returns the VDSProperties that this object encapsulates. |
| public boolean | jobAggregatorLogGlobal()
Returns what job aggregator is to be used to aggregate multiple
compute jobs into a single condor job. |
| public Properties | matchingSubset(String prefix, boolean keepPrefix)
Extracts a specific property key subset from the known properties.
The prefix may be removed from the keys in the resulting dictionary,
or it may be kept. |
| protected static PegasusProperties | nonSingletonInstance(String propFileName)
To get a reference to the the object. |
| public static PegasusProperties | nonSingletonInstance()
To get a reference to the the object. |
| public boolean | quoteTransferURL()
Returns whether to introduce quotes around url's before handing to
g-u-c and condor. |
| protected static void | sanityCheck(File dir)
Checks the destination location for existence, if it can
be created, if it is writable etc. |
| public boolean | setPostSCRIPTDebugON()
Returns a boolean indicating whether to turn debug on or not for exitcode. |
| public Object | setProperty(String key, String value)
Accessor: Overwrite any properties from within the program.
Parameters:
key - is the key to look up
Parameters:
value - is the new property value to place in the system. |
| public boolean | streamCondorError()
Tells whether to stream condor error or not. |
| public boolean | streamCondorOutput()
Tells whether to stream condor output or not. |
| public boolean | transferProxy()
It specifies if for a job execution the proxy is to be transferred
from the submit host or not. |
| public boolean | treatCacheAsRC()
Returns a boolean indicating whether to treat the entries in the cache
files as a replica catalog or not. |
| public boolean | useCondorQuotingForArguments()
Returns a boolean indicating whether we want to Condor Quote the
arguments of the job or not. |
| public boolean | useDeepStorageDirectoryStructure()
Returns a boolean indicating whether to have a deep storage directory
structure or not while staging out data to the output site. |
| public boolean | useExtendedTimeStamp()
It specifies whether to use the extended timestamp format for generation
of timestamps that are used to create the random directory name, and for
the classads generation. |
| public boolean | useForceInTransfer()
It specifies whether the underlying transfer mechanism being used should
use the force option if available to transfer the files. |
| public boolean | useInvokeInGridStart()
Returns a boolean indicating whether to use invoke in kickstart always
or not. |
| public boolean | useTimestampForDirectoryStructure()
Returns a boolean indicating whether to use timestamp for directory
name creation or not. |
| public boolean | writeOutMetrics()
Returns a boolean indicating whether to write out the planner metrics
or not. |
| public String | writeOutProperties(String directory)
Writes out the properties to a temporary file in the directory passed.
Parameters:
directory - the directory in which the properties file needs tobe written to. |
