Modifier and Type | Method and Description |
---|---|
private String |
PlannerCache.getCacheFileName(ADag adag,
FileServerType.OPERATION operation)
Constructs the basename to the cache file that is to be used
to log the transient files.
|
void |
PlannerCache.initialize(PegasusBag bag,
ADag dag)
Initialize the replica catalog instances that make up the cache.
|
private ReplicaCatalog |
PlannerCache.intializeRCAsCache(ADag dag,
FileServerType.OPERATION type)
Initializes the transient replica catalog and returns a handle to it.
|
Modifier and Type | Method and Description |
---|---|
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
|
Modifier and Type | Field and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
ADag |
Abstract.getClusteredDAG()
Returns the clustered workflow.
|
ADag |
Clusterer.getClusteredDAG()
Returns the clustered workflow.
|
ADag |
Horizontal.getClusteredDAG()
Returns the clustered workflow.
|
ADag |
Horizontal.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner.
|
Modifier and Type | Method and Description |
---|---|
void |
Abstract.initialize(ADag dag,
PegasusBag bag)
Initializes the Clusterer impelementation
|
void |
Clusterer.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
|
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.
|
Modifier and Type | Field and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
JobAggregatorInstanceFactory.initialize(ADag dag,
PegasusBag bag)
Initializes the Factory.
|
void |
Abstract.initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation
|
void |
SeqExec.initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation
|
void |
MPIExec.initialize(ADag dag,
PegasusBag bag)
Initializes the JobAggregator impelementation
|
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.
|
Modifier and Type | Field and Description |
---|---|
private ADag |
GridStartFactory.mDAG
The workflow object.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
Braindump.defaultBrainDumpEntries(ADag workflow)
Returns default braindump entries.
|
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> |
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.
|
Collection<File> |
MonitordNotify.generateCode(ADag dag)
Generates the notifications input file.
|
Collection<File> |
PMC.generateCode(ADag dag)
Generates the code for the concrete workflow in the GRMS input format.
|
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> |
PBS.generateCode(ADag dag)
Generates the code for the concrete workflow in the GRMS input format.
|
Collection<File> |
Shell.generateCode(ADag dag)
Generates the code for the concrete workflow in the GRMS input format.
|
void |
Braindump.generateCode(ADag dag,
Job job)
Method not implemented.
|
void |
DAXReplicaStore.generateCode(ADag dag,
Job job)
Not implemented
|
void |
Stampede.generateCode(ADag dag,
Job job)
Method not implemented.
|
void |
MonitordNotify.generateCode(ADag dag,
Job job)
Not implemented
|
void |
PMC.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow
executor being used.
|
void |
Stork.generateCode(ADag dag,
Job job)
Generates the code for a single job in the Stork format.
|
void |
PBS.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow
executor being used.
|
void |
Shell.generateCode(ADag dag,
Job job)
Generates the code for a single job in the input format of the workflow
executor being used.
|
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
|
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> |
PMC.getAdditionalBraindumpEntries(ADag workflow)
Returns a Map containing additional braindump entries that are specific
to a Code Generator.
|
Map<String,String> |
Stork.getAdditionalBraindumpEntries(ADag workflow)
Returns an empty map
|
Map<String,String> |
PBS.getAdditionalBraindumpEntries(ADag workflow)
Returns a Map containing additional braindump 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 |
PBS.getPathtoPBSFile(ADag dag)
Returns the basename for the PBS script file for the dag
|
protected String |
PMC.getPathtoPMCFile(ADag dag)
Returns the basename for the pmc file for the dag
|
protected String |
Shell.getPathToShellScript(ADag dag)
Returns path to the shell script that is generated
|
protected String |
PBS.pbsBasename(ADag dag)
Returns the basename for the PBS file for the dag
|
protected String |
PMC.pmcBasename(ADag dag)
Returns the basename for the pmc file for the dag
|
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 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.
|
Modifier and Type | Field and Description |
---|---|
protected ADag |
CondorGenerator.mConcreteWorkflow
The workflow for which the code has to be generated.
|
private ADag |
SUBDAXGenerator.mDAG |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Field and Description |
---|---|
private ADag |
Kickstart.mConcDAG
The handle to the workflow that is being enabled.
|
private ADag |
NoGridStart.mDAG |
private ADag |
PegasusLite.mDAG |
Modifier and Type | Method and Description |
---|---|
void |
NoGridStart.initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation.
|
void |
Kickstart.initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation.
|
void |
PegasusLite.initialize(PegasusBag bag,
ADag dag)
Initializes the GridStart implementation.
|
Modifier and Type | Field and Description |
---|---|
private ADag |
PDAX2MDAG.mMegaDAG
The abstract dag object that ends up holding the megadag.
|
Modifier and Type | Method and Description |
---|---|
protected String |
PartitionAndPlan.createSubmitDirectory(ADag dag,
String dir,
String user,
String vogroup,
boolean timestampBased)
Creates the submit directory for the workflow.
|
Modifier and Type | Method and Description |
---|---|
static Graph |
Adapter.convert(ADag dag)
Converts the
ADag to Graph instance. |
Modifier and Type | Field and Description |
---|---|
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 |
CreateDirectory.mCurrentDag
It is a reference to the Concrete Dag so far.
|
protected ADag |
DeployWorkerPackage.mCurrentDag
It is a reference to the Concrete Dag so far.
|
private ADag |
ReplicaCatalogBridge.mDag
The DAG being worked upon.
|
private ADag |
InterPoolEngine.mDag
ADag object corresponding to the Dag whose jobs we want to schedule.
|
private ADag |
TransferEngine.mDag
The DAG object to which the transfer nodes are to be added.
|
private ADag |
MainEngine.mOriginalDag
The Original Dag object which is constructed by parsing the dag file.
|
private ADag |
MainEngine.mReducedDag
The reduced Dag object which is got from the Reduction Engine.
|
private ADag |
DataReuseEngine.mWorkflow
The workflow object being worked upon.
|
Modifier and Type | Method and Description |
---|---|
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 |
TestReduceEdges.createTest1() |
ADag |
TestReduceEdges.createTest2() |
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 |
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 |
ReduceEdges.reduce(ADag dag)
Prunes redundant edges from the workflow.
|
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.
|
Modifier and Type | Method and Description |
---|---|
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 |
TransferEngine.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.
|
private ReplicaCatalog |
TransferEngine.initializeWorkflowCacheFile(ADag dag)
Initializes a Replica Catalog Instance that is used to store
the GET URL's for all files on the staging site ( inputs staged and outputs
created ).
|
ADag |
ReduceEdges.reduce(ADag dag)
Prunes redundant edges from the workflow.
|
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.
|
Constructor and Description |
---|
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
ADag |
Strategy.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes.
|
ADag |
Minimal.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes.
|
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.
|
Modifier and Type | Method and Description |
---|---|
ADag |
Strategy.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes.
|
ADag |
Minimal.addCreateDirectoryNodes(ADag dag)
Modifies the workflow to add create directory nodes.
|
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.
|
Graph |
Minimal.addCreateDirectoryNodes(Graph workflow,
ADag dag,
Set<String> sites)
Adds create dir nodes to the workflow.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
SiteSelector.mapWorkflow(ADag workflow,
List sites)
Maps the jobs in the workflow to the various grid sites.
|
Modifier and Type | Field and Description |
---|---|
private ADag |
NonJavaCallout.mAbstractDag
The abstract DAG.
|
Modifier and Type | Method and Description |
---|---|
void |
NonJavaCallout.mapWorkflow(ADag workflow,
List sites)
Maps the jobs in the workflow to the various grid sites.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Algorithm.schedule(ADag dag,
List sites)
Schedules the workflow using the heft.
|
Modifier and Type | Field and Description |
---|---|
protected ADag |
AbstractRefiner.mDAG
The ADag object associated with the Dag.
|
Modifier and Type | Method and Description |
---|---|
ADag |
AbstractRefiner.getWorkflow()
Returns a reference to the workflow that is being refined by the refiner.
|
Constructor and Description |
---|
AbstractRefiner(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
MultipleFTPerXFERJobRefiner(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
SingleFTPerXFERJobRefiner(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
OutputMapper.initialize(PegasusBag bag,
ADag workflow)
Initializes the mappers.
|
static OutputMapper |
OutputMapperFactory.loadInstance(ADag dag,
PegasusBag bag)
Loads the implementing class corresponding to the value specified in the
properties.
|
static OutputMapper |
OutputMapperFactory.loadInstance(String className,
PegasusBag bag,
ADag dag)
Loads the implementing class corresponding to the class.
|
Modifier and Type | Method and Description |
---|---|
void |
Hashed.initialize(PegasusBag bag,
ADag workflow)
Initializes the mappers.
|
void |
Replica.initialize(PegasusBag bag,
ADag workflow)
Initializes the mappers.
|
void |
AbstractFileFactoryBasedMapper.initialize(PegasusBag bag,
ADag workflow)
Initializes the mappers.
|
void |
Fixed.initialize(PegasusBag bag,
ADag workflow)
Initializes the mappers.
|
void |
Flat.initialize(PegasusBag bag,
ADag workflow)
Initializes the mappers.
|
org.griphyn.vdl.euryale.FileFactory |
Hashed.instantiateFileFactory(PegasusBag bag,
ADag workflow)
Method that instantiates the FileFactory
|
abstract org.griphyn.vdl.euryale.FileFactory |
AbstractFileFactoryBasedMapper.instantiateFileFactory(PegasusBag bag,
ADag workflow)
Method that instantiates the FileFactory
|
org.griphyn.vdl.euryale.FileFactory |
Flat.instantiateFileFactory(PegasusBag bag,
ADag workflow)
Instantiates a Flat File Factory and returns it.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Constructor and Description |
---|
Basic(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Bundle(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Chain(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Cluster(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Empty(ADag dag,
PegasusBag bag)
The overloaded constructor.
|