| java.lang.Object
 org.griphyn.cPlanner.engine.Engine
org.griphyn.cPlanner.engine.ReplicaCatalogBridge
| ReplicaCatalogBridge | | public class ReplicaCatalogBridge extends Engine (Code) | | This coordinates the look up to the Replica Location Service, to determine
the logical to physical mappings.
author:
Karan Vahi
author:
Gaurang Mehta
version:
$Revision: 456 $ |
| Method Summary | |
| protected void | appendProperty(StringBuffer sb, String key, String value)
Appends a property to the StringBuffer, in the java command line format. | | public void | closeConnection()
To close the connection to replica services. | | public void | finalize()
Closes the connection to the rli. | | protected String | getCommandLineProperties(PegasusProperties properties)
Returns the properties that need to be passed to the the rc-client
invocation on the command line . | | public ReplicaLocation | getFileLocs(String lfn)
Returns all the locations as returned from the Replica Lookup Mechanism.
Parameters:
lfn - The name of the logical file whose PFN mappings arerequired. | | public Set | getFilesInReplica()
This returns the files for which mappings exist in the Replica Catalog. | | public void | initialize(ADag dag, PegasusProperties properties, PlannerOptions options)
Intialises the refiner. | | public SubInfo | makeRCRegNode(String regJobName, SubInfo job, Collection files)
It constructs the SubInfo object for the registration node, which
registers the materialized files on the output pool in the RLS.
Note that the relations corresponding to this node should already have
been added to the concerned DagInfo object.
Parameters:
regJobName - The name of the job which registers the files in theReplica Location Service.
Parameters:
job - The job whose output files are to be registered inthe Replica Location Service.
Parameters:
files - Collection of FileTransfer objectscontaining the information about source anddestination URLs. |
| CACHE_REPLICA_CATALOG_IMPLEMENTER | | final public static String CACHE_REPLICA_CATALOG_IMPLEMENTER(Code) | | The name of the Replica Catalog Implementer that serves as the source for
cache files.
|
| CACHE_REPLICA_CATALOG_KEY | | final public static String CACHE_REPLICA_CATALOG_KEY(Code) | | The name of the source key for Replica Catalog Implementer that serves as
cache
|
| RC_DERIVATION_NAME | | final public static String RC_DERIVATION_NAME(Code) | | The derivation name for the transfer jobs.
|
| RC_DERIVATION_NS | | final public static String RC_DERIVATION_NS(Code) | | The derivation namespace for the transfer jobs.
|
| RC_DERIVATION_VERSION | | final public static String RC_DERIVATION_VERSION(Code) | | The version number for the derivations for registration jobs.
|
| RC_TRANSFORMATION_NAME | | final public static String RC_TRANSFORMATION_NAME(Code) | | The logical name of the transformation used.
|
| RC_TRANSFORMATION_NS | | final public static String RC_TRANSFORMATION_NS(Code) | | The transformation namespace for the regostration jobs.
|
| RC_TRANSFORMATION_VERSION | | final public static String RC_TRANSFORMATION_VERSION(Code) | | The logical name of the transformation used.
|
| REPLICA_CATALOG_URL_KEY | | final public static String REPLICA_CATALOG_URL_KEY(Code) | | The name of the URL key for the replica catalog impelementer to be picked
up.
|
| mSearchFiles | | protected Set mSearchFiles(Code) | | The Vector of String objects containing the logical
filenames of the files whose locations are to be searched in the
Replica Catalog.
|
| ReplicaCatalogBridge | | public ReplicaCatalogBridge(ADag dag, PegasusProperties properties, PlannerOptions options)(Code) | | The overloaded constructor.
Parameters:
dag - the workflow that is being worked on.
Parameters:
properties - the properties passed to the planner.
Parameters:
options - the options passed to the planner at runtime. |
| appendProperty | | protected void appendProperty(StringBuffer sb, String key, String value)(Code) | | Appends a property to the StringBuffer, in the java command line format.
Parameters:
sb - the StringBuffer to append the property to.
Parameters:
key - the property.
Parameters:
value - the property value. |
| closeConnection | | public void closeConnection()(Code) | | To close the connection to replica services. This must be defined in the
case where one has not done a singleton implementation. In other
cases just do an empty implementation of this method.
|
| finalize | | public void finalize()(Code) | | Closes the connection to the rli.
|
| getCommandLineProperties | | protected String getCommandLineProperties(PegasusProperties properties)(Code) | | Returns the properties that need to be passed to the the rc-client
invocation on the command line . It is of the form
"-Dprop1=value1 -Dprop2=value2 .."
Parameters:
properties - the properties object the properties list, else empty string. |
| getFilesInReplica | | public Set getFilesInReplica()(Code) | | This returns the files for which mappings exist in the Replica Catalog.
This should return a subset of the files which are
specified in the mSearchFiles, while getting an instance to this.
a Set of logical file names as String objects, forwhich logical to physical mapping exists.
See Also: ReplicaCatalogBridge.mSearchFiles |
| initialize | | public void initialize(ADag dag, PegasusProperties properties, PlannerOptions options)(Code) | | Intialises the refiner.
Parameters:
dag - the workflow that is being worked on.
Parameters:
properties - the properties passed to the planner.
Parameters:
options - the options passed to the planner at runtime. |
| makeRCRegNode | | public SubInfo makeRCRegNode(String regJobName, SubInfo job, Collection files)(Code) | | It constructs the SubInfo object for the registration node, which
registers the materialized files on the output pool in the RLS.
Note that the relations corresponding to this node should already have
been added to the concerned DagInfo object.
Parameters:
regJobName - The name of the job which registers the files in theReplica Location Service.
Parameters:
job - The job whose output files are to be registered inthe Replica Location Service.
Parameters:
files - Collection of FileTransfer objectscontaining the information about source anddestination URLs. The destinationURLs would be our PFNs. SubInfo corresponding to the new registration node. |
|
|