public abstract class AbstractSingleFTPerXFERJob extends Abstract implements SingleFTPerXFERJob
CHANGE_XBIT_TRANSFORMATION, mAddNodesForSettingXBit, mChmodDisabledForAllSites, mDisabledChmodSites, mLocalIrodsEnv, mLocalIrodsEnvBasename, mLocalS3cfg, mLocalS3cfgBasename, mLocalUserProxy, mLocalUserProxyBasename, mLogger, mPOptions, mProps, mRefiner, mSiteStore, mTCHandle, NOOP_PREFIX, SET_XBIT_PREFIX, XBIT_DERIVATION_NS, XBIT_DERIVATION_VERSION, XBIT_EXECUTABLE_BASENAME, XBIT_TRANSFORMATION_NS, XBIT_TRANSFORMATION_VERSION
TRANSFER_UNIVERSE, VERSION
Constructor and Description |
---|
AbstractSingleFTPerXFERJob(PegasusBag bag)
The overloaded constructor, that is called by the Factory to load the
class.
|
Modifier and Type | Method and Description |
---|---|
TransferJob |
createTransferJob(Job job,
String site,
Collection files,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per
transfer job.
|
TransferJob |
createTransferJob(Job job,
String site,
FileTransfer file,
Collection execFiles,
String txJobName,
int jobClass)
Constructs a general transfer job that handles single transfers per
transfer job.
|
protected abstract String |
generateArgumentStringAndAssociateCredentials(TransferJob job,
FileTransfer file)
It constructs the arguments to the transfer executable that need to be passed
to the executable referred to in this transfer mode.
|
protected abstract String |
getCompleteTCName()
Returns the complete name for the transformation that the implementation
is using.
|
protected abstract String |
getDerivationName()
Returns the logical name of the derivation that this implementation
refers to.
|
protected abstract String |
getDerivationNamespace()
Returns the namespace of the derivation that this implementation
refers to.
|
protected abstract String |
getDerivationVersion()
Returns the version of the derivation that this implementation
refers to.
|
addSetXBitJobs, addSetXBitJobs, addSetXBitJobs, applyPriority, checkAndTransferIrodsEnvFile, checkAndTransferProxy, construct, createNoOPJob, createSetXBitJob, createSetXBitJob, createSetXBitJob, determineDisabledChmodSites, disableChmodJobCreation, getNOOPJobName, getPriority, getSetXBitJobName, setRefiner
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
doesPreserveXBit, getDescription, getTransformationCatalogEntry, useThirdPartyTransferAlways
public AbstractSingleFTPerXFERJob(PegasusBag bag)
bag
- the bag of Pegasus initialization objectspublic TransferJob createTransferJob(Job job, String site, Collection files, Collection execFiles, String txJobName, int jobClass)
createTransferJob
in interface Implementation
job
- the Job object for the job, in relation to which
the transfer node is being added. Either the transfer
node can be transferring this jobs input files to
the execution pool, or transferring this job's output
files to the output pool.site
- the site where the transfer job should run.files
- collection of FileTransfer
objects
representing the data files and staged executables to be
transferred.execFiles
- subset collection of the files parameter, that identifies
the executable files that are being transferred.txJobName
- the name of transfer node.jobClass
- the job Class for the newly added job. Can be one of the
following:
stage-in
stage-out
inter-pool transferpublic TransferJob createTransferJob(Job job, String site, FileTransfer file, Collection execFiles, String txJobName, int jobClass)
job
- the Job object for the job, in relation to which
the transfer node is being added. Either the transfer
node can be transferring this jobs input files to
the execution pool, or transferring this job's output
files to the output pool.site
- the site where the transfer job should run.file
- collection of FileTransfer
objects
representing the data files and staged executables to be
transferred.execFiles
- subset collection of the files parameter, that identifies
the executable files that are being transferred.txJobName
- the name of transfer node.jobClass
- the job Class for the newly added job. Can be one of the
following:
stage-in
stage-out
inter-pool transferprotected abstract String getDerivationNamespace()
protected abstract String getDerivationName()
protected abstract String getDerivationVersion()
protected abstract String generateArgumentStringAndAssociateCredentials(TransferJob job, FileTransfer file)
job
- the job containing the transfer node.file
- the FileTransfer that needs to be done.protected abstract String getCompleteTCName()
Copyright © 2011 The University of Southern California. All Rights Reserved.