edu.isi.pegasus.planner.transfer.refiner
public class Chain extends Basic
Modifier and Type | Class and Description |
---|---|
private static class |
Chain.SiteTransfer
A container to manage the transfer jobs that are needed to be done on a
single site.
|
private static class |
Chain.TransferChain
A shallow container class, that contains the list of the names of the
transfer jobs and can return the last job in the list.
|
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_BUNDLE_FACTOR
The default bundling factor that identifies the number of transfer jobs
that are being created per execution pool for the workflow.
|
static String |
DESCRIPTION
A short description of the transfer refinement.
|
private Map |
mSIBundleMap
The map containing the stage in bundle values indexed by the name of the
site.
|
protected SiteStore |
mSiteStore
The handle to the Site Catalog.
|
private Map |
mStageInMap
A map indexed by execution sites.
|
mCreateRegistrationJobs, mFileTable, mLogMsg, mPPS
mDAG, mLogger, mPOptions, mProps, mRemoteTransfers, mTPT, mTXInterImplementation, mTXStageInImplementation, mTXStageOutImplementation, mTXSymbolicLinkImplementation, mXMLStore
INTER_POOL_PREFIX, LOCAL_PREFIX, REGISTER_PREFIX, REMOTE_PREFIX, STAGE_IN_PREFIX, STAGE_OUT_PREFIX
Constructor and Description |
---|
Chain(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
addRelation(String parent,
String child,
String site,
boolean parentNew)
Adds a new relation to the workflow.
|
void |
done()
Prints out the bundles and chains that have been constructed.
|
String |
getDescription()
Returns a textual description of the transfer mode.
|
int |
getSiteBundleValue(String site,
String key)
Determines the bundle factor for a particular site on the basis of the
key associcated with the underlying transfer transformation in the
transformation catalog.
|
addInterSiteTXNodes, addJob, addRelation, addStageInXFERNodes, addStageInXFERNodes, addStageOutXFERNodes, addStageOutXFERNodes, appendAttribute, constructFileKey, createRegistrationJob, getJobPriority, logRefinerAction
loadImplementations
addStageInXFERNodes, getWorkflow, getXMLProducer, isSiteThirdParty, logConfigMessages, refinerPreferenceForLocalTransferJobs, refinerPreferenceForTransferJobLocation, runTPTOnRemoteSite, runTransferRemotely
public static final String DEFAULT_BUNDLE_FACTOR
protected SiteStore mSiteStore
private Map mSIBundleMap
private Map mStageInMap
Chain.TransferChain
public static final String DESCRIPTION
public Chain(ADag dag, PegasusBag bag)
dag
- the workflow to which transfer nodes need to be added.bag
- the bag of initialization objectspublic void addRelation(String parent, String child, String site, boolean parentNew)
addRelation
in class Basic
parent
- the jobname of the parent node of the edge.child
- the jobname of the child node of the edge.site
- the execution site where the transfer node is to be run.parentNew
- the parent node being added, is the new transfer job
and is being called for the first time.public int getSiteBundleValue(String site, String key)
site
- the site at which the transfer job is being run.key
- the bundle key whose value needs to be searched.DEFAULT_BUNDLE_FACTOR
public void done()
public String getDescription()
getDescription
in class Basic