Package | Description |
---|---|
edu.isi.pegasus.planner.classes | |
edu.isi.pegasus.planner.parser.dax | |
edu.isi.pegasus.planner.refiner | |
edu.isi.pegasus.planner.refiner.cleanup |
Modifier and Type | Class and Description |
---|---|
class |
FileTransfer
This is a container for the storing the transfers that are required in
between sites.
|
Modifier and Type | Field and Description |
---|---|
protected List<PegasusFile> |
CompoundTransformation.mUses
The list of dependant executables
|
Modifier and Type | Method and Description |
---|---|
List<PegasusFile> |
CompoundTransformation.getDependantFiles()
Returns the List of dependant files
|
Set<PegasusFile> |
Job.getInputFiles()
Returns the set of input files associated with the job.
|
Set<PegasusFile> |
Job.getOutputFiles()
Returns the set of output files associated with the job.
|
Modifier and Type | Method and Description |
---|---|
void |
CompoundTransformation.addDependantFile(PegasusFile pf)
Adds a dependant file.
|
void |
Job.addInputFile(PegasusFile file)
Adds an input file to the underlying collection of input files
associated with the job.
|
void |
Job.addOutputFile(PegasusFile file)
Adds an output file to the underlying collection of output files
associated with the job.
|
Modifier and Type | Method and Description |
---|---|
void |
Job.setInputFiles(Set<PegasusFile> ipFiles)
Sets the input files associated with the job.
|
void |
Job.setOutputFiles(Set<PegasusFile> opFiles)
Sets the output files associated with the job.
|
Constructor and Description |
---|
FileTransfer(PegasusFile pf)
The overloaded constructor.
|
Modifier and Type | Field and Description |
---|---|
private PegasusFile |
DAXParser2.mUsesPegasusFile
The PegasusFile object that a uses tag corresponds to.
|
Modifier and Type | Method and Description |
---|---|
private Set<PegasusFile> |
TransferEngine.getOutputFiles(Collection<GraphNode> nodes)
It gets the output files for all the nodes which are specified in
the nodes passed.
|
Modifier and Type | Method and Description |
---|---|
private boolean |
TransferEngine.bypassStagingForInputFile(ReplicaCatalogEntry entry,
PegasusFile file,
String computeSite)
Returns a boolean indicating whether to bypass first level staging for a
file or not
|
private FileTransfer |
TransferEngine.constructFileTX(PegasusFile pf,
Job job,
String destSiteHandle,
String path,
boolean localTransfer)
Constructs the FileTransfer object on the basis of the transiency
information.
|
private void |
TransferEngine.logRemoval(Job job,
PegasusFile file,
String prefix,
boolean removed)
Helped method for logging removal message.
|
Modifier and Type | Field and Description |
---|---|
private List<PegasusFile> |
CleanupJobContent.mToBeDeletedFiles
The list of files that need to be deleted and are associated with this job.
|
Modifier and Type | Method and Description |
---|---|
List<PegasusFile> |
CleanupJobContent.getListOfFilesToDelete()
Returns the list of files to be deleted for a cleanupNode
|
Constructor and Description |
---|
CleanupJobContent(GraphNode node,
List<PegasusFile> files) |