Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Abstract.mProps
The object holding all the properties pertaining to Pegasus.
|
Modifier and Type | Method and Description |
---|---|
static LogManager |
LogManagerFactory.loadInstance(PegasusProperties properties)
Loads the appropriate LogManager class as specified by properties.
|
static LogFormatter |
LogFormatterFactory.loadInstance(PegasusProperties properties)
Loads the appropriate LogFormatter class as specified by properties.
|
static LogManager |
LogManagerFactory.loadSingletonInstance(PegasusProperties properties)
Loads the appropriate LogManager class as specified by properties.
|
Modifier and Type | Method and Description |
---|---|
static ReplicaCatalog |
ReplicaFactory.loadInstance(PegasusProperties props)
Connects the interface with the replica catalog implementation.
|
Modifier and Type | Method and Description |
---|---|
static SiteCatalog |
SiteFactory.loadInstance(PegasusProperties properties)
Connects the interface with the site catalog implementation.
|
Modifier and Type | Method and Description |
---|---|
private boolean |
SiteStore.hashedOutputMapperUsed(PegasusProperties properties)
Returns a boolean indicating whether the Hashed Output Mapper was used or
not
|
void |
SiteStore.setForPlannerUse(PegasusProperties properties,
PlannerOptions options)
A setter method that is to be set to use getWorkDirectory functions, correctly.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
PoolInfoProvider.mProps
The object holding all the properties pertaining to Pegasus.
|
Modifier and Type | Method and Description |
---|---|
static PoolInfoProvider |
SiteFactory.loadInstance(PegasusProperties properties,
boolean singleton)
Connects the interface with the site catalog implementation.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Mapper.mProps
Handle to Pegasus Properties
|
Modifier and Type | Method and Description |
---|---|
static TransformationCatalog |
TransformationFactory.loadInstance(PegasusProperties properties)
Connects the interface with the transformation catalog implementation.
|
static TransformationCatalog |
TransformationFactory.loadInstance(PegasusProperties properties,
LogManager logger)
Connects the interface with the transformation catalog implementation.
|
Modifier and Type | Field and Description |
---|---|
private PegasusProperties |
Text.mProps
The handle to the properties object.
|
private PegasusProperties |
File.mProps
The handle to the properties object.
|
Modifier and Type | Method and Description |
---|---|
static WorkCatalog |
WorkFactory.loadInstance(PegasusProperties props)
Connects the interface with the work catalog implementation.
|
Modifier and Type | Field and Description |
---|---|
private PegasusProperties |
PlannerCache.mProps
The PegasusProperties
|
private PegasusProperties |
PegasusBag.mProps
The handle to the
PegasusProperties . |
Modifier and Type | Method and Description |
---|---|
PegasusProperties |
PegasusBag.getPegasusProperties()
A convenice method to get PegasusProperties
|
Modifier and Type | Method and Description |
---|---|
void |
PlannerMetrics.setApplicationMetrics(PegasusProperties properties)
Sets the app metrics that need to be forwarded.
|
void |
Job.updateProfiles(PegasusProperties properties)
Updates all the profile namespaces with the information specified by the
user in the properties file, that apply to this job.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
RCClient.m_pegasus_props
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
Executable.mProps
The object holding all the properties pertaining to Pegasus.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
RCClient.connect(PegasusProperties properties)
Connects the interface with the replica catalog implementation.
|
private String |
CPlanner.determineRootWorkflowUUID(ADag dag,
PlannerOptions options,
PegasusProperties properties)
Determines the workflow uuid for a workflow
|
private List<TransformationCatalogEntry> |
TCConverter.parseTC(PegasusProperties pegasusProperties)
Parses the input format specified in the properties file and returns list of TransfromationCatalogEntry
|
String |
PartitionDAX.partitionDAX(PegasusProperties properties,
String daxFile,
String directory,
String type) |
protected void |
Executable.setupLogging(LogManager logger,
PegasusProperties properties)
Sets up the logging options for this class.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Abstract.mProps
The handle to the properties object holding all the properties.
|
protected PegasusProperties |
Horizontal.mProps
The handle to the properties object holding all the properties.
|
Modifier and Type | Method and Description |
---|---|
static Partitioner |
ClustererFactory.loadPartitioner(PegasusProperties properties,
String type,
GraphNode root,
Map graph)
Loads the appropriate partitioner on the basis of the clustering type
specified in the options passed to the planner.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Abstract.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
JobAggregatorInstanceFactory.mProps
The handle to the properties object holding all the properties.
|
Modifier and Type | Field and Description |
---|---|
private PegasusProperties |
GridStartFactory.mProps
The properties object holding all the properties.
|
Modifier and Type | Method and Description |
---|---|
void |
POSTScript.initialize(PegasusProperties properties,
String path,
String submitDir)
Initialize the POSTScript implementation.
|
private POSTScript |
GridStartFactory.loadPOSTScript(PegasusProperties properties,
String submitDir,
String path,
String className)
Loads the implementing class corresponding to the class.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Abstract.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
Braindump.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
MonitordNotify.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
DAXReplicaStore.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
Stampede.mProps
The object holding all the properties pertaining to Pegasus.
|
Modifier and Type | Field and Description |
---|---|
private PegasusProperties |
SUBDAXGenerator.mProps
The handle to Pegasus Properties.
|
Modifier and Type | Method and Description |
---|---|
protected String |
CondorGenerator.getCategoryDAGManKnobs(PegasusProperties properties)
Write out the DAGMan knobs for each category the user mentions in
the properties.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Abstract.mProps
The object holding all the properties pertaining to Pegasus.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
NetloggerPostScript.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
UserPOSTScript.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
PegasusLite.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
NoPOSTScript.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
NoGridStart.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
VDSPOSTScript.mProps
The object holding all the properties pertaining to Pegasus.
|
private PegasusProperties |
Kickstart.mProps
The object holding all the properties pertaining to Pegasus.
|
Modifier and Type | Method and Description |
---|---|
protected String |
NetloggerPostScript.getPostScriptProperties(PegasusProperties properties)
Returns the properties that need to be passed to the the postscript
invocation in the java format.
|
protected String |
PegasusExitCode.getPostScriptProperties(PegasusProperties properties)
Returns an empty string, as python version of exitcode cannot parse properties
file.
|
protected String |
VDSPOSTScript.getPostScriptProperties(PegasusProperties properties)
Returns the properties that need to be passed to the the postscript
invocation in the java format.
|
void |
NetloggerPostScript.initialize(PegasusProperties properties,
String path,
String submitDir)
Initialize the POSTScript implementation.
|
void |
UserPOSTScript.initialize(PegasusProperties properties,
String path,
String submitDir)
Initialize the POSTScript implementation.
|
void |
NoPOSTScript.initialize(PegasusProperties properties,
String path,
String submitDir)
Initialize the POSTScript implementation.
|
void |
VDSPOSTScript.initialize(PegasusProperties properties,
String path,
String submitDir)
Initialize the POSTScript implementation.
|
Modifier and Type | Method and Description |
---|---|
static PegasusProperties |
PegasusProperties.getInstance()
Returns an instance to this properties object.
|
static PegasusProperties |
PegasusProperties.getInstance(String confProperties)
Returns an instance to this properties object.
|
static PegasusProperties |
PegasusProperties.nonSingletonInstance()
To get a reference to the the object.
|
protected static PegasusProperties |
PegasusProperties.nonSingletonInstance(String confProperties)
To get a reference to the the object.
|
Modifier and Type | Method and Description |
---|---|
protected void |
PegasusConfiguration.checkAndSetProperty(PegasusProperties properties,
String key,
String value)
Checks for a property, if it does not exist then sets the property to
the value passed
|
private void |
PegasusConfiguration.loadConfigurationProperties(PegasusProperties properties)
Loads configuration specific properties into PegasusProperties
|
void |
PegasusConfiguration.loadConfigurationPropertiesAndOptions(PegasusProperties properties,
PlannerOptions options)
Loads configuration specific properties into PegasusProperties,
and adjusts planner options accordingly.
|
void |
Shiwa.readBundle(String shiwaBundle,
PegasusProperties properties,
PlannerOptions options)
Untars a shiwa bundle and updates the properties and options to refer to
the contents of the bundle
|
boolean |
PegasusConfiguration.setupForCondorIO(PegasusProperties properties)
Returns a boolean indicating if properties are setup for condor io
|
Modifier and Type | Method and Description |
---|---|
void |
Dagman.assimilate(PegasusProperties properties,
Profiles.NAMESPACES namespace)
Assimilate the profiles in the namespace in a controlled manner.
|
void |
Namespace.assimilate(PegasusProperties properties,
Profiles.NAMESPACES namespace)
Assimilate the profiles in the namespace in a controlled manner.
|
void |
Condor.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
Selector.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
Pegasus.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
Hints.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
ENV.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
Stat.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
Dagman.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
abstract void |
Namespace.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
void |
Globus.checkKeyInNS(PegasusProperties properties,
String pool)
It puts in the namespace specific information specified in the properties
file into the namespace.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Parser.mProps
The object holding all the properties pertaining to Pegasus.
|
Modifier and Type | Method and Description |
---|---|
static Callback |
DAXParserFactory.loadDAXParserCallback(PegasusProperties properties,
String dax,
String className)
Loads the implementing class corresponding to the type specified by the user.
|
static Callback |
DAXParserFactory.loadDAXParserCallback(String type,
PegasusProperties properties,
String dax)
Loads the implementing class corresponding to the type specified by the user.
|
Constructor and Description |
---|
ConfigXmlParser(PegasusProperties properties)
Default Class Constructor.
|
ConfigXmlParser(String configFileName,
PegasusProperties properties)
Class Constructor intializes the parser and turns on validation.
|
Parser(PegasusProperties properties)
Intialises the parser.
|
PDAXParser(PegasusProperties properties)
The default constructor.
|
PDAXParser(String fileName,
PegasusProperties properties)
The constructor initialises the parser, and turns on the validation feature
in Xerces.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
DAX2NewGraph.mProps
The handle to the properties object.
|
private PegasusProperties |
DAX2CDAG.mProps
The handle to the properties object.
|
protected PegasusProperties |
DAX2Graph.mProps
The handle to the properties object.
|
private PegasusProperties |
DAX2Metadata.mProps
The handle to the properties object.
|
Constructor and Description |
---|
DAX2CDAG(PegasusProperties properties,
String dax)
The overloaded constructor.
|
DAX2Graph(PegasusProperties properties,
String dax)
The overloaded constructor.
|
DAX2LabelGraph(PegasusProperties properties,
String dax)
The overloaded constructor.
|
DAX2Metadata(PegasusProperties properties,
String dax)
The overloaded constructor.
|
DAX2NewGraph(PegasusProperties properties,
String dax)
The overloaded constructor.
|
ExampleDAXCallback(PegasusProperties properties,
String dax)
The overloaded constructor.
|
Modifier and Type | Field and Description |
---|---|
private PegasusProperties |
PDAX2MDAG.mProps
The handle to the properties file.
|
Modifier and Type | Method and Description |
---|---|
static String |
PDAX2MDAG.constructDAGManKnobs(PegasusProperties properties)
Constructs Any extra arguments that need to be passed to dagman, as determined
from the properties file.
|
static Callback |
PDAXCallbackFactory.loadInstance(PegasusProperties properties,
PlannerOptions options,
String directory)
Loads the implementing class corresponding to the type specified by the user.
|
static Callback |
PDAXCallbackFactory.loadInstance(PegasusProperties properties,
PlannerOptions options,
String directory,
String className)
Loads the implementing class corresponding to the type specified by the user.
|
Constructor and Description |
---|
PDAX2MDAG(String directory,
PegasusProperties properties,
PlannerOptions options)
The overloaded constructor.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Partitioner.mProps
The object holding all the properties pertaining to Pegasus.
|
protected PegasusProperties |
WriterCallback.mProps
Handle to the properties available.
|
private PegasusProperties |
ClustererCallback.mProps
The handle to the properties object.
|
private PegasusProperties |
PartitionAndPlan.mProps
The handle to Pegasus Properties.
|
Modifier and Type | Method and Description |
---|---|
Collection<File> |
PartitionAndPlan.doPartitionAndPlan(PegasusProperties properties,
PlannerOptions options)
Partitions and plans the workflow.
|
void |
ClustererCallback.initialize(PegasusProperties properties,
Clusterer clusterer)
Initializes the callback.
|
void |
WriterCallback.initialize(PegasusProperties properties,
String daxFile,
String daxName,
String directory)
Initializes the Writer Callback.
|
static Partitioner |
PartitionerFactory.loadInstance(PegasusProperties properties,
GraphNode root,
Map graph,
String className)
Loads the implementing class corresponding to the type specified by the user.
|
static DAXWriter |
DAXWriter.loadInstance(PegasusProperties properties,
String daxFile,
String directory)
The ends up loading the PDAXWriter.
|
static DAXWriter |
DAXWriter.loadInstance(String className,
PegasusProperties properties,
String daxFile,
String directory)
Loads the implementing PDAXWriter.
|
Constructor and Description |
---|
BFS(GraphNode root,
Map graph,
PegasusProperties properties)
The overloaded constructor.
|
Horizontal(GraphNode root,
Map graph,
PegasusProperties properties)
The overloaded constructor.
|
Label(GraphNode root,
Map graph,
PegasusProperties properties)
The overloaded constructor.
|
One2One(GraphNode root,
Map graph,
PegasusProperties properties)
The overloaded constructor.
|
Partitioner(GraphNode root,
Map graph,
PegasusProperties properties)
The overloaded constructor.
|
Whole(GraphNode root,
Map graph,
PegasusProperties properties)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
static PPS |
PPSFactory.loadPPS(PegasusProperties properties)
Loads the appropriate PPS implementation on the basis of the property set in the
properties.
|
Modifier and Type | Method and Description |
---|---|
static XMLProducer |
XMLProducerFactory.loadXMLProducer(PegasusProperties properties)
Loads the appropriate XMLProducer on the basis of the property set in the
properties.
|
Modifier and Type | Method and Description |
---|---|
boolean |
GetDAX.connect(PegasusProperties properties)
A convenience method to connect on the basis of PegasusProperties.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Engine.mProps
The object holding all the properties pertaining to Pegasus.
|
private PegasusProperties |
Authenticate.mProps
The handle to the PegasusProperties object.
|
private PegasusProperties |
ThreadPool.mProps
The handle to the properties object.
|
Modifier and Type | Method and Description |
---|---|
private Map<String,NameValue> |
TransferEngine.constructSiteToSRMServerMap(PegasusProperties props)
Constructs a Properties objects by parsing the relevant SRM
pegasus properties.
|
protected String |
ReplicaCatalogBridge.getCommandLineProperties(PegasusProperties properties)
Returns the properties that need to be passed to the the rc-client
invocation on the command line .
|
void |
ReplicaCatalogBridge.initialize(ADag dag,
PegasusProperties properties,
PlannerOptions options)
Intialises the refiner.
|
Constructor and Description |
---|
Authenticate(PegasusProperties properties,
PoolInfoProvider poolHandle)
The overloaded constructor.
|
ThreadPool(PegasusProperties properties,
Set pools)
The overloaded constructor.
|
Modifier and Type | Field and Description |
---|---|
private PegasusProperties |
InPlace.mProps
The handle to the properties passed to Pegasus.
|
private PegasusProperties |
RM.mProps
The handle to the properties passed to Pegasus.
|
private PegasusProperties |
Cleanup.mProps
The handle to the properties passed to Pegasus.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
DefaultImplementation.mProps
The handle to the pegasus properties.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Local.mProps
The properties object containing the properties passed to the planner.
|
protected PegasusProperties |
Default.mProps
The properties object containing the properties passed to the planner.
|
Modifier and Type | Method and Description |
---|---|
static ReplicaSelector |
ReplicaSelectorFactory.loadInstance(PegasusProperties properties)
Loads the implementing class corresponding to the mode specified by the user
at runtime in the properties file.
|
static ReplicaSelector |
ReplicaSelectorFactory.loadInstance(PegasusProperties properties,
String className)
Loads the implementing class corresponding to the class.
|
Constructor and Description |
---|
Default(PegasusProperties properties)
The overloaded constructor, that is called by load method.
|
Local(PegasusProperties properties)
The overloaded constructor, that is called by load method.
|
Regex(PegasusProperties properties)
The overloaded constructor, that is called by load method.
|
Restricted(PegasusProperties properties)
The overloaded constructor, that is called by load method.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Abstract.mProps
The properties passed to Pegasus at runtime.
|
Modifier and Type | Field and Description |
---|---|
private PegasusProperties |
Algorithm.mProps
The handle to the properties.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
AbstractRefiner.mProps
The handle to the properties object holding the properties relevant to
Pegasus.
|
private PegasusProperties |
RemoteTransfer.mProps
The handle to the properties object holding the properties relevant to
Pegasus.
|
private PegasusProperties |
TPT.mProps
The handle to the properties object holding the properties relevant to
Pegasus.
|
Constructor and Description |
---|
RemoteTransfer(PegasusProperties properties)
The overloaded constructor.
|
TPT(PegasusProperties properties)
The overloaded constructor.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Abstract.mProps
The handle to the properties object holding the properties relevant to
Pegasus.
|
Modifier and Type | Field and Description |
---|---|
protected PegasusProperties |
Condor.mProps
The handle to the properties.
|
protected PegasusProperties |
Transfer.mProps
The handle to the properties.
|