|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of ADag in edu.isi.pegasus.planner.client |
|---|
| Methods in edu.isi.pegasus.planner.client with parameters of type ADag | |
|---|---|
protected String |
CPlanner.determineRelativeSubmitDirectory(ADag dag,
String dir,
String user,
String vogroup,
boolean timestampBased)
Creates the submit directory for the workflow. |
private String |
CPlanner.determineRootWorkflowUUID(ADag dag,
PlannerOptions options,
PegasusProperties properties)
Determines the workflow uuid for a workflow |
private void |
CPlanner.generateStampedeEventsForAbstractWorkflow(ADag workflow,
PegasusBag bag)
Generates events for the abstract workflow. |
protected String |
CPlanner.getDAGFilename(ADag dag,
PlannerOptions options)
Returns the basename of the dag file |
String |
CPlanner.getNOOPJobName(ADag dag)
Returns the name of the noop job. |
protected String |
CPlanner.getRandomDirectory(ADag dag)
Sets the basename of the random directory that is created on the remote sites per workflow. |
protected boolean |
CPlanner.handleRescueDAG(ADag dag,
PlannerOptions options)
Checks for rescue dags, and determines whether to plan or not. |
private void |
CPlanner.logIDHierarchyMessage(ADag dag,
String parentType,
String parentID)
Logs a message that connects the jobs with DAX/DAG |
| Uses of ADag in edu.isi.pegasus.planner.cluster |
|---|
| Fields in edu.isi.pegasus.planner.cluster declared as ADag | |
|---|---|
protected ADag |
Abstract.mScheduledDAG
ADag object containing the jobs that have been scheduled by the site selector. |
private ADag |
Horizontal.mScheduledDAG
ADag object containing the jobs that have been scheduled by the site selector. |
| Methods in edu.isi.pegasus.planner.cluster that return ADag | |
|---|---|
ADag |
Abstract.getClusteredDAG()
Returns the clustered workflow. |
ADag |
Horizontal.getClusteredDAG()
Returns the clustered workflow. |
ADag |
Clusterer.getClusteredDAG()
Returns the clustered workflow. |
ADag |
Horizontal.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. |
| Methods in edu.isi.pegasus.planner.cluster with parameters of type ADag | |
|---|---|
void |
Abstract.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation |
void |
JobAggregator.initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation |
void |
Horizontal.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation |
void |
Clusterer.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation |
static Clusterer |
ClustererFactory.loadClusterer(ADag dag,
PegasusBag bag,
String type)
Loads the appropriate clusterer on the basis of the clustering type specified in the options passed to the planner. |
| Uses of ADag in edu.isi.pegasus.planner.cluster.aggregator |
|---|
| Fields in edu.isi.pegasus.planner.cluster.aggregator declared as ADag | |
|---|---|
protected ADag |
Abstract.mClusteredADag
The handle to the ADag object that contains the workflow being clustered. |
private ADag |
JobAggregatorInstanceFactory.mDAG
ADag object containing the jobs that have been scheduled by the site selector. |
| Methods in edu.isi.pegasus.planner.cluster.aggregator with parameters of type ADag | |
|---|---|
void |
SeqExec.initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation |
void |
Abstract.initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation |
void |
MPIExec.initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation |
void |
JobAggregatorInstanceFactory.initialize(ADag dag,
PegasusBag bag)
Initializes the Factory. |
static JobAggregator |
JobAggregatorFactory.loadInstance(ADag dag,
PegasusBag bag)
Loads the implementing class corresponding to the mode specified by the user at runtime in the properties file. |
static JobAggregator |
JobAggregatorFactory.loadInstance(String className,
ADag dag,
PegasusBag bag)
Loads the implementing class corresponding to the class passed. |
| Uses of ADag in edu.isi.pegasus.planner.code |
|---|
| Fields in edu.isi.pegasus.planner.code declared as ADag | |
|---|---|
private ADag |
GridStartFactory.mDAG
The workflow object. |
| Methods in edu.isi.pegasus.planner.code with parameters of type ADag | |
|---|---|
Collection<File> |
CodeGenerator.generateCode(ADag dag)
Generates the code for the concrete workflow in the input format of the workflow executor being used. |
void |
CodeGenerator.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow executor being used. |
void |
GridStartFactory.initialize(PegasusBag bag,
ADag dag)
Initializes the factory with known GridStart implementations. |
void |
GridStart.initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation. |
private GridStart |
GridStartFactory.loadGridStart(PegasusBag bag,
ADag dag,
String className)
Loads the implementing class corresponding to the class. |
| Uses of ADag in edu.isi.pegasus.planner.code.generator |
|---|
| Methods in edu.isi.pegasus.planner.code.generator with parameters of type ADag | |
|---|---|
Map<String,String> |
Braindump.defaultBrainDumpEntries(ADag workflow)
Returns default braindump entries. |
Collection<File> |
MonitordNotify.generateCode(ADag dag)
Generates the notifications input file. |
Collection<File> |
Stork.generateCode(ADag dag)
Generates the code for the concrete workflow in the input format of the workflow executor being used. |
Collection<File> |
Metrics.generateCode(ADag dag)
Generates the code for the executable workflow in terms of a braindump file that contains workflow metadata useful for monitoring daemons etc. |
Collection<File> |
Braindump.generateCode(ADag dag)
Generates the code for the executable workflow in terms of a braindump file that contains workflow metadata useful for monitoring daemons etc. |
Collection<File> |
DAXReplicaStore.generateCode(ADag dag)
Generates the notifications input file. |
Collection<File> |
Shell.generateCode(ADag dag)
Generates the code for the concrete workflow in the GRMS input format. |
Collection<File> |
Stampede.generateCode(ADag dag)
Generates the code for the executable workflow in terms of a braindump file that contains workflow metadata useful for monitoring daemons etc. |
void |
MonitordNotify.generateCode(ADag dag,
Job job)
Not implemented |
void |
Stork.generateCode(ADag dag,
Job job)
Generates the code for a single job in the Stork format. |
void |
Metrics.generateCode(ADag dag,
Job job)
Method not implemented. |
void |
Braindump.generateCode(ADag dag,
Job job)
Method not implemented. |
void |
DAXReplicaStore.generateCode(ADag dag,
Job job)
Not implemented |
void |
Shell.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow executor being used. |
void |
Stampede.generateCode(ADag dag,
Job job)
Method not implemented. |
Collection<File> |
Braindump.generateCode(ADag dag,
Map<String,String> additionalEntries)
Generates the code for the executable workflow in terms of a braindump file that contains workflow metadata useful for monitoring daemons etc. |
protected void |
Stampede.generateEventsForDAXTask(PrintWriter writer,
ADag workflow,
Job job)
Generates stampede events corresponding to jobs/tasks in the DAX |
protected void |
Stampede.generateEventsForExecutableJob(PrintWriter writer,
ADag dag,
Job job)
Generates stampede events corresponding to an executable job |
protected void |
Stampede.generateTaskMapEvents(PrintWriter writer,
ADag dag,
Job job)
Generates the task.map events that link the jobs in the DAX with the jobs in the executable workflow |
Map<String,String> |
Stork.getAdditionalBraindumpEntries(ADag workflow)
Returns an empty map |
abstract Map<String,String> |
Abstract.getAdditionalBraindumpEntries(ADag workflow)
Returns a Map containing additional metrics entries that are specific to a Code Generator |
Map<String,String> |
Shell.getAdditionalBraindumpEntries(ADag workflow)
Returns a Map containing additional braindump entries that are specific to a Code Generator |
protected String |
Abstract.getDAGFilename(ADag dag,
String suffix)
Returns the name of the file on the basis of the metadata associated with the DAG. |
protected String |
Shell.getPathToShellScript(ADag dag)
Returns path to the shell script that is generated |
protected void |
Abstract.writeOutBraindump(ADag workflow)
Writes out the metrics file for the workflow |
protected void |
Abstract.writeOutDAXReplicaStore(ADag workflow)
Writes out the DAX replica store |
void |
NetloggerJobMapper.writeOutMappings(Writer writer,
ADag dag)
Writes out the job mappings for a workflow. |
protected File |
Metrics.writeOutMetricsFile(ADag dag)
Writes out the workflow metrics file in the submit directory |
protected void |
Abstract.writeOutNotifications(ADag workflow)
Writes out the generator input file for the work-flow. |
protected void |
Abstract.writeOutStampedeEvents(ADag workflow)
Writes out the stampedeEventGenerator events for the workflow. |
protected void |
Abstract.writeOutWorkflowMetrics(ADag workflow)
Writes out the workflow metrics file for the workflow. |
| Uses of ADag in edu.isi.pegasus.planner.code.generator.condor |
|---|
| Fields in edu.isi.pegasus.planner.code.generator.condor declared as ADag | |
|---|---|
protected ADag |
CondorGenerator.mConcreteWorkflow
The workflow for which the code has to be generated. |
private ADag |
SUBDAXGenerator.mDAG
|
| Methods in edu.isi.pegasus.planner.code.generator.condor with parameters of type ADag | |
|---|---|
protected void |
CondorGenerator.concreteDagEmpty(String filename,
ADag dag)
A callout method that dictates what needs to be done in case the concrete plan that is generated is empty. |
protected String |
SUBDAXGenerator.createSubmitDirectory(ADag dag,
String dir,
String user,
String vogroup,
boolean timestampBased)
Creates the submit directory for the workflow. |
static void |
ClassADSGenerator.generate(PrintWriter writer,
ADag dag)
Writes out the classads for a workflow to corresponding writer stream. |
static void |
ClassADSGenerator.generate(PrintWriter writer,
ADag dag,
Job job)
Writes out the classads for a job to corresponding writer stream. |
Collection<File> |
CondorGenerator.generateCode(ADag dag)
Generates the code for the concrete workflow in Condor DAGMAN and CondorG input format. |
void |
CondorGenerator.generateCode(ADag dag,
Job job)
Generates the code (condor submit file) for a single job. |
Map<String,String> |
CondorGenerator.getAdditionalBraindumpEntries(ADag workflow)
Returns a Map containing additional braindump entries that are specific to a Code Generator. |
protected String |
CondorGenerator.getCondorLogInSubmitDirectory(ADag dag)
Returns the path to the condor log file in the submit directory. |
protected String |
CondorGenerator.getDAGMANOutFilename(ADag dag)
Returns the basename of the file, that contains the output of the dagman while running the dag generated for the workflow. |
void |
SUBDAXGenerator.initialize(PegasusBag bag,
ADag dag,
Graph workflow,
PrintWriter dagWriter)
Initializes the class. |
protected void |
CondorGenerator.writeDOTFile(String filename,
ADag dag)
Writes out the DOT file in the submit directory. |
protected void |
CondorGenerator.writeJobMapFile(String filename,
ADag dag)
Writes out the job map file in the submit directory. |
| Uses of ADag in edu.isi.pegasus.planner.code.gridstart |
|---|
| Fields in edu.isi.pegasus.planner.code.gridstart declared as ADag | |
|---|---|
private ADag |
Kickstart.mConcDAG
The handle to the workflow that is being enabled. |
private ADag |
NoGridStart.mDAG
|
private ADag |
PegasusLite.mDAG
|
| Methods in edu.isi.pegasus.planner.code.gridstart with parameters of type ADag | |
|---|---|
void |
NoGridStart.initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation. |
void |
PegasusLite.initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation. |
void |
Kickstart.initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation. |
| Uses of ADag in edu.isi.pegasus.planner.parser.pdax |
|---|
| Fields in edu.isi.pegasus.planner.parser.pdax declared as ADag | |
|---|---|
private ADag |
PDAX2MDAG.mMegaDAG
The abstract dag object that ends up holding the megadag. |
| Uses of ADag in edu.isi.pegasus.planner.partitioner |
|---|
| Methods in edu.isi.pegasus.planner.partitioner with parameters of type ADag | |
|---|---|
protected String |
PartitionAndPlan.createSubmitDirectory(ADag dag,
String dir,
String user,
String vogroup,
boolean timestampBased)
Creates the submit directory for the workflow. |
| Uses of ADag in edu.isi.pegasus.planner.partitioner.graph |
|---|
| Methods in edu.isi.pegasus.planner.partitioner.graph with parameters of type ADag | |
|---|---|
static Graph |
Adapter.convert(ADag dag)
Converts the ADag to Graph instance. |
| Uses of ADag in edu.isi.pegasus.planner.refiner |
|---|
| Fields in edu.isi.pegasus.planner.refiner declared as ADag | |
|---|---|
private ADag |
MainEngine.mCleanupDag
The cleanup dag for the final concrete dag. |
private ADag |
RemoveDirectory.mConcDag
The concrete dag so far, for which the clean up dag needs to be generated. |
protected ADag |
DeployWorkerPackage.mCurrentDag
It is a reference to the Concrete Dag so far. |
protected ADag |
CreateDirectory.mCurrentDag
It is a reference to the Concrete Dag so far. |
private ADag |
TransferEngine.mDag
The DAG object to which the transfer nodes are to be added. |
private ADag |
InterPoolEngine.mDag
ADag object corresponding to the Dag whose jobs we want to schedule. |
private ADag |
ReplicaCatalogBridge.mDag
The DAG being worked upon. |
private ADag |
ReductionEngine.mOriginalDag
the original dag object which needs to be reduced on the basis of the results returned from the Replica Catalog |
private ADag |
MainEngine.mOriginalDag
The Original Dag object which is constructed by parsing the dag file. |
private ADag |
ReductionEngine.mReducedDag
the reduced dag object which is returned. |
private ADag |
MainEngine.mReducedDag
The reduced Dag object which is got from the Reduction Engine. |
private ADag |
ReductionEngine.mWorkflow
The workflow object being worked upon. |
private ADag |
DataReuseEngine.mWorkflow
The workflow object being worked upon. |
| Methods in edu.isi.pegasus.planner.refiner that return ADag | |
|---|---|
ADag |
CleanupEngine.addCleanupJobs(ADag dag)
Adds the cleanup jobs in the workflow that removes the files staged to the remote site. |
ADag |
DeployWorkerPackage.addCleanupNodesForWorkerPackage(ADag dag)
Adds cleanup nodes in the workflow for sites specified. |
ADag |
CreateDirectory.addCreateDirectoryNodes(ADag dag)
It modifies the concrete dag passed in the constructor and adds the create random directory nodes to it at the root level. |
ADag |
DeployWorkerPackage.addSetupNodes(ADag dag)
Adds a setup node per execution site in the workflow that will stage the worker node executables to the workdirectory on the sites the workflow has been scheduled to. |
ADag |
NodeCollapser.cluster(ADag dag)
Clusters the jobs in the workflow. |
ADag |
NodeCollapser.cluster(ADag dag,
String type)
Clusters the jobs in the workflow. |
ADag |
RemoveDirectory.generateCleanUPDAG()
Generates a cleanup DAG for the dag associated with the class. |
ADag |
RemoveDirectory.generateCleanUPDAG(ADag dag)
Generates a cleanup DAG for the dag object passed. |
ADag |
MainEngine.getCleanupDAG()
Returns the cleanup dag for the concrete dag. |
ADag |
ReductionEngine.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. |
ADag |
DataReuseEngine.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. |
ADag |
InterPoolEngine.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. |
ADag |
Refiner.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. |
ADag |
ReductionEngine.makeRedDagObject(ADag orgDag,
Vector vDelJobs)
makes the Reduced Dag object which corresponding to the deleted jobs which are specified. |
ADag |
ReductionEngine.reduceDag(ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the replica catalog. |
ADag |
DataReuseEngine.reduceWorkflow(ADag workflow,
ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the replica catalog. |
ADag |
MainEngine.runPlanner()
The main function which calls the other engines and does the necessary work. |
| Methods in edu.isi.pegasus.planner.refiner with parameters of type ADag | |
|---|---|
ADag |
CleanupEngine.addCleanupJobs(ADag dag)
Adds the cleanup jobs in the workflow that removes the files staged to the remote site. |
ADag |
DeployWorkerPackage.addCleanupNodesForWorkerPackage(ADag dag)
Adds cleanup nodes in the workflow for sites specified. |
ADag |
CreateDirectory.addCreateDirectoryNodes(ADag dag)
It modifies the concrete dag passed in the constructor and adds the create random directory nodes to it at the root level. |
ADag |
DeployWorkerPackage.addSetupNodes(ADag dag)
Adds a setup node per execution site in the workflow that will stage the worker node executables to the workdirectory on the sites the workflow has been scheduled to. |
private Graph |
DeployWorkerPackage.addSetupNodesWithoutUntarNodes(ADag dag,
Set<String> deploymentSites)
Adds only the stage worker nodes to the workflow. |
private Graph |
DeployWorkerPackage.addSetupNodesWithUntarNodes(ADag dag,
Set<String> deploymentSites)
Adds untar nodes to the workflow, in addition to the stage worker nodes |
ADag |
NodeCollapser.cluster(ADag dag)
Clusters the jobs in the workflow. |
ADag |
NodeCollapser.cluster(ADag dag,
String type)
Clusters the jobs in the workflow. |
ADag |
RemoveDirectory.generateCleanUPDAG(ADag dag)
Generates a cleanup DAG for the dag object passed. |
private String |
MainEngine.getCacheFileName(ADag adag)
Constructs the basename to the cache file that is to be used to log the transient files. |
protected String |
DeployWorkerPackage.getCleanupJobname(ADag dag,
String site)
It returns the name of the untar job, that is to be assigned. |
protected Set |
RemoveDirectory.getCreateDirSites(ADag dag)
Retrieves the sites for which the create dir jobs need to be created. |
protected String |
DeployWorkerPackage.getDeployJobName(ADag dag,
String site,
boolean localTransfer)
It returns the name of the deployment job, that is to be assigned. |
protected Set |
DeployWorkerPackage.getDeploymentSites(ADag dag)
Retrieves the sites for which the deployment jobs need to be created. |
private String |
RemoveDirectory.getRemoveDirJobName(ADag dag,
String pool)
It returns the name of the remove directory job, that is to be assigned. |
protected String |
DeployWorkerPackage.getUntarJobName(ADag dag,
String site)
It returns the name of the untar job, that is to be assigned. |
void |
DeployWorkerPackage.initialize(ADag scheduledDAG)
Initialize with the scheduled graph. |
void |
ReplicaCatalogBridge.initialize(ADag dag,
PegasusBag bag)
Intialises the refiner. |
void |
ReplicaCatalogBridge.initialize(ADag dag,
PegasusProperties properties,
PlannerOptions options)
Intialises the refiner. |
protected void |
TransferEngine.initializeStageOutSiteDirectoryFactory(ADag workflow)
Initialize the Stageout Site Directory factory. |
private ReplicaCatalog |
MainEngine.initializeTransientRC(ADag dag)
Initializes the transient replica catalog and returns a handle to it. |
ADag |
ReductionEngine.makeRedDagObject(ADag orgDag,
Vector vDelJobs)
makes the Reduced Dag object which corresponding to the deleted jobs which are specified. |
ADag |
DataReuseEngine.reduceWorkflow(ADag workflow,
ReplicaCatalogBridge rcb)
Reduces the workflow on the basis of the existence of lfn's in the replica catalog. |
void |
InterPoolEngine.scheduleJobs(ADag dag,
List sites)
It schedules a list of jobs on the execution pools by calling out to the site selector specified. |
| Constructors in edu.isi.pegasus.planner.refiner with parameters of type ADag | |
|---|---|
DataReuseEngine(ADag orgDag,
PegasusBag bag)
The constructor |
|
InterPoolEngine(ADag aDag,
PegasusBag bag)
Overloaded constructor. |
|
MainEngine(ADag orgDag,
PegasusBag bag)
This constructor initialises the class variables to the variables passed. |
|
ReductionEngine(ADag orgDag,
PegasusBag bag)
The constructor |
|
RemoveDirectory(ADag concDag,
PegasusBag bag,
String submitDirectory)
The overloaded constructor that sets the dag for which we have to generated the cleanup dag for. |
|
ReplicaCatalogBridge(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
TransferEngine(ADag reducedDag,
PegasusBag bag,
List<Job> deletedJobs,
List<Job> deletedLeafJobs)
Overloaded constructor. |
|
| Uses of ADag in edu.isi.pegasus.planner.refiner.createdir |
|---|
| Methods in edu.isi.pegasus.planner.refiner.createdir that return ADag | |
|---|---|
ADag |
HourGlass.addCreateDirectoryNodes(ADag dag)
It modifies the concrete dag passed in the constructor and adds the create random directory nodes to it at the root level. |
ADag |
Tentacles.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes. |
ADag |
Strategy.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes. |
| Methods in edu.isi.pegasus.planner.refiner.createdir with parameters of type ADag | |
|---|---|
ADag |
HourGlass.addCreateDirectoryNodes(ADag dag)
It modifies the concrete dag passed in the constructor and adds the create random directory nodes to it at the root level. |
ADag |
Tentacles.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes. |
ADag |
Strategy.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes. |
protected String |
HourGlass.getConcatJobname(ADag dag)
Returns the name of the concat job |
String |
AbstractStrategy.getCreateDirJobName(ADag dag,
String pool)
It returns the name of the create directory job, that is to be assigned. |
protected Set |
AbstractStrategy.getCreateDirSites(ADag dag)
Retrieves the sites for which the create dir jobs need to be created. |
private void |
HourGlass.introduceRootDependencies(ADag dag,
String newRoot)
It traverses through the root jobs of the dag and introduces a new super root node to it. |
Job |
HourGlass.makeDummyConcatJob(ADag dag)
It creates a dummy concat job that is run at the local submit host. |
| Uses of ADag in edu.isi.pegasus.planner.selector |
|---|
| Methods in edu.isi.pegasus.planner.selector with parameters of type ADag | |
|---|---|
void |
SiteSelector.mapWorkflow(ADag workflow,
List sites)
Maps the jobs in the workflow to the various grid sites. |
| Uses of ADag in edu.isi.pegasus.planner.selector.site |
|---|
| Fields in edu.isi.pegasus.planner.selector.site declared as ADag | |
|---|---|
private ADag |
NonJavaCallout.mAbstractDag
The abstract DAG. |
| Methods in edu.isi.pegasus.planner.selector.site with parameters of type ADag | |
|---|---|
void |
Abstract.mapWorkflow(ADag workflow,
List sites)
Maps the jobs in the workflow to the various grid sites. |
void |
Heft.mapWorkflow(ADag workflow,
List sites)
Maps the jobs in the workflow to the various grid sites. |
void |
NonJavaCallout.mapWorkflow(ADag workflow,
List sites)
Maps the jobs in the workflow to the various grid sites. |
| Uses of ADag in edu.isi.pegasus.planner.selector.site.heft |
|---|
| Methods in edu.isi.pegasus.planner.selector.site.heft with parameters of type ADag | |
|---|---|
void |
Algorithm.schedule(ADag dag,
List sites)
Schedules the workflow using the heft. |
| Uses of ADag in edu.isi.pegasus.planner.transfer |
|---|
| Fields in edu.isi.pegasus.planner.transfer declared as ADag | |
|---|---|
protected ADag |
AbstractRefiner.mDAG
The ADag object associated with the Dag. |
| Methods in edu.isi.pegasus.planner.transfer that return ADag | |
|---|---|
ADag |
AbstractRefiner.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner. |
| Constructors in edu.isi.pegasus.planner.transfer with parameters of type ADag | |
|---|---|
AbstractRefiner(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
MultipleFTPerXFERJobRefiner(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
SingleFTPerXFERJobRefiner(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
| Uses of ADag in edu.isi.pegasus.planner.transfer.refiner |
|---|
| Methods in edu.isi.pegasus.planner.transfer.refiner with parameters of type ADag | |
|---|---|
static Refiner |
RefinerFactory.loadInstance(ADag dag,
PegasusBag bag)
Loads the implementing class corresponding to the value specified in the properties. |
static Refiner |
RefinerFactory.loadInstance(String className,
PegasusBag bag,
ADag dag)
Loads the implementing class corresponding to the class. |
| Constructors in edu.isi.pegasus.planner.transfer.refiner with parameters of type ADag | |
|---|---|
Bundle(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
Chain(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
Cluster(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
Default(ADag dag,
PegasusBag bag)
The overloaded constructor. |
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||