| java.lang.Object
 org.griphyn.cPlanner.transfer.implementation.Abstract
org.griphyn.cPlanner.transfer.implementation.Windward
| Windward | | public class Windward extends Abstract implements MultipleFTPerXFERJob(Code) | | A Windward implementation that uses the seqexec client to execute
-DC Transfer client to fetch the raw data sources
-Pegasus transfer client to fetch the patterns from the pattern catalog.
author:
Karan Vahi
version:
$Revision: 450 $ |
| Method Summary | |
| public TransferJob | createTransferJob(SubInfo job, Collection files, Collection execFiles, String txJobName, int jobClass)
Parameters:
job - the SubInfo object for the job, in relation to whichthe transfer node is being added. | | protected TransformationCatalogEntry | defaultTCEntry(String namespace, String name, String version, String site)
Returns a default TC entry to be used for the DC transfer client.
Parameters:
namespace - the namespace of the transfer transformation
Parameters:
name - the logical name of the transfer transformation
Parameters:
version - the version of the transfer transformation
Parameters:
site - the site for which the default entry is required. | | public boolean | doesPreserveXBit()
Returns a boolean indicating whether the transfer protocol being used by
the implementation preserves the X Bit or not while staging. | | protected String | getCompleteTCName()
Returns the complete name for the transformation. | | public String | getDescription()
Returns a textual description of the transfer implementation. | | protected List | getEnvironmentVariables(String site)
Returns the environment profiles that are required for the default
entry to sensibly work.
Parameters:
site - the site where the job is going to run. | | public TransformationCatalogEntry | getTransformationCatalogEntry(String siteHandle)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
Parameters:
siteHandle - the handle of the site where the transformation isto be searched. | | protected String | quote(String url)
| | public void | setRefiner(Refiner refiner)
Sets the callback to the refiner, that has loaded this implementation. | | public boolean | useThirdPartyTransferAlways()
Return a boolean indicating whether the transfers to be done always in
a third party transfer mode. |
| DATA_SOURCE_PREFIX | | final public static String DATA_SOURCE_PREFIX(Code) | | The prefix to identify the raw data sources.
|
| DERIVATION_NAME | | final public static String DERIVATION_NAME(Code) | | The name of the underlying derivation.
|
| DERIVATION_NAMESPACE | | final public static String DERIVATION_NAMESPACE(Code) | | The derivation namespace for for the transfer job.
|
| DERIVATION_VERSION | | final public static String DERIVATION_VERSION(Code) | | The derivation version number for the transfer job.
|
| DESCRIPTION | | final public static String DESCRIPTION(Code) | | A short description of the transfer implementation.
|
| TRANSFORMATION_NAME | | final public static String TRANSFORMATION_NAME(Code) | | The name of the underlying transformation that is queried for in the
Transformation Catalog.
|
| TRANSFORMATION_NAMESPACE | | final public static String TRANSFORMATION_NAMESPACE(Code) | | The transformation namespace for for the transfer job.
|
| TRANSFORMATION_VERSION | | final public static String TRANSFORMATION_VERSION(Code) | | The version number for the transfer job.
|
| Windward | | public Windward(PegasusProperties properties, PlannerOptions options)(Code) | | The overloaded constructor, that is called by the Factory to load the
class.
Parameters:
properties - the properties object.
Parameters:
options - the options passed to the Planner. |
| createTransferJob | | public TransferJob createTransferJob(SubInfo job, Collection files, Collection execFiles, String txJobName, int jobClass)(Code) | |
Parameters:
job - the SubInfo object for the job, in relation to whichthe transfer node is being added. Either the transfernode can be transferring this jobs input files tothe execution pool, or transferring this job's outputfiles to the output pool.
Parameters:
files - collection of FileTransfer objectsrepresenting the data files and staged executables to betransferred.
Parameters:
execFiles - subset collection of the files parameter, that identifiesthe executable files that are being transferred.
Parameters:
txJobName - the name of transfer node.
Parameters:
jobClass - the job Class for the newly added job. Can be one of thefollowing:stage-instage-outinter-pool transfer the created TransferJob. |
| defaultTCEntry | | protected TransformationCatalogEntry defaultTCEntry(String namespace, String name, String version, String site)(Code) | | Returns a default TC entry to be used for the DC transfer client.
Parameters:
namespace - the namespace of the transfer transformation
Parameters:
name - the logical name of the transfer transformation
Parameters:
version - the version of the transfer transformation
Parameters:
site - the site for which the default entry is required. the default entry. |
| doesPreserveXBit | | public boolean doesPreserveXBit()(Code) | | Returns a boolean indicating whether the transfer protocol being used by
the implementation preserves the X Bit or not while staging.
boolean |
| getCompleteTCName | | protected String getCompleteTCName()(Code) | | Returns the complete name for the transformation.
the complete name. |
| getDescription | | public String getDescription()(Code) | | Returns a textual description of the transfer implementation.
a short textual description |
| getEnvironmentVariables | | protected List getEnvironmentVariables(String site)(Code) | | Returns the environment profiles that are required for the default
entry to sensibly work.
Parameters:
site - the site where the job is going to run. List of environment variables, else null in case where therequired environment variables could not be found. |
| getTransformationCatalogEntry | | public TransformationCatalogEntry getTransformationCatalogEntry(String siteHandle)(Code) | | Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
Parameters:
siteHandle - the handle of the site where the transformation isto be searched. the transformation catalog entry if found, else null. |
| quote | | protected String quote(String url)(Code) | | Quotes a URL and returns it
Parameters:
url - String quoted url |
| setRefiner | | public void setRefiner(Refiner refiner)(Code) | | Sets the callback to the refiner, that has loaded this implementation.
Parameters:
refiner - the transfer refiner that loaded the implementation. |
| useThirdPartyTransferAlways | | public boolean useThirdPartyTransferAlways()(Code) | | Return a boolean indicating whether the transfers to be done always in
a third party transfer mode. A value of false, results in the
direct or peer to peer transfers being done.
A value of false does not preclude third party transfers. They still can
be done, by setting the property "pegasus.transfer.*.thirdparty.sites".
boolean indicating whether to always use third party transfersor not.
See Also: PegasusProperties.getThirdPartySites(String) |
| Methods inherited from org.griphyn.cPlanner.transfer.implementation.Abstract | protected boolean addSetXBitJobs(SubInfo computeJob, SubInfo txJob, Collection execFiles)(Code)(Java Doc)
public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass)(Code)(Java Doc)
public boolean addSetXBitJobs(SubInfo computeJob, String txJobName, Collection execFiles, int transferClass, int xbitIndex)(Code)(Java Doc)
public void applyPriority(TransferJob job)(Code)(Java Doc)
public boolean checkAndTransferProxy(TransferJob job)(Code)(Java Doc)
protected void construct(SubInfo job, String key, String value)(Code)(Java Doc)
public SubInfo createNoOPJob(String name)(Code)(Java Doc)
protected SubInfo createSetXBitJob(FileTransfer file, String name)(Code)(Java Doc)
protected Set determineDisabledChmodSites(String sites)(Code)(Java Doc)
protected boolean disableChmodJobCreation(String site)(Code)(Java Doc)
public String getNOOPJobName(String name, int counter)(Code)(Java Doc)
protected String getPathToUserProxy()(Code)(Java Doc)
protected String getPriority(TransferJob job)(Code)(Java Doc)
public String getSetXBitJobName(String name, int counter)(Code)(Java Doc)
public void setRefiner(Refiner refiner)(Code)(Java Doc)
|
|
|