public interface TransformationCatalog extends Catalog
Modifier and Type | Field and Description |
---|---|
static String |
MODIFY_FOR_FILE_URLS_KEY
Property specify whether to modify file url or not.
|
static String |
VERSION
The version of the API
|
DB_ALL_PREFIX
Modifier and Type | Method and Description |
---|---|
int |
addLFNProfile(String namespace,
String name,
String version,
List profiles)
Add additional profile to a logical transformation .
|
int |
addPFNProfile(String pfn,
TCType type,
String resourcename,
List profiles)
Add additional profile to a physical transformation.
|
int |
clear()
Deletes the entire transformation catalog.
|
int |
deleteLFNProfiles(String namespace,
String name,
String version,
List profiles)
Delete a list of profiles or all the profiles associated with a logical
transformation.
|
int |
deletePFNProfiles(String physicalname,
TCType type,
String resourceid,
List profiles)
Delete a list of profiles or all the profiles associated with a pfn on a
resource and of a type.
|
List<TransformationCatalogEntry> |
getContents()
List all the contents of the TC
|
String |
getDescription()
Returns the TC implementation being used
|
List<String[]> |
getTCLogicalNames(String resourceid,
TCType type)
Get the list of LogicalNames available on a particular resource.
|
void |
initialize(PegasusBag bag)
Initialize the implementation, and return an instance of the implementation.
|
int |
insert(List<TransformationCatalogEntry> tcentry)
Add multiple TCEntries to the Catalog.
|
int |
insert(String namespace,
String name,
String version,
String physicalname,
TCType type,
String resourceid,
List lfnprofiles,
List pfnprofiles,
SysInfo sysinfo)
Add an single entry into the transformation catalog.
|
int |
insert(TransformationCatalogEntry tcentry)
Add single TCEntry to the Catalog.
|
int |
insert(TransformationCatalogEntry tcentry,
boolean write)
Add single TCEntry object temporarily to the in memory Catalog.
|
List<TransformationCatalogEntry> |
lookup(String namespace,
String name,
String version,
List resourceids,
TCType type)
Returns TC entries for a particular logical transformation and/or on a
number of resources and/or of a particular type.
|
List<TransformationCatalogEntry> |
lookup(String namespace,
String name,
String version,
String resourceid,
TCType type)
Returns TC entries for a particular logical transformation and/or on a
particular resource and/or of a particular type.
|
List<Profile> |
lookupLFNProfiles(String namespace,
String name,
String version)
Get the list of Profiles associated with a particular logical transformation.
|
List<TransformationCatalogEntry> |
lookupNoProfiles(String namespace,
String name,
String version,
String resourceid,
TCType type)
Get the list of PhysicalNames for a particular transformation on a site/sites
for a particular type/types;
|
List<Profile> |
lookupPFNProfiles(String pfn,
String resourceid,
TCType type)
Get the list of Profiles associated with a particular physical transformation.
|
List<String> |
lookupSites(String namespace,
String name,
String version,
TCType type)
Get the list of Resource ID's where a particular transformation may reside.
|
int |
removeByLFN(String namespace,
String name,
String version,
String resourceid,
TCType type)
Delete all entries in the transformation catalog for a give logical transformation and/or on a resource and/or of
a particular type
|
int |
removeByPFN(String physicalname,
String namespace,
String name,
String version,
String resourceid,
TCType type)
Delete all entries in the transformation catalog for pair of logical and physical transformation.
|
int |
removeBySiteID(String resourceid)
Delete all entries on a particular resource from the transformation catalog.
|
int |
removeBySysInfo(SysInfo sysinfo)
Deletes entries from the catalog which have a particular system information.
|
int |
removeByType(TCType type,
String resourceid)
Delete a particular type of transformation, and/or on a particular resource
|
static final String VERSION
static final String MODIFY_FOR_FILE_URLS_KEY
void initialize(PegasusBag bag)
bag
- the bag of Pegasus initialization objects.List<TransformationCatalogEntry> lookup(String namespace, String name, String version, String resourceid, TCType type) throws Exception
namespace
- String The namespace of the logical transformation.name
- String the name of the logical transformation.version
- String The version of the logical transformation.resourceid
- String The resourceid where the transformation is located.
If NULL it returns all resources.type
- TCType The type of the transformation to search for.
If NULL it returns all types.Exception
TCType
,
edu.isi.pegasus.planner.catalog.TransformationCatalogEntry
List<TransformationCatalogEntry> lookup(String namespace, String name, String version, List resourceids, TCType type) throws Exception
namespace
- String The namespace of the logical transformation.name
- String the name of the logical transformation.version
- String The version of the logical transformation.resourceids
- List The List resourceid where the transformation is located.
If NULL it returns all resources.type
- TCType The type of the transformation to search for.
If NULL it returns all types.Exception
TCType
,
edu.isi.pegasus.planner.catalog.TransformationCatalogEntry
List<String> lookupSites(String namespace, String name, String version, TCType type) throws Exception
namespace
- String The namespace of the transformation to search for.name
- String The name of the transformation to search for.version
- String The version of the transformation to search for.type
- TCType The type of the transformation to search for.Exception
- NotImplementedException if not implementedTCType
List<TransformationCatalogEntry> lookupNoProfiles(String namespace, String name, String version, String resourceid, TCType type) throws Exception
namespace
- String The namespace of the transformation to search for.name
- String The name of the transformation to search for.version
- String The version of the transformation to search for.resourceid
- String The id of the resource on which you want to search. type
- TCType The type of the transformation to search for. Exception
- NotImplementedException if not implemented.TCType
List<String[]> getTCLogicalNames(String resourceid, TCType type) throws Exception
resourceid
- String The id of the resource on which you want to searchtype
- TCType The type of the transformation to search for. Exception
- NotImplementedException if not implemented.List<Profile> lookupLFNProfiles(String namespace, String name, String version) throws Exception
namespace
- String The namespace of the transformation to search for.name
- String The name of the transformation to search for.version
- String The version of the transformation to search for.Exception
- NotImplementedException if not implemented.org.griphyn.cPlanner.classes.Profile
List<Profile> lookupPFNProfiles(String pfn, String resourceid, TCType type) throws Exception
pfn
- The physical file name to search the transformation by.resourceid
- String The id of the resource on which you want to search.type
- TCType The type of the transformation to search for. Exception
- NotImplementedException if not implemented.org.griphyn.cPlanner.classes.Profile
List<TransformationCatalogEntry> getContents() throws Exception
Exception
int insert(List<TransformationCatalogEntry> tcentry) throws Exception
tcentry
- List Takes a list of TransformationCatalogEntry objects as inputException
edu.isi.pegasus.planner.catalog.TransformationCatalogEntry
int insert(TransformationCatalogEntry tcentry) throws Exception
tcentry
- Takes a single TransformationCatalogEntry object as inputException
edu.isi.pegasus.planner.catalog.TransformationCatalogEntry
int insert(TransformationCatalogEntry tcentry, boolean write) throws Exception
tcentry
- Takes a single TransformationCatalogEntry object as inputwrite
- boolean enable write commits to backed catalog or not.Exception
edu.isi.pegasus.planner.catalog.TransformationCatalogEntry
int insert(String namespace, String name, String version, String physicalname, TCType type, String resourceid, List lfnprofiles, List pfnprofiles, SysInfo sysinfo) throws Exception
namespace
- String The namespace of the transformation to be added (Can be null)name
- String The name of the transformation to be added.version
- String The version of the transformation to be added. (Can be null)physicalname
- String The physical name/location of the transformation to be added.type
- TCType The type of the physical transformation.resourceid
- String The resource location id where the transformation is located.lfnprofiles
- List The List of Profile objects associated with a Logical Transformation. (can be null)pfnprofiles
- List The List of Profile objects associated with a Physical Transformation. (can be null)sysinfo
- SysInfo The System information associated with a physical transformation.Exception
edu.isi.pegasus.planner.catalog.TransformationCatalogEntry
,
SysInfo
,
org.griphyn.cPlanner.classes.Profile
int addLFNProfile(String namespace, String name, String version, List profiles) throws Exception
namespace
- String The namespace of the transformation to be added. (can be null)name
- String The name of the transformation to be added.version
- String The version of the transformation to be added. (can be null)profiles
- List The List of Profile objects that are to be added
to the transformation.Exception
org.griphyn.cPlanner.classes.Profile
int addPFNProfile(String pfn, TCType type, String resourcename, List profiles) throws Exception
pfn
- String The physical name of the transformationtype
- TCType The type of transformation that the profile is
associated with.resourcename
- String The resource on which the physical transformation existsprofiles
- The List of Profile objects that are to be added
to the transformation.Exception
org.griphyn.cPlanner.classes.Profile
int removeByLFN(String namespace, String name, String version, String resourceid, TCType type) throws Exception
namespace
- String The namespace of the transformation to be deleted. (can be null)name
- String The name of the transformation to be deleted.version
- String The version of the transformation to be deleted. ( can be null)resourceid
- String The resource id for which the transformation is to be deleted.
If NULL then transformation on all resource are deletedtype
- TCType The type of the transformation. If NULL then all types are deleted for the transformation.Exception
TCType
int removeByPFN(String physicalname, String namespace, String name, String version, String resourceid, TCType type) throws Exception
physicalname
- String The physical name of the transformationnamespace
- String The namespace associated in the logical name of the transformation.name
- String The name of the logical transformation.version
- String The version number of the logical transformation.resourceid
- String The resource on which the transformation is to be deleted.
If NULL then it searches all the resource id.type
- TCType The type of transformation. If NULL then it search and deletes entries for all types.Exception
TCType
int removeByType(TCType type, String resourceid) throws Exception
int removeBySiteID(String resourceid) throws Exception
resourceid
- String The resource which you want to remove.Exception
int removeBySysInfo(SysInfo sysinfo) throws Exception
int clear() throws Exception
Exception
int deletePFNProfiles(String physicalname, TCType type, String resourceid, List profiles) throws Exception
physicalname
- String The physical name of the transformation.type
- TCType The type of the transformation.resourceid
- String The resource of the transformation.profiles
- List The list of profiles to be deleted. If NULL then all profiles for that pfn+resource+type are deleted.Exception
org.griphyn.cPlanner.classes.Profile
int deleteLFNProfiles(String namespace, String name, String version, List profiles) throws Exception
namespace
- String The namespace of the logical transformation.name
- String The name of the logical transformation.version
- String The version of the logical transformation.profiles
- List The List of profiles to be deleted. If NULL
then all profiles for the logical transformation are deleted.Exception
org.griphyn.cPlanner.classes.Profile
String getDescription()