Modifier and Type | Method and Description |
---|---|
List<TransformationCatalogEntry> |
TransformationCatalog.getContents()
List all the contents of the TC
|
List<TransformationCatalogEntry> |
TransformationCatalog.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> |
TransformationCatalog.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<TransformationCatalogEntry> |
TransformationCatalog.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;
|
Modifier and Type | Method and Description |
---|---|
int |
TransformationCatalog.insert(TransformationCatalogEntry tcentry)
Add single TCEntry to the Catalog.
|
int |
TransformationCatalog.insert(TransformationCatalogEntry tcentry,
boolean write)
Add single TCEntry object temporarily to the in memory Catalog.
|
Modifier and Type | Method and Description |
---|---|
int |
TransformationCatalog.insert(List<TransformationCatalogEntry> tcentry)
Add multiple TCEntries to the Catalog.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TransformationCatalogEntry.equals(TransformationCatalogEntry entry)
Compares two catalog entries for equality.
|
Modifier and Type | Field and Description |
---|---|
private Map<String,Map<String,List<TransformationCatalogEntry>>> |
TransformationStore.mTCStore
The internal store map.
|
Modifier and Type | Method and Description |
---|---|
List<TransformationCatalogEntry> |
TransformationStore.getAllEntries()
Returns all the entries in the Transformation Store
|
List<TransformationCatalogEntry> |
TransformationStore.getEntries(String completeName,
String site)
Returns List of TransformationCatalogEntry objects for a transformation
on a particular site.
|
List<TransformationCatalogEntry> |
TransformationStore.getEntries(String completeName,
String site,
TCType type)
Returns List of TransformationCatalogEntry objects for a transformation
on a particular site and a type.
|
List<TransformationCatalogEntry> |
TransformationStore.getEntries(String site,
TCType type)
Returns a list of TransformationCatalogEntry objects matching on a site and
transformation type.
|
Modifier and Type | Method and Description |
---|---|
void |
TransformationStore.addEntry(TransformationCatalogEntry entry)
Adds an entry into the store.
|
Modifier and Type | Method and Description |
---|---|
private static String |
TCFormatUtility.toText(TransformationCatalogEntry entry,
String newline,
String indent)
Converts the transformation catalog entry object to the multi line
textual representation.
|
Modifier and Type | Method and Description |
---|---|
static TransformationCatalogEntry |
Abstract.modifyForFileURLS(TransformationCatalogEntry entry)
Modifies a Transformation Catalog Entry to handle file URL's.
|
Modifier and Type | Method and Description |
---|---|
List<TransformationCatalogEntry> |
File.getContents()
List all the contents of the TC
|
List<TransformationCatalogEntry> |
Text.getContents()
List all the contents of the TC
|
List<TransformationCatalogEntry> |
Database.getContents()
List all the contents of the TC
|
List<TransformationCatalogEntry> |
File.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> |
Text.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> |
Database.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> |
File.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<TransformationCatalogEntry> |
Text.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<TransformationCatalogEntry> |
Database.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<TransformationCatalogEntry> |
File.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<TransformationCatalogEntry> |
Text.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<TransformationCatalogEntry> |
Database.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;
|
Modifier and Type | Method and Description |
---|---|
int |
File.insert(TransformationCatalogEntry entry)
Add single TCEntry to the Catalog.
|
int |
Text.insert(TransformationCatalogEntry entry)
Add single TCEntry to the Catalog.
|
int |
Database.insert(TransformationCatalogEntry entry)
Add single TCEntry to the Catalog.
|
int |
File.insert(TransformationCatalogEntry entry,
boolean write)
Add single TCEntry object temporarily to the in memory Catalog.
|
int |
Text.insert(TransformationCatalogEntry entry,
boolean write)
Add single TCEntry object temporarily to the in memory Catalog.
|
int |
Database.insert(TransformationCatalogEntry entry,
boolean write)
Add single TCEntry object temporarily to the in memory Catalog.
|
static TransformationCatalogEntry |
Abstract.modifyForFileURLS(TransformationCatalogEntry entry)
Modifies a Transformation Catalog Entry to handle file URL's.
|
Modifier and Type | Method and Description |
---|---|
int |
File.insert(List<TransformationCatalogEntry> entries)
Add multiple TCEntries to the Catalog.
|
int |
Text.insert(List<TransformationCatalogEntry> entries)
Add multiple TCEntries to the Catalog.
|
int |
Database.insert(List<TransformationCatalogEntry> tcentry)
Add multiple TCEntries to the Catalog.
|
Modifier and Type | Method and Description |
---|---|
void |
Job.addNotifications(TransformationCatalogEntry entry)
Adds all the notifications specfied in the TransformationCatalogEntry
to the underlying job notifications.
|
boolean |
TCMap.setSiteTCEntries(String fqlfn,
String siteid,
TransformationCatalogEntry entry)
This method allows to add a TransformationCatalogEntry object in the map
to a particular transformation for a particular site
|
void |
Job.updateProfiles(TransformationCatalogEntry entry)
Updates all the profile namespaces with the information associated in
the transformation catalog for this job.
|
Modifier and Type | Method and Description |
---|---|
private List<TransformationCatalogEntry> |
TCConverter.parseTC(PegasusProperties pegasusProperties)
Parses the input format specified in the properties file and returns list of TransfromationCatalogEntry
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
Abstract.defaultTCEntry(String name,
String executableBasename,
String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected TransformationCatalogEntry |
Abstract.getTCEntry(Job job)
Helper method to get an entry from the transformation catalog for an
installed executable.
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
CondorGenerator.constructTCEntryFromEnvironment()
Returns a tranformation catalog entry object constructed from the environment
An entry is constructed if either of the following environment variables
are defined
1) CONDOR_HOME
2) CONDOR_LOCATION
CONDOR_HOME takes precedence over CONDOR_LOCATION
|
private TransformationCatalogEntry |
SUBDAXGenerator.constructTCEntryFromEnvironment()
Returns a tranformation catalog entry object constructed from the environment
An entry is constructed if either of the following environment variables
are defined
1) CONDOR_HOME
2) CONDOR_LOCATION
CONDOR_HOME takes precedence over CONDOR_LOCATION
|
private TransformationCatalogEntry |
CondorGenerator.constructTCEntryFromEnvProfiles(ENV env)
Returns a tranformation catalog entry object constructed from the environment
An entry is constructed if either of the following environment variables
are defined
1) CONDOR_HOME
2) CONDOR_LOCATION
CONDOR_HOME takes precedence over CONDOR_LOCATION
|
private TransformationCatalogEntry |
SUBDAXGenerator.constructTCEntryFromEnvProfiles(ENV env)
Returns a tranformation catalog entry object constructed from the environment
An entry is constructed if either of the following environment variables
are defined
1) CONDOR_HOME
2) CONDOR_LOCATION
CONDOR_HOME takes precedence over CONDOR_LOCATION
|
private TransformationCatalogEntry |
SUBDAXGenerator.constructTCEntryFromPath()
Returns a tranformation catalog entry object constructed from the path
environment variable
|
private TransformationCatalogEntry |
SUBDAXGenerator.constructTransformationCatalogEntryForDAGMan(String path)
Constructs TransformationCatalogEntry for DAGMan.
|
private TransformationCatalogEntry |
CondorGenerator.defaultTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
private TransformationCatalogEntry |
SUBDAXGenerator.defaultTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
Modifier and Type | Method and Description |
---|---|
TransformationCatalogEntry |
Kickstart.getTransformationCatalogEntry(String site)
Returns the transformation catalog entry for kickstart on a site
|
Modifier and Type | Method and Description |
---|---|
void |
Namespace.checkKeyInNS(TransformationCatalogEntry entry)
It puts in the namespace specific information from the Transformation
Catalog into the namespace.
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
TransformationCatalogTextParser.getTransformationCatalogEntry(String transformation,
Profiles profiles,
boolean modifyFileURL)
Constructs a single transformation catalog entry and returns it.
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
DAXParser2.constructTCEntryFromJobHints(Job job)
Constructs a TC entry object from the contents of a job.
|
Modifier and Type | Method and Description |
---|---|
List<TransformationCatalogEntry> |
DAXParser3.convertExecutableToTCE(Executable executable)
Converts the executable into transformation catalog entries
|
Modifier and Type | Method and Description |
---|---|
void |
ExampleDAXCallback.cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
|
void |
Callback.cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
from Section 2: Executables that list entries in a Transformaton Catalog
|
void |
DAX2Graph.cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
|
void |
DAX2CDAG.cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
|
void |
DAX2NewGraph.cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
|
void |
DAX2Metadata.cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
PDAX2MDAG.constructTCEntryFromEnvironment()
Returns a tranformation catalog entry object constructed from the environment
An entry is constructed if either of the following environment variables
are defined
1) CONDOR_HOME
2) CONDOR_LOCATION
CONDOR_HOME takes precedence over CONDOR_LOCATION
|
private TransformationCatalogEntry |
PDAX2MDAG.constructTCEntryFromEnvProfiles(ENV env)
Returns a tranformation catalog entry object constructed from the environment
An entry is constructed if either of the following environment variables
are defined
1) CONDOR_HOME
2) CONDOR_LOCATION
CONDOR_HOME takes precedence over CONDOR_LOCATION
|
private TransformationCatalogEntry |
PDAX2MDAG.defaultTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
Modifier and Type | Field and Description |
---|---|
private TransformationCatalogEntry |
ReplicaCatalogBridge.mDefaultTCRCEntry
The default tc entry.
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
DeployWorkerPackage.addDefaultTCEntry(String site,
String pegasusHome,
SysInfo sysinfo,
boolean useFullPath,
String name,
String executable)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected TransformationCatalogEntry |
DeployWorkerPackage.addDefaultTCEntryForPegasusWebsite(String site,
String name)
Returns a default TC entry for the pegasus site.
|
private TransformationCatalogEntry |
RemoveDirectory.defaultTCEntry(SiteCatalogEntry site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
private TransformationCatalogEntry |
ReplicaCatalogBridge.defaultTCRCEntry()
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
private TransformationCatalogEntry |
DeployWorkerPackage.defaultUntarTCEntry(SiteCatalogEntry site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
private TransformationCatalogEntry |
InterPoolEngine.selectTCEntry(List entries,
Job job,
String selector)
Calls out to the transformation selector to select an entry from a list
of valid transformation catalog entries.
|
Modifier and Type | Method and Description |
---|---|
private static TransformationCatalogEntry |
RM.defaultTCEntry()
Returns a default TransformationCatalogEntry object for the rm executable.
|
private TransformationCatalogEntry |
Cleanup.defaultTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected TransformationCatalogEntry |
RM.getTCEntry(String site)
Returns the TCEntry object for the rm executable on a grid site.
|
protected TransformationCatalogEntry |
Cleanup.getTCEntry(String site)
Returns the TCEntry object for the rm executable on a grid stagingSite.
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
DefaultImplementation.defaultTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
Modifier and Type | Method and Description |
---|---|
protected int |
Algorithm.getExpectedRuntime(Job job,
TransformationCatalogEntry entry)
Return expected runtime.
|
protected double |
Algorithm.getExpectedRuntimeFromAC(Job job,
TransformationCatalogEntry entry)
Return expected runtime from the AC only if the process catalog is
initialized.
|
Modifier and Type | Method and Description |
---|---|
TransformationCatalogEntry |
Implementation.getTransformationCatalogEntry(String siteHandle,
int jobClass)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
Modifier and Type | Method and Description |
---|---|
protected TransformationCatalogEntry |
GUC.defaultTCEntry(String namespace,
String name,
String version,
String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected TransformationCatalogEntry |
AbstractMultipleFTPerXFERJob.defaultTCEntry(String namespace,
String name,
String version,
String executableBasename,
String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
private TransformationCatalogEntry |
Abstract.defaultXBitTCEntry(String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
TransformationCatalogEntry |
T2.getTransformationCatalogEntry(String siteHandle,
int jobClass)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
TransformationCatalogEntry |
Stork.getTransformationCatalogEntry(String siteHandle,
int jobClass)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
TransformationCatalogEntry |
Transfer.getTransformationCatalogEntry(String siteHandle,
int jobClass)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
TransformationCatalogEntry |
GUC.getTransformationCatalogEntry(String siteHandle,
int jobClass)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
Modifier and Type | Method and Description |
---|---|
protected TransformationCatalogEntry |
Transfer.defaultTCEntry(String namespace,
String name,
String version,
String executableBasename,
String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
TransformationCatalogEntry |
Transfer.getTransformationCatalogEntry(String siteHandle)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
Copyright © 2011 The University of Southern California. All Rights Reserved.