Uses of Class
edu.isi.pegasus.planner.transfer.refiner.Bundle.PoolTransfer
-
Packages that use Bundle.PoolTransfer Package Description edu.isi.pegasus.planner.transfer.refiner -
-
Uses of Bundle.PoolTransfer in edu.isi.pegasus.planner.transfer.refiner
Fields in edu.isi.pegasus.planner.transfer.refiner with type parameters of type Bundle.PoolTransfer Modifier and Type Field Description protected java.util.Map<java.lang.String,Bundle.PoolTransfer>
Cluster. mStageInLocalMapPerLevel
A map indexed by site name, that contains the pointer to the stage in PoolTransfer objects for that site.protected java.util.Map<java.lang.String,Bundle.PoolTransfer>
Cluster. mStageInRemoteMapPerLevel
A map indexed by site name, that contains the pointer to the symlink stage in PoolTransfer objects for that site.private java.util.Map<java.lang.String,Bundle.PoolTransfer>
Bundle. mStageOutLocalMapPerLevel
A map indexed by site name, that contains the pointer to the local stage out PoolTransfer objects for that site.private java.util.Map<java.lang.String,Bundle.PoolTransfer>
Bundle. mStageOutRemoteMapPerLevel
A map indexed by site name, that contains the pointer to the remote stage out PoolTransfer objects for that site.Methods in edu.isi.pegasus.planner.transfer.refiner that return Bundle.PoolTransfer Modifier and Type Method Description protected Bundle.PoolTransfer
Cluster. getStageInPoolTransfer(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap, java.lang.String site, int num, boolean localTransfer)
Returns the appropriate stagein pool transfer for a particular site.Bundle.PoolTransfer
Bundle. getStageOutPoolTransfer(java.lang.String site, boolean localTransfer, int num)
Returns the appropriate pool transfer for a particular site.Methods in edu.isi.pegasus.planner.transfer.refiner that return types with arguments of type Bundle.PoolTransfer Modifier and Type Method Description protected java.util.Map<java.lang.String,Bundle.PoolTransfer>
Cluster. resetStageInMap(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap, Implementation implementation, java.util.Map<java.lang.String,Job> transientSynchJobMap, int jobType, boolean createChildSyncJob, boolean localTransfer)
Resets the stage in map and adds the stage in jobs for each site per level.Method parameters in edu.isi.pegasus.planner.transfer.refiner with type arguments of type Bundle.PoolTransfer Modifier and Type Method Description void
Bundle. addStageInXFERNodes(Job job, boolean localTransfer, java.util.Collection files, int type, java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap, Bundle.BundleValue bundleValue, Implementation implementation)
Adds the stage in transfer nodes which transfer the input files for a job, from the location returned from the replica catalog to the job's execution pool.void
Cluster. addStageInXFERNodes(Job job, boolean localTransfer, java.util.Collection files, int jobType, java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap, Bundle.BundleValue cValue, Implementation implementation)
Adds the stage in transfer nodes which transfer the input files for a job, from the location returned from the replica catalog to the job's execution pool.void
Bundle. doneStageIn(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap, Implementation implementation, int stageInJobType, boolean localTransfer)
Signals that the traversal of the workflow is done.protected Bundle.PoolTransfer
Cluster. getStageInPoolTransfer(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap, java.lang.String site, int num, boolean localTransfer)
Returns the appropriate stagein pool transfer for a particular site.protected java.util.Map<java.lang.String,Bundle.PoolTransfer>
Cluster. resetStageInMap(java.util.Map<java.lang.String,Bundle.PoolTransfer> stageInMap, Implementation implementation, java.util.Map<java.lang.String,Job> transientSynchJobMap, int jobType, boolean createChildSyncJob, boolean localTransfer)
Resets the stage in map and adds the stage in jobs for each site per level.protected java.util.Map
Bundle. resetStageOutMap(java.util.Map<java.lang.String,Bundle.PoolTransfer> map, boolean localTransfer)
Resets a single map
-