public class Empty extends MultipleFTPerXFERJobRefiner
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
DESCRIPTION
A short description of the transfer refinement.
|
protected java.lang.Boolean |
mCreateRegistrationJobs
Boolean indicating whether to create registration jobs or not.
|
protected java.util.Map |
mFileTable
A Map containing information about which logical file has been
transferred to which site and the name of the stagein transfer node
that is transferring the file from the location returned from
the replica catalog.
|
protected java.lang.String |
mLogMsg
The string holding the logging messages
|
protected PPS |
mPPS
The handle to the provenance store implementation.
|
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 |
---|
Empty(ADag dag,
PegasusBag bag)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
addInterSiteTXNodes(Job job,
java.util.Collection files,
boolean localTransfer)
Adds the inter pool transfer nodes that are required for transferring
the output files of the parents to the jobs execution site.
|
void |
addJob(Job job)
Add a new job to the workflow being refined.
|
void |
addRelation(java.lang.String parent,
java.lang.String child)
Adds a new relation to the workflow being refiner.
|
void |
addRelation(java.lang.String parent,
java.lang.String child,
java.lang.String site,
boolean parentNew)
Adds a new relation to the workflow.
|
void |
addStageInXFERNodes(Job job,
java.util.Collection<FileTransfer> files,
java.util.Collection<FileTransfer> symlinkFiles)
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 |
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 |
addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
void |
addStageOutXFERNodes(Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb,
boolean localTransfer,
boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
|
protected Job |
createRegistrationJob(java.lang.String regJobName,
Job job,
java.util.Collection files,
ReplicaCatalogBridge rcb)
Creates the registration jobs, which registers the materialized files on
the output site in the Replica Catalog.
|
void |
done()
Signals that the traversal of the workflow is done.
|
java.lang.String |
getDescription()
Returns a textual description of the transfer mode.
|
loadImplementations
addStageInXFERNodes, getWorkflow, getXMLProducer, isSiteThirdParty, logConfigMessages, refinerPreferenceForLocalTransferJobs, refinerPreferenceForTransferJobLocation, runTPTOnRemoteSite, runTransferRemotely
public static final java.lang.String DESCRIPTION
protected java.lang.String mLogMsg
protected java.util.Map mFileTable
protected PPS mPPS
protected java.lang.Boolean mCreateRegistrationJobs
public Empty(ADag dag, PegasusBag bag)
dag
- the workflow to which transfer nodes need to be added.bag
- the bag of initialization objects.public void addStageInXFERNodes(Job job, java.util.Collection<FileTransfer> files, java.util.Collection<FileTransfer> symlinkFiles)
addStageInXFERNodes
in class AbstractRefiner
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.symlinkFiles
- Collection of FileTransfer
objects containing
source and destination file url's for symbolic linking
on compute site.public void addStageInXFERNodes(Job job, java.util.Collection<FileTransfer> files, java.lang.String prefix, Implementation implementation)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.prefix
- the prefix to be used while constructing the transfer jobname.implementation
- the transfer implementation to usepublic void addInterSiteTXNodes(Job job, java.util.Collection files, boolean localTransfer)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.localTransfer
- boolean indicating that associated transfer job will run
on local site.public void addStageOutXFERNodes(Job job, java.util.Collection files, ReplicaCatalogBridge rcb, boolean localTransfer)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.rcb
- bridge to the Replica Catalog. Used for creating registration
nodes in the workflow.localTransfer
- boolean indicating that associated transfer job will run
on local site.public void addStageOutXFERNodes(Job job, java.util.Collection files, ReplicaCatalogBridge rcb, boolean localTransfer, boolean deletedLeaf)
job
- Job
object corresponding to the node to
which the files are to be transferred to.files
- Collection of FileTransfer
objects containing the
information about source and destURL's.rcb
- bridge to the Replica Catalog. Used for creating registration
nodes in the workflow.localTransfer
- boolean indicating that associated transfer job will run
on local site.deletedLeaf
- to specify whether the node is being added for
a deleted node by the reduction engine or not.
default: falseprotected Job createRegistrationJob(java.lang.String regJobName, Job job, java.util.Collection files, ReplicaCatalogBridge rcb)
regJobName
- The name of the job which registers the files in the
Replica Mechanism.job
- The job whose output files are to be registered in the
Replica Mechanism.files
- Collection of FileTransfer
objects containing
the information about source and destURL's.rcb
- bridge to the Replica Catalog. Used for creating registration
nodes in the workflow.public void done()
public void addJob(Job job)
job
- the job to be added.public void addRelation(java.lang.String parent, java.lang.String child)
parent
- the jobname of the parent node of the edge.child
- the jobname of the child node of the edge.public void addRelation(java.lang.String parent, java.lang.String child, java.lang.String site, boolean parentNew)
parent
- the jobname of the parent node of the edge.child
- the jobname of the child node of the edge.site
- the execution pool 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 java.lang.String getDescription()