| org.griphyn.cPlanner.transfer.refiner.Default
 org.griphyn.cPlanner.transfer.refiner.Bundle
| Bundle | | public class Bundle extends Default (Code) | | An extension of the default refiner, that allows the user to specify
the number of transfer nodes per execution site for stagein and stageout.
author:
Karan Vahi
version:
$Revision: 226 $ |
| Field Summary | |
| final public static String | DEFAULT_STAGE_IN_BUNDLE_FACTOR
The default bundling factor that identifies the number of transfer jobs
that are being created per execution pool for stageing in data for
the workflow. | | final public static String | DEFAULT_STAGE_OUT_BUNDLE_FACTOR
The default bundling factor that identifies the number of transfer jobs
that are being created per execution pool while stageing data out. | | final public static String | DESCRIPTION
A short description of the transfer refinement. |
| Method Summary | |
| public void | addStageInXFERNodes(SubInfo job, Collection files)
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. | | public void | addStageOutXFERNodes(SubInfo job, Collection files, ReplicaCatalogBridge rcb, boolean deletedLeaf)
Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
Parameters:
job - SubInfo object corresponding to the node towhich the files are to be transferred to.
Parameters:
files - Collection of FileTransfer objects containing theinformation about source and destURL's.
Parameters:
rcb - bridge to the Replica Catalog. | | public void | done()
Signals that the traversal of the workflow is done. | | public String | getDescription()
Returns a textual description of the transfer mode. | | protected int | getSISiteBundleValue(String site, String deflt)
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. | | protected int | getSOSiteBundleValue(String site, String deflt)
Determines the bundle factor for a particular site on the basis of the
stage out bundle value associcated with the underlying transfer
transformation in the transformation catalog. | | public PoolTransfer | getStageOutPoolTransfer(String site, int num)
Returns the appropriate pool transfer for a particular site.
Parameters:
site - the site for which the PT is reqd.
Parameters:
num - the number of Stageout jobs required for that Pool. |
| DEFAULT_STAGE_IN_BUNDLE_FACTOR | | final public static String DEFAULT_STAGE_IN_BUNDLE_FACTOR(Code) | | The default bundling factor that identifies the number of transfer jobs
that are being created per execution pool for stageing in data for
the workflow.
|
| DEFAULT_STAGE_OUT_BUNDLE_FACTOR | | final public static String DEFAULT_STAGE_OUT_BUNDLE_FACTOR(Code) | | The default bundling factor that identifies the number of transfer jobs
that are being created per execution pool while stageing data out.
|
| DESCRIPTION | | final public static String DESCRIPTION(Code) | | A short description of the transfer refinement.
|
| Bundle | | public Bundle(ADag dag, PegasusProperties properties, PlannerOptions options)(Code) | | The overloaded constructor.
Parameters:
dag - the workflow to which transfer nodes need to be added.
Parameters:
properties - the PegasusProperties object containing allthe properties required by Pegasus.
Parameters:
options - the options passed to the planner. |
| addStageInXFERNodes | | public void addStageInXFERNodes(SubInfo job, Collection files)(Code) | | 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.
Parameters:
job - SubInfo object corresponding to the node towhich the files are to be transferred to.
Parameters:
files - Collection of FileTransfer objects containing theinformation about source and destURL's. |
| addStageOutXFERNodes | | public void addStageOutXFERNodes(SubInfo job, Collection files, ReplicaCatalogBridge rcb, boolean deletedLeaf)(Code) | | Adds the stageout transfer nodes, that stage data to an output site
specified by the user.
Parameters:
job - SubInfo object corresponding to the node towhich the files are to be transferred to.
Parameters:
files - Collection of FileTransfer objects containing theinformation about source and destURL's.
Parameters:
rcb - bridge to the Replica Catalog. Used for creating registrationnodes in the workflow.
Parameters:
deletedLeaf - to specify whether the node is being added fora deleted node by the reduction engine or not.default: false |
| done | | public void done()(Code) | | Signals that the traversal of the workflow is done. At this point the
transfer nodes are actually constructed traversing through the transfer
containers and the stdin of the transfer jobs written.
|
| getDescription | | public String getDescription()(Code) | | Returns a textual description of the transfer mode.
a short textual description |
| getSISiteBundleValue | | protected int getSISiteBundleValue(String site, String deflt)(Code) | | 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. If the key is not found,
then the default value is returned. In case of the default value being
null the global default is returned.
Parameters:
site - the site at which the value is desired.
Parameters:
deflt - the default value. the bundle factor.
See Also: Bundle.DEFAULT_BUNDLE_STAGE_IN_FACTOR |
| getSOSiteBundleValue | | protected int getSOSiteBundleValue(String site, String deflt)(Code) | | Determines the bundle factor for a particular site on the basis of the
stage out bundle value associcated with the underlying transfer
transformation in the transformation catalog. If the key is not found,
then the default value is returned. In case of the default value being
null the global default is returned.
Parameters:
site - the site at which the value is desired.
Parameters:
deflt - the default value. the bundle factor.
See Also: Bundle.DEFAULT_STAGE_OUT_BUNDLE_FACTOR |
| getStageOutPoolTransfer | | public PoolTransfer getStageOutPoolTransfer(String site, int num)(Code) | | Returns the appropriate pool transfer for a particular site.
Parameters:
site - the site for which the PT is reqd.
Parameters:
num - the number of Stageout jobs required for that Pool. the PoolTransfer |
| Methods inherited from org.griphyn.cPlanner.transfer.refiner.Default | public void addInterSiteTXNodes(SubInfo job, Collection files)(Code)(Java Doc)
public void addJob(SubInfo job)(Code)(Java Doc)
public void addRelation(String parent, String child)(Code)(Java Doc)
public void addRelation(String parent, String child, String site, boolean parentNew)(Code)(Java Doc)
public void addStageInXFERNodes(SubInfo job, Collection files)(Code)(Java Doc)
public void addStageOutXFERNodes(SubInfo job, Collection files, ReplicaCatalogBridge rcb)(Code)(Java Doc)
public void addStageOutXFERNodes(SubInfo job, Collection files, ReplicaCatalogBridge rcb, boolean deletedLeaf)(Code)(Java Doc)
protected void appendAttribute(StringBuffer xmlFeed, String key, String value)(Code)(Java Doc)
protected String constructFileKey(String lfn, String siteHandle)(Code)(Java Doc)
protected SubInfo createRegistrationJob(String regJobName, SubInfo job, Collection files, ReplicaCatalogBridge rcb)(Code)(Java Doc)
public void done()(Code)(Java Doc)
public String getDescription()(Code)(Java Doc)
protected void logRefinerAction(SubInfo computeJob, SubInfo txJob, Collection files, String type)(Code)(Java Doc)
|
|
|