Uses of Interface
edu.isi.pegasus.planner.transfer.Implementation
-
Packages that use Implementation Package Description edu.isi.pegasus.planner.refiner edu.isi.pegasus.planner.transfer edu.isi.pegasus.planner.transfer.implementation edu.isi.pegasus.planner.transfer.refiner -
-
Uses of Implementation in edu.isi.pegasus.planner.refiner
Fields in edu.isi.pegasus.planner.refiner declared as Implementation Modifier and Type Field Description protected Implementation
DeployWorkerPackage. mSetupTransferImplementation
The transfer implementation to be used for staging in the data as part of setup job. -
Uses of Implementation in edu.isi.pegasus.planner.transfer
Fields in edu.isi.pegasus.planner.transfer declared as Implementation Modifier and Type Field Description protected Implementation
AbstractRefiner. mTXInterImplementation
The inter transfer implementation that the refiner requires.protected Implementation
AbstractRefiner. mTXStageInImplementation
The stage-in transfer implementation that the refiner requires.protected Implementation
AbstractRefiner. mTXStageOutImplementation
The stage-out transfer implementation that the refiner requires.protected Implementation
AbstractRefiner. mTXSymbolicLinkImplementation
The stage-in symbolic link transfer implementation that refiner requires.Methods in edu.isi.pegasus.planner.transfer with parameters of type Implementation Modifier and Type Method Description private void
MultipleFTPerXFERJobRefiner. checkCompatibility(Implementation implementation)
Checks whether the implementation loaded is compatible with the refiner. -
Uses of Implementation in edu.isi.pegasus.planner.transfer.implementation
Classes in edu.isi.pegasus.planner.transfer.implementation that implement Implementation Modifier and Type Class Description class
Abstract
An abstract implementation that implements some of the common functions in the Implementation Interface that are required by all the implementations.class
AbstractMultipleFTPerXFERJob
An abstract implementation for implementations that can handle multiple file transfers in a single file transfer job.class
AbstractSingleFTPerXFERJob
An abstract implementation for implementations that can handle only a single file transfer in a single file transfer job.class
GUC
The implementation that is used to create transfer jobs that callout to the new globus-url-copy client, that support multiple file transfersclass
Stork
The implementation that creates transfer jobs referring to the stork data placement scheduler that can handle only one transfer per job.class
T2
The implementation that creates transfer jobs referring to the T2 executable distributed with the Pegasus.class
TPTGUC
The implementation that is used to create transfer jobs that callout to the new globus-url-copy client, that support multiple file transfersclass
Transfer
The implementation that creates transfer jobs referring to the python based transfer script distributed with Pegasus since version 3.0Methods in edu.isi.pegasus.planner.transfer.implementation that return Implementation Modifier and Type Method Description static Implementation
ImplementationFactory. loadInstance(PegasusBag bag, int type)
Loads the implementing class corresponding to the type specified by the user.private static Implementation
ImplementationFactory. loadInstance(java.lang.String className, PegasusBag bag)
Loads the implementing class corresponding to the class. -
Uses of Implementation in edu.isi.pegasus.planner.transfer.refiner
Methods in edu.isi.pegasus.planner.transfer.refiner with parameters of type Implementation Modifier and Type Method Description void
BalancedCluster. addStageInXFERNodes(Job job, boolean localTransfer, java.util.Collection files, int type, java.util.Map<java.lang.String,BalancedCluster.PoolTransfer> stageInMap, BalancedCluster.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
Basic. addStageInXFERNodes(Job job, java.util.Collection<FileTransfer> files, java.lang.String prefix, 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. 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
Empty. addStageInXFERNodes(Job job, java.util.Collection<FileTransfer> files, java.lang.String prefix, 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.int
BalancedCluster.BundleValue. determine(Implementation implementation, Job job)
Determines the bundle factor for a particular site on the basis of the stage in bundle value associcated with the underlying transfer transformation in the transformation catalog.int
Bundle.BundleValue. determine(Implementation implementation, Job job)
Determines the bundle factor for a particular site on the basis of the stage in bundle value associcated with the underlying transfer transformation in the transformation catalog.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.java.util.Map<java.lang.String,BalancedCluster.PoolTransfer>
BalancedCluster. resetStageInMap(java.util.Map<java.lang.String,BalancedCluster.PoolTransfer> stageInMap, Implementation implementation, int stageInJobType, boolean localTransfer)
Signals that the traversal of the workflow is done.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.
-