Modifier and Type | Method and Description |
---|---|
java.util.List<TransformationCatalogEntry> |
TransformationCatalog.getContents()
List all the contents of the TC
|
java.util.List<TransformationCatalogEntry> |
TransformationCatalog.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.util.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.
|
java.util.List<TransformationCatalogEntry> |
TransformationCatalog.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String resourceid,
TCType type)
Returns TC entries for a particular logical transformation and/or on a
particular resource and/or of a particular type.
|
java.util.List<TransformationCatalogEntry> |
TransformationCatalog.lookupNoProfiles(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.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(java.util.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 java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<TransformationCatalogEntry>>> |
TransformationStore.mTCStore
The internal store map.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<TransformationCatalogEntry> |
TransformationStore.getAllEntries()
Returns all the entries in the Transformation Store
|
java.util.List<TransformationCatalogEntry> |
TransformationStore.getEntries(java.lang.String completeName,
java.lang.String site)
Returns List of TransformationCatalogEntry objects for a transformation
on a particular site.
|
java.util.List<TransformationCatalogEntry> |
TransformationStore.getEntries(java.lang.String completeName,
java.lang.String site,
TCType type)
Returns List of TransformationCatalogEntry objects for a transformation
on a particular site and a type.
|
java.util.List<TransformationCatalogEntry> |
TransformationStore.getEntries(java.lang.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 java.lang.String |
TCFormatUtility.toText(TransformationCatalogEntry entry,
java.lang.String newline,
java.lang.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 |
---|---|
java.util.List<TransformationCatalogEntry> |
Database.getContents()
List all the contents of the TC
|
java.util.List<TransformationCatalogEntry> |
Text.getContents()
List all the contents of the TC
|
java.util.List<TransformationCatalogEntry> |
File.getContents()
List all the contents of the TC
|
java.util.List<TransformationCatalogEntry> |
Database.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.util.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.
|
java.util.List<TransformationCatalogEntry> |
Text.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.util.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.
|
java.util.List<TransformationCatalogEntry> |
File.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.util.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.
|
java.util.List<TransformationCatalogEntry> |
Database.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String resourceid,
TCType type)
Returns TC entries for a particular logical transformation and/or on a
particular resource and/or of a particular type.
|
java.util.List<TransformationCatalogEntry> |
Text.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String resourceid,
TCType type)
Returns TC entries for a particular logical transformation and/or on a
particular resource and/or of a particular type.
|
java.util.List<TransformationCatalogEntry> |
File.lookup(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String resourceid,
TCType type)
Returns TC entries for a particular logical transformation and/or on a
particular resource and/or of a particular type.
|
java.util.List<TransformationCatalogEntry> |
Database.lookupNoProfiles(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String resourceid,
TCType type)
Get the list of PhysicalNames for a particular transformation on a site/sites
for a particular type/types;
|
java.util.List<TransformationCatalogEntry> |
Text.lookupNoProfiles(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String resourceid,
TCType type)
Get the list of PhysicalNames for a particular transformation on a site/sites
for a particular type/types;
|
java.util.List<TransformationCatalogEntry> |
File.lookupNoProfiles(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.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 |
Database.insert(TransformationCatalogEntry entry)
Add single TCEntry to the Catalog.
|
int |
Text.insert(TransformationCatalogEntry entry)
Add single TCEntry to the Catalog.
|
int |
File.insert(TransformationCatalogEntry entry)
Add single TCEntry to the Catalog.
|
int |
Database.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 |
File.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 |
Database.insert(java.util.List<TransformationCatalogEntry> tcentry)
Add multiple TCEntries to the Catalog.
|
int |
Text.insert(java.util.List<TransformationCatalogEntry> entries)
Add multiple TCEntries to the Catalog.
|
int |
File.insert(java.util.List<TransformationCatalogEntry> entries)
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(java.lang.String fqlfn,
java.lang.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 java.util.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(java.lang.String name,
java.lang.String executableBasename,
java.lang.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 |
SUBDAXGenerator.constructTCEntryFromEnvironment()
Returns a transformation 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.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.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 |
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.constructTCEntryFromPath()
Returns a tranformation catalog entry object constructed from the path
environment variable
|
private TransformationCatalogEntry |
SUBDAXGenerator.constructTransformationCatalogEntryForDAGMan(java.lang.String path)
Constructs TransformationCatalogEntry for DAGMan.
|
private TransformationCatalogEntry |
SUBDAXGenerator.defaultTCEntry(java.lang.String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
private TransformationCatalogEntry |
CondorGenerator.defaultTCEntry(java.lang.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(java.lang.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(java.lang.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 |
---|---|
java.util.List<TransformationCatalogEntry> |
DAXParser3.convertExecutableToTCE(Executable executable)
Converts the executable into transformation catalog entries
|
Modifier and Type | Method and Description |
---|---|
void |
DAX2Metadata.cbExecutable(TransformationCatalogEntry tce)
Callback when a transformation catalog entry is encountered in the DAX
|
void |
ExampleDAXCallback.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 |
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 |
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
|
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(java.lang.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(java.lang.String site,
java.lang.String pegasusHome,
SysInfo sysinfo,
boolean useFullPath,
java.lang.String name,
java.lang.String executable)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected TransformationCatalogEntry |
DeployWorkerPackage.addDefaultTCEntryForPegasusWebsite(java.lang.String site,
java.lang.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(java.util.List entries,
Job job,
java.lang.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(java.lang.String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected TransformationCatalogEntry |
RM.getTCEntry(java.lang.String site)
Returns the TCEntry object for the rm executable on a grid site.
|
protected TransformationCatalogEntry |
Cleanup.getTCEntry(java.lang.String site)
Returns the TCEntry object for the rm executable on a grid stagingSite.
|
Modifier and Type | Method and Description |
---|---|
private TransformationCatalogEntry |
DefaultImplementation.defaultTCEntry(java.lang.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(java.lang.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(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
protected TransformationCatalogEntry |
AbstractMultipleFTPerXFERJob.defaultTCEntry(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String executableBasename,
java.lang.String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
private TransformationCatalogEntry |
Abstract.defaultXBitTCEntry(java.lang.String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
TransformationCatalogEntry |
GUC.getTransformationCatalogEntry(java.lang.String siteHandle,
int jobClass)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|
TransformationCatalogEntry |
T2.getTransformationCatalogEntry(java.lang.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(java.lang.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(java.lang.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(java.lang.String namespace,
java.lang.String name,
java.lang.String version,
java.lang.String executableBasename,
java.lang.String site)
Returns a default TC entry to be used in case entry is not found in the
transformation catalog.
|
TransformationCatalogEntry |
Transfer.getTransformationCatalogEntry(java.lang.String siteHandle)
Retrieves the transformation catalog entry for the executable that is
being used to transfer the files in the implementation.
|