Modifier and Type | Method and Description |
---|---|
KeplerLSID |
RemoveCustomKeplerDocumentationAction.getLSID() |
KeplerLSID |
ShowDocumentationAction.getLsidToView() |
Modifier and Type | Method and Description |
---|---|
void |
RemoveCustomKeplerDocumentationAction.setLSID(KeplerLSID lsid) |
void |
ShowDocumentationAction.setLsidToView(KeplerLSID lsid) |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
OpenCompositeAction.getLsidToOpen() |
Modifier and Type | Method and Description |
---|---|
void |
OpenCompositeAction.setLsidToOpen(KeplerLSID lsid) |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
LibLsidViewerAction.getLsidToView() |
Modifier and Type | Method and Description |
---|---|
void |
LibLsidViewerAction.setLsidToView(KeplerLSID lsid) |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
SaveKAR.checkNamedObjLSID(NamedObj no)
Every NamedObj should have an LSID.
|
KeplerLSID[] |
KARFile.getContentOfType(java.lang.String getType)
Return an array of lsids of a certain type from within this kar. if the
type is null return all of the lsids
|
KeplerLSID |
KARBuilder.getKarLSID() |
KeplerLSID |
KARCached.getLsid() |
KeplerLSID |
KARCacheContent.getLsid() |
KeplerLSID |
KARCacheError.getLsid() |
KeplerLSID |
KARFile.getLSID() |
KeplerLSID |
KAREntry.getLSID() |
KeplerLSID |
SaveKAR.saveToDisk(TableauFrame tableauFrame,
java.lang.String overrideModDeps)
Save this KAR file to disk.
|
Modifier and Type | Method and Description |
---|---|
java.util.Set<KeplerLSID> |
KARFile.getContainedLSIDs()
Return the LSIDs of all of the entries contained by this KARFile.
|
java.util.Vector<KeplerLSID> |
KARBuilder.getKAREntryLSIDs(java.util.Hashtable<KAREntry,java.io.InputStream> entries) |
java.util.List<KeplerLSID> |
KAREntry.getLsidDependencies() |
java.util.Vector<KeplerLSID> |
KARCacheContent.getSemanticTypes() |
static java.util.Vector<KeplerLSID> |
KAREntry.parseLsidDependencies(java.util.jar.Attributes atts) |
Modifier and Type | Method and Description |
---|---|
void |
KAREntry.addLsidDependency(KeplerLSID lsid) |
static java.lang.String |
UploadToRepository.buildAccessDocument(KeplerLSID lsid)
uploads a document as the kepler user with public read permissions
|
static java.lang.String |
UploadToRepository.buildAccessDocument(KeplerLSID lsid,
boolean publicDoc) |
static java.lang.String |
UploadToRepository.buildAccessDocument(KeplerLSID lsid,
java.lang.String owner,
boolean publicDoc)
build an access document that gives 'public' read access to the inserted
documents.
|
boolean |
KAREntry.dependsOn(KeplerLSID lsid) |
java.lang.String |
KARFile.getEntryName(KeplerLSID lsid) |
java.lang.String |
KARFile.getEntryType(KeplerLSID lsid) |
java.util.Vector<KARCacheContent> |
KARCacheManager.getKARCacheContents(KeplerLSID lsid)
Return all of the KARCacheContents matching the specified lsid.
|
java.util.zip.ZipEntry |
KARFile.getKAREntry(KeplerLSID lsid)
returns a KAREntry for the given lsid.
|
void |
KARCacheManager.insertEntryIntoCache(java.io.File karFile,
KeplerLSID entryLSID,
java.lang.String entryName,
java.lang.String entryType) |
boolean |
UploadToRepository.isAlreadyRegistered(KeplerLSID lsid) |
boolean |
KARCacheManager.isCached(KeplerLSID karLSID)
Deprecated.
Cached Kars now use the File as the primary key Use
isCached(File) instead
|
void |
KARCacheContent.populate(java.io.File karFile,
KeplerLSID lsid,
java.sql.Statement stmt)
Populate this object from the database. setKarLsid() and setLsid() must
be called before running this method.
|
void |
KAREntry.removeLsidDependency(KeplerLSID lsid) |
java.util.Hashtable<KAREntry,java.io.InputStream> |
KAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
Return an array of KAREntry objects that are to be saved for the given
lsids.
|
void |
KARBuilder.setKarLSID(KeplerLSID karLSID) |
void |
KARCached.setLsid(KeplerLSID lsid) |
void |
KARCacheError.setLsid(KeplerLSID lsid) |
void |
KARFile.setLSID(KeplerLSID lsid) |
void |
KAREntry.setLSID(KeplerLSID lsid) |
void |
SaveKAR.specifyLSID(KeplerLSID lsid)
Set the LSID to be used for the KAR.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ExportRunsToKAR.exportRunsToKAR(java.util.List<KeplerLSID> runLSIDs,
java.io.File karFile,
boolean addToLibraryAndCache,
boolean overrideKARModuleDependencies)
Export a list of runs and their associated workflow MoML into a KAR.
|
java.util.ArrayList<NamedObj> |
ExportRunsToKAR.prepareNamedObjs(java.util.List<KeplerLSID> runLSIDs)
helper method prepares list of NamedObjs (workflows) for KAR from list of run LSIDs
|
java.util.Hashtable<KAREntry,java.io.InputStream> |
KAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
Return an array of KAREntry objects that are to be saved for the given
lsids.
|
void |
KARCacheContent.setSemanticTypes(java.util.Vector<KeplerLSID> semanticTypes) |
Constructor and Description |
---|
ExportRunsToKAR(Queryable q,
KeplerLSID wfLSID)
Constructor
|
Modifier and Type | Method and Description |
---|---|
java.util.Hashtable<KAREntry,java.io.InputStream> |
JARKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
java.util.Hashtable<KAREntry,java.io.InputStream> |
ActorMetadataKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
The save method for ActorMetadataKAREntryHandler is not used since Actors
and Workflows are not dependent on anything else.
|
java.util.Hashtable<KAREntry,java.io.InputStream> |
ModuleTxtKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
Return an array of KAREntry objects that are to be saved for the given
lsid.
|
java.util.Hashtable<KAREntry,java.io.InputStream> |
ProvKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
Serialize a workflow execution to a KAR entry.
|
java.util.Hashtable<KAREntry,java.io.InputStream> |
WorkflowRunEntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
java.util.Hashtable<KAREntry,java.io.InputStream> |
ReportLayoutKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
java.util.Hashtable<KAREntry,java.io.InputStream> |
ReportInstanceKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
Modifier and Type | Method and Description |
---|---|
java.util.Hashtable<KAREntry,java.io.InputStream> |
JARKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
java.util.Hashtable<KAREntry,java.io.InputStream> |
ActorMetadataKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
The save method for ActorMetadataKAREntryHandler is not used since Actors
and Workflows are not dependent on anything else.
|
java.util.Hashtable<KAREntry,java.io.InputStream> |
ModuleTxtKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
Return an array of KAREntry objects that are to be saved for the given
lsid.
|
java.util.Hashtable<KAREntry,java.io.InputStream> |
ProvKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame)
Serialize a workflow execution to a KAR entry.
|
java.util.Hashtable<KAREntry,java.io.InputStream> |
WorkflowRunEntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
java.util.Hashtable<KAREntry,java.io.InputStream> |
ReportLayoutKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
java.util.Hashtable<KAREntry,java.io.InputStream> |
ReportInstanceKAREntryHandler.save(java.util.Vector<KeplerLSID> lsids,
KeplerLSID karLsid,
TableauFrame tableauFrame) |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
NamedObjId.getId() |
static KeplerLSID |
NamedObjId.getIdFor(NamedObj no)
Return the LSID for the given NamedObj.
|
KeplerLSID |
KeplerActorMetadata.getLsid() |
Modifier and Type | Method and Description |
---|---|
java.util.List<KeplerLSID> |
NamedObjIdReferralList.getReferrals()
This method returns a list of KeplerLSID objects.
|
Modifier and Type | Method and Description |
---|---|
void |
NamedObjIdReferralList.addReferral(KeplerLSID lsid)
Add an LSID to the referral list.
|
static void |
NamedObjId.assignIdTo(NamedObj no,
KeplerLSID lsid)
Assign the given KeplerLSID to this NamedObj.
|
static void |
NamedObjId.assignIdTo(NamedObj no,
KeplerLSID lsid,
boolean updateReferrals)
Assign the given KeplerLSID to this NamedObj.
|
boolean |
NamedObjIdReferralList.hasReferral(KeplerLSID lsid) |
static boolean |
NamedObjId.idMatches(KeplerLSID lsid,
NamedObj no,
boolean matchRevision)
Check the given NamedObj to see if it matches the search ID.
|
void |
NamedObjIdReferralList.removeReferral(KeplerLSID removeLSID)
Remove an LSID from the referral list.
|
void |
NamedObjId.setExpression(KeplerLSID lsid)
Helper method for setting the expression directly with a KeplerLSID
object.
|
void |
KeplerActorMetadata.setLsid(KeplerLSID lsid) |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
ActorMetadata.getLSID()
returns the id of this object as a KeplerLSID
|
Modifier and Type | Method and Description |
---|---|
NamedObj |
ObjectManager.getHighestObjectRevision(KeplerLSID lsid)
Return the NamedObj that has the highest revision number for a given LSID
after searching through all the NamedObjs accessible by the
ObjectManager.
|
NamedObj |
ObjectManager.getObjectRevision(KeplerLSID lsid) |
java.lang.String |
ObjectManager.getObjectType(KeplerLSID lsid) |
NamedObj |
ObjectManager.removeObject(KeplerLSID lsid)
Attempts to remove object from ObjectManager:
if getObjectRevision(lsid) returns a NamedObj, calls removeNamedObj on
this NamedObj.
|
NamedObj |
ObjectManager.removeObjectForLSID(KeplerLSID lsid) |
Modifier and Type | Field and Description |
---|---|
protected KeplerLSID |
CacheObject._lsid |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
CacheContent.getLsid() |
KeplerLSID |
CacheObject.getLSID()
get the lsid for this object
|
KeplerLSID |
CacheObjectInterface.getLSID()
get the lsid for this object
|
Modifier and Type | Method and Description |
---|---|
java.util.Vector<KeplerLSID> |
CacheManager.getCachedLsids()
Return a complete list of KeplerLSIDs for everything that is in the
cache.
|
java.util.Vector<KeplerLSID> |
CacheManager.getCachedLsids(KeplerLSID lsid) |
java.util.List<KeplerLSID> |
CacheManager.getCachedLsidsForClass(java.lang.String className)
Get a list of LSIDs for a class name.
|
java.util.Vector<KeplerLSID> |
CacheContent.getSemanticTypes() |
java.util.Vector<KeplerLSID> |
CacheManager.getSemanticTypesFor(KeplerLSID lsid)
Return a list of Semantic Types for the given LSID.
|
Modifier and Type | Method and Description |
---|---|
java.util.Vector<KeplerLSID> |
CacheManager.getCachedLsids(KeplerLSID lsid) |
java.lang.Long |
CacheManager.getHighestCachedLsidRevision(KeplerLSID lsid) |
CacheObject |
CacheManager.getHighestCacheObjectRevision(KeplerLSID anLsid)
Return the CacheObject that has the highest revision number and matches
the given LSID, return null if not found.
|
CacheObjectInterface |
CacheManager.getObject(KeplerLSID lsid)
return the CacheObjectInterface with the specified lsid.
|
java.util.Vector<KeplerLSID> |
CacheManager.getSemanticTypesFor(KeplerLSID lsid)
Return a list of Semantic Types for the given LSID.
|
boolean |
CacheManager.isContained(KeplerLSID lsid)
return true of the given lsid has an associated object in the cache
|
void |
CacheContent.populate(KeplerLSID lsid,
java.sql.Statement stmt) |
void |
CacheManager.removeObject(KeplerLSID lsid)
remove the CacheObjectInterface with the specified lsid.
|
void |
CacheContent.setLsid(KeplerLSID lsid) |
void |
CacheObject.setLSID(KeplerLSID lsid)
set the lsid
|
void |
CacheObjectInterface.setLSID(KeplerLSID lsid)
set the lsid
|
Constructor and Description |
---|
ActorCacheObject(java.lang.String name,
KeplerLSID lsid)
construct a new CacheObject
|
CacheObject(java.lang.String name,
KeplerLSID lsid)
construct a new CacheObject
|
RawDataCacheObject(java.lang.String name,
KeplerLSID lsid)
construct a new CacheObject
|
ReportLayoutCacheObject(java.lang.String name,
KeplerLSID lsid)
construct a new CacheObject
|
WorkflowRunCacheObject(java.lang.String name,
KeplerLSID lsid,
WorkflowRun run)
Create a WorkflowRunCacheObject from given run, put it into cache and
return the WorkflowRunCacheObject.
|
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
LibItem.getLsid() |
Modifier and Type | Method and Description |
---|---|
java.util.Vector<KeplerLSID> |
LibItem.getLsids() |
Modifier and Type | Method and Description |
---|---|
void |
LibItem.addLsid(KeplerLSID lsid) |
java.util.Vector<java.lang.Integer> |
LibIndex.removeItemsByLsid(KeplerLSID lsidToRemove)
This method will remove the given LSID from being associated with any of
the Library Items.
|
void |
LibItem.removeLsid(KeplerLSID lsid) |
void |
LibItem.setLsid(KeplerLSID lsid) |
void |
LibIndex.updateDefaultLsid(int liid,
KeplerLSID lsid)
Update the default LSID for the given LIID to the given LSID.
|
Modifier and Type | Method and Description |
---|---|
java.util.Vector<java.lang.Integer> |
LibraryManager.getLiidsFor(java.util.Vector<KeplerLSID> lsids)
Return the LIIDs for the given set of LSIDs.
|
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
LSIDGenerator.getNewLSID()
Return a new LSID using the Authority and Namespace for this Kepler
Instance and the NextObjectID for this instance with a revision number of
1.
|
KeplerLSID |
LSIDGenerator.updateLsidRevision(KeplerLSID lsid)
Update the revision of a KeplerLSID.
|
Modifier and Type | Method and Description |
---|---|
boolean |
KeplerLSID.equalsWithAnchor(KeplerLSID lsid)
return true if this lsid equals the passed in lsid and the anchors are
the same.
|
boolean |
KeplerLSID.equalsWithoutRevision(KeplerLSID lsid)
return true if this lsid equals the passed in lsid regardless of
revision or anchor
|
KeplerLSID |
LSIDGenerator.updateLsidRevision(KeplerLSID lsid)
Update the revision of a KeplerLSID.
|
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
EcogridRepository.addRegistryEntry(org.ecoinformatics.ecogrid.registry.stub.RegistryEntryType registryEntry,
java.lang.String sessionId)
add an ecogrid registry entry.
|
Modifier and Type | Method and Description |
---|---|
abstract java.io.InputStream |
Repository.get(KeplerLSID lsid,
boolean authenticate)
return the object from the repository that has the given lsid
|
java.io.InputStream |
EcogridRepository.get(KeplerLSID lsid,
boolean authenticate)
return the object from the repository that has the given lsid
|
java.lang.String |
EcogridRepository.getNextObject(KeplerLSID lsid)
returns the next object for the given lsid
|
java.lang.String |
EcogridRepository.getNextRevision(KeplerLSID lsid)
returns the next revision for the given lsid
|
abstract void |
Repository.put(java.lang.Object o,
KeplerLSID lsid,
java.lang.String sessionid)
put an object into the repository with a predetermined sessionid
|
void |
EcogridRepository.put(java.lang.Object o,
KeplerLSID lsid,
java.lang.String sessionId)
put a file with a predetermined sessionid
|
void |
EcogridRepository.removeRegistryEntry(KeplerLSID lsid,
java.lang.String sessionId)
remove an ecogrid registry entry.
|
void |
EcogridRepository.updateRegistryEntry(java.lang.String registryEntry,
KeplerLSID lsid)
update an ecogrid registry entry.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionMonitorPanel.ExecutionMonitorRecording.executionStart(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the starting of workflow execution.
|
void |
ExecutionMonitorPanel.ExecutionMonitorRecording.executionStop(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the stopping of workflow execution.
|
Modifier and Type | Field and Description |
---|---|
protected KeplerLSID |
Recording._containerLSID
The LSID of the containing workflow.
|
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
ProvenanceRecorder.getExecutionLSID()
Get the execution LSID.
|
KeplerLSID |
DefaultQuery.getExecutionLSIDForExecution(java.lang.Integer execId) |
KeplerLSID |
Queryable.getExecutionLSIDForExecution(java.lang.Integer execId)
Get the execution LSID for a specific execution id.
|
KeplerLSID |
DefaultQuery.getLastExecutionLSIDForWorkflow(KeplerLSID lsid) |
KeplerLSID |
Queryable.getLastExecutionLSIDForWorkflow(KeplerLSID lsid)
Get the last execution LSID for a workflow.
|
KeplerLSID |
DefaultQuery.getLastExecutionLSIDForWorkflow(java.lang.String workflow) |
KeplerLSID |
Queryable.getLastExecutionLSIDForWorkflow(java.lang.String workflow)
Get the last execution LSID for a workflow.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<KeplerLSID> |
DefaultQuery.getExecutionLSIDs() |
java.util.List<KeplerLSID> |
Queryable.getExecutionLSIDs()
Get a list of all execution LSIDs.
|
java.util.List<KeplerLSID> |
DefaultQuery.getExecutionLSIDsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after,
java.util.Date before,
int execIdAfter,
int execIdBefore) |
java.util.List<KeplerLSID> |
Queryable.getExecutionLSIDsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after,
java.util.Date before,
int execIdAfter,
int execIdBefore) |
java.util.List<KeplerLSID> |
DefaultQuery.getExecutionsForType(WorkflowRun.type type) |
java.util.List<KeplerLSID> |
Queryable.getExecutionsForType(WorkflowRun.type type)
Get a list of executions corresponding to a specific type.
|
java.util.Map<KeplerLSID,WorkflowRun> |
DefaultQuery.getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executions) |
java.util.Map<KeplerLSID,WorkflowRun> |
Queryable.getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executions)
Get "workflow runs" for a list of execution LSIDs.
|
Modifier and Type | Method and Description |
---|---|
protected java.lang.Integer |
DefaultQuery._getLastExecutionId(KeplerLSID workflow)
Get the last execution id for a workflow.
|
boolean |
Recording.changeExecutionLSID(int execId,
KeplerLSID newExecLSID,
Queryable q)
Change execution LSID for an execution Id.
|
void |
Recording.executionError(Nameable source,
java.lang.Throwable throwable,
KeplerLSID executionLSID)
An actor threw an exception.
|
void |
Recording.executionImported(KeplerLSID executionLSID)
An execution was imported.
|
void |
ProvenanceRecorder.executionImported(KeplerLSID execLSID)
Report that an execution has been imported
|
void |
Recording.executionStart(KeplerLSID executionLSID)
Record the starting of workflow execution.
|
void |
Recording.executionStart(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the starting of workflow execution at a specific time.
|
void |
Recording.executionStop(KeplerLSID executionLSID)
Record the stopping of workflow execution.
|
void |
Recording.executionStop(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the stopping of workflow execution.
|
java.lang.Integer |
DefaultQuery.getEntityId(java.lang.String entityName,
KeplerLSID lsid) |
java.lang.Integer |
Queryable.getEntityId(java.lang.String entityName,
KeplerLSID lsid)
Get the id of entity.
|
java.lang.String |
DefaultQuery.getErrorForExecution(KeplerLSID lsid) |
java.lang.String |
Queryable.getErrorForExecution(KeplerLSID lsid)
Get the error for an execution.
|
java.lang.Integer |
DefaultQuery.getExecutionForExecutionLSID(KeplerLSID runLSID) |
java.lang.Integer |
Queryable.getExecutionForExecutionLSID(KeplerLSID runLSID)
Get the execution for a specific run LSID.
|
java.util.Map<java.lang.String,java.lang.Long> |
DefaultQuery.getExecutionTimesForActor(KeplerLSID workflow,
KeplerLSID execLSID,
java.lang.String actor)
Get the execution times for an actor.
|
java.util.Map<java.lang.String,java.lang.Long> |
Queryable.getExecutionTimesForActor(KeplerLSID workflow,
KeplerLSID execLSID,
java.lang.String actor)
Get the execution times for an actor.
|
java.util.Map<java.lang.Integer,java.lang.Integer> |
DefaultQuery.getIOBytesForPort(KeplerLSID workflow,
java.lang.Integer execId,
java.lang.String port,
boolean read)
Get the number of bytes read or written by a port.
|
java.util.Map<java.lang.Integer,java.lang.Integer> |
Queryable.getIOBytesForPort(KeplerLSID workflow,
java.lang.Integer execId,
java.lang.String port,
boolean read)
Get the number of bytes read or written by a port.
|
java.lang.Integer |
DefaultQuery.getLastExecutionForWorkflow(KeplerLSID lsid) |
java.lang.Integer |
Queryable.getLastExecutionForWorkflow(KeplerLSID lsid)
Get the last execution for a workflow.
|
KeplerLSID |
DefaultQuery.getLastExecutionLSIDForWorkflow(KeplerLSID lsid) |
KeplerLSID |
Queryable.getLastExecutionLSIDForWorkflow(KeplerLSID lsid)
Get the last execution LSID for a workflow.
|
java.lang.String |
DefaultQuery.getMoMLForExecution(KeplerLSID lsid) |
java.lang.String |
Queryable.getMoMLForExecution(KeplerLSID lsid)
Get workflow MoML for an execution LSID
|
java.lang.String |
DefaultQuery.getParameterValueAtTime(java.util.Date timestamp,
java.lang.String parameter,
KeplerLSID lsid) |
java.lang.String |
Queryable.getParameterValueAtTime(java.util.Date timestamp,
java.lang.String parameter,
KeplerLSID lsid)
Get the value of a parameter at a specific time.
|
java.lang.String |
DefaultQuery.getParameterValueLatest(java.lang.String parameter,
KeplerLSID lsid) |
java.lang.String |
Queryable.getParameterValueLatest(java.lang.String parameter,
KeplerLSID lsid)
Get the latest value of a parameter.
|
java.util.List<java.lang.String> |
DefaultQuery.getPortsForActor(KeplerLSID workflow,
java.lang.String actor) |
java.util.List<java.lang.String> |
Queryable.getPortsForActor(KeplerLSID workflow,
java.lang.String actor)
Get the ports for an actor.
|
long |
DefaultQuery.getTotalExecutionTimeForActor(KeplerLSID workflow,
KeplerLSID execLSID,
java.lang.String actor)
Get the total execution time for an actor.
|
long |
Queryable.getTotalExecutionTimeForActor(KeplerLSID workflow,
KeplerLSID execLSID,
java.lang.String actor)
Get the total execution time for an actor.
|
java.lang.Integer |
DefaultQuery.getTotalIOBytesForActor(KeplerLSID workflow,
java.lang.Integer execId,
java.lang.String actor,
boolean read)
Get the total number of bytes read or or written by an actor over all its ports.
|
java.lang.Integer |
Queryable.getTotalIOBytesForActor(KeplerLSID workflow,
java.lang.Integer execId,
java.lang.String actor,
boolean read)
Get the total number of bytes read or or written by an actor over all its ports.
|
java.lang.String |
DefaultQuery.getUserForExecution(KeplerLSID execLSID) |
java.lang.String |
Queryable.getUserForExecution(KeplerLSID execLSID)
Get the user for a specific execution LSID.
|
java.lang.String |
DefaultQuery.getWorkflowName(KeplerLSID lsid) |
java.lang.String |
Queryable.getWorkflowName(KeplerLSID lsid)
Get a workflow name.
|
java.lang.String |
DefaultQuery.getWorkflowNameForExecution(KeplerLSID lsid) |
java.lang.String |
Queryable.getWorkflowNameForExecution(KeplerLSID lsid)
Get a workflow name for an execution LSID.
|
boolean |
DefaultQuery.isErrorForExecution(KeplerLSID executionLSID) |
boolean |
Queryable.isErrorForExecution(KeplerLSID executionLSID)
Returns true if the execution had an error.
|
boolean |
DefaultQuery.isImportedExecution(KeplerLSID executionLSID) |
boolean |
Queryable.isImportedExecution(KeplerLSID executionLSID)
See if an execution appears to be imported.
|
void |
Recording.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
A workflow was renamed.
|
void |
ProvenanceRecorder.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
A workflow was renamed.
|
void |
Recording.setContainerLSID(KeplerLSID lsid)
Set the container LSID.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
DefaultQuery.getMoMLForExecutionLSIDs(java.util.List<KeplerLSID> lsids) |
java.util.List<java.lang.String> |
Queryable.getMoMLForExecutionLSIDs(java.util.List<KeplerLSID> lsids)
Get workflow MoMLs for a list of execution lsids.
|
java.util.Map<KeplerLSID,WorkflowRun> |
DefaultQuery.getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executions) |
java.util.Map<KeplerLSID,WorkflowRun> |
Queryable.getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executions)
Get "workflow runs" for a list of execution LSIDs.
|
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
UploadKarToRepositoryNoGUI.buildAccessDocument(KeplerLSID lsid)
uploads a document as the kepler user with public read permissions
|
static java.lang.String |
UploadKarToRepositoryNoGUI.buildAccessDocument(KeplerLSID lsid,
boolean publicDoc) |
static java.lang.String |
UploadKarToRepositoryNoGUI.buildAccessDocument(KeplerLSID lsid,
java.lang.String owner,
boolean publicDoc)
build an access document that gives 'public' read access to the inserted
documents.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<KeplerLSID> |
TransferComponent.getExecutionLSIDs()
Get the KeplerLSIDs for provenance executions.
|
Modifier and Type | Method and Description |
---|---|
static void |
ProvenanceManager.exportROBundle(java.lang.String outputFileName,
KeplerLSID runLSID)
Export a research object bundle
|
static void |
ProvenanceManager.exportWorkflow(java.lang.String outputFileName,
KeplerLSID runLSID)
Export a workflow to a file.
|
Modifier and Type | Method and Description |
---|---|
void |
TransferComponent.addExecutions(java.util.List<KeplerLSID> executionLSIDs)
Add KeplerLSIDs for provenance executions.
|
static void |
ProvenanceManager.deleteRuns(java.util.List<KeplerLSID> execLSIDs)
Delete runs.
|
static void |
ProvenanceManager.exportProvenance(java.lang.String outputFileName,
boolean delete,
java.util.List<KeplerLSID> runs)
Export a set of provenance runs to a KAR file.
|
static void |
ProvenanceManager.exportProvenance(java.lang.String outputFileName,
boolean delete,
java.util.List<KeplerLSID> runs,
java.lang.String format)
Export a set of provenance runs to a KAR file.
|
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
ProvQuery.getExecutionLSIDForExecution(java.lang.Integer execId)
Get the execution LSID for a workflow execution id.
|
Modifier and Type | Method and Description |
---|---|
void |
ProvRecording.executionStart(KeplerLSID executionLSID,
java.util.Date timestamp) |
void |
ProvRecording.executionStop(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the stopping of workflow execution.
|
Modifier and Type | Field and Description |
---|---|
protected KeplerLSID |
SQLRecordingV8._wfLSID
The current workflow id.
|
Modifier and Type | Field and Description |
---|---|
protected java.util.Map<KeplerLSID,java.lang.Integer> |
SQLRecordingV8._executionLSIDtoIdMap |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
SQLQueryV8.getExecutionLSIDForExecution(java.lang.Integer execId)
Get the execution LSID for a specific execution id.
|
KeplerLSID |
SQLQueryV8.getLastExecutionLSIDForWorkflow(KeplerLSID lsid)
Get the last execution LSID for a workflow.
|
KeplerLSID |
SQLQueryV8.getLastExecutionLSIDForWorkflow(java.lang.String workflow)
Get the last execution LSID for a workflow.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<KeplerLSID> |
SQLQueryV8.getExecutionLSIDs()
Get a list of all execution LSIDs.
|
java.util.List<KeplerLSID> |
SQLQueryV8.getExecutionLSIDsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after,
java.util.Date before,
int execIdAfter,
int execIdBefore)
Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
|
java.util.List<KeplerLSID> |
SQLQueryV8.getExecutionsForType(WorkflowRun.type type)
Get a list of executions corresponding to a specific type.
|
java.util.Map<KeplerLSID,WorkflowRun> |
SQLQueryV8.getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executionLSIDs)
Get WorkflowRuns for a list of execution LSIDs
|
Modifier and Type | Method and Description |
---|---|
protected void |
SQLRecordingV8._changeWorkflowNameColumn(java.lang.String newName,
KeplerLSID lsid)
Change the workflow.name column for a specific LSID.
|
boolean |
SQLRecordingV8.changeExecutionLSID(int execId,
KeplerLSID newExecLSID,
Queryable q)
Change execution LSID for an execution Id.
|
boolean |
SQLRecordingV8.changeExecutionType(KeplerLSID executionLSID,
WorkflowRun.type type)
Change the execution type.
|
void |
SQLRecordingV8.executionError(Nameable source,
java.lang.Throwable throwable,
KeplerLSID executionLSID)
An actor threw an exception.
|
void |
SQLRecordingV8.executionStart(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the starting of workflow execution.
|
void |
SQLRecordingV8.executionStop(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the stopping of workflow execution.
|
java.lang.Integer |
SQLQueryV8.getEntityId(java.lang.String entityName,
KeplerLSID lsid)
Get the id of entity.
|
java.lang.String |
SQLQueryV8.getErrorForExecution(KeplerLSID lsid)
Get the error for an execution.
|
java.lang.Integer |
SQLQueryV8.getExecutionForExecutionLSID(KeplerLSID execLSID)
Get the execution ids for a specific exec LSID.
|
java.util.Map<java.lang.String,java.lang.Long> |
SQLQueryV8.getExecutionTimesForActor(KeplerLSID workflow,
KeplerLSID execLSID,
java.lang.String actor)
Get the execution times for an actor.
|
java.util.Map<java.lang.Integer,java.lang.Integer> |
SQLQueryV8.getIOBytesForPort(KeplerLSID workflow,
java.lang.Integer execId,
java.lang.String port,
boolean read)
Get the number of bytes read or written by a port.
|
java.lang.Integer |
SQLQueryV8.getLastExecutionForWorkflow(KeplerLSID lsid)
Get the last execution for a workflow.
|
KeplerLSID |
SQLQueryV8.getLastExecutionLSIDForWorkflow(KeplerLSID lsid)
Get the last execution LSID for a workflow.
|
java.lang.String |
SQLQueryV8.getMoMLForExecution(KeplerLSID lsid)
Get workflow MoML for an execution, using execution lsid.
|
java.lang.String |
SQLQueryV8.getParameterValueAtTime(java.util.Date timestamp,
java.lang.String parameter,
KeplerLSID lsid)
Get the value of a parameter at a specific time.
|
java.lang.String |
SQLQueryV8.getParameterValueLatest(java.lang.String parameter,
KeplerLSID lsid)
Get the latest value of a parameter.
|
java.util.List<java.lang.String> |
SQLQueryV8.getPortsForActor(KeplerLSID workflow,
java.lang.String actor)
Get the ports for an actor.
|
java.util.List<java.lang.String> |
SQLQueryV8.getTagURNsForExecutionLSID(KeplerLSID execLSID) |
java.lang.String |
SQLQueryV8.getUserForExecution(KeplerLSID execLSID)
Get the user for a specific execution LSID.
|
java.lang.String |
SQLQueryV8.getWorkflowName(KeplerLSID lsid)
Get a workflow name.
|
java.lang.String |
SQLQueryV8.getWorkflowNameForExecution(KeplerLSID lsid)
Get a workflow name for an execution LSID.
|
boolean |
SQLQueryV8.isErrorForExecution(KeplerLSID executionLSID)
Returns true if the execution had an error.
|
boolean |
SQLQueryV8.isImportedExecution(KeplerLSID executionLSID)
See if an execution appears to be imported.
|
void |
SQLRecordingV8.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
A workflow was renamed.
|
Modifier and Type | Method and Description |
---|---|
int |
SQLRecordingV8.deleteExecutions(java.util.List<KeplerLSID> lsidList)
Delete executions given a list of execution LSIDs.
|
java.util.ArrayList<java.lang.String> |
SQLQueryV8.getMoMLForExecutionLSIDs(java.util.List<KeplerLSID> lsids)
Get workflow MoMLs for a list of execution lsids.
|
java.util.Map<KeplerLSID,WorkflowRun> |
SQLQueryV8.getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executionLSIDs)
Get WorkflowRuns for a list of execution LSIDs
|
Modifier and Type | Method and Description |
---|---|
void |
StaticReportItemImage.generateValues(Queryable queryable,
KeplerLSID lsid,
int execId) |
void |
StaticReportItemLabel.generateValues(Queryable queryable,
KeplerLSID lsid,
int execId) |
void |
StaticReportItemHR.generateValues(Queryable queryable,
KeplerLSID lsid,
int execId) |
void |
StaticReportItemText.generateValues(Queryable queryable,
KeplerLSID lsid,
int execId) |
void |
StaticReportItem.generateValues(Queryable queryable,
KeplerLSID lsid,
int execId,
TableauFrame tableauFrame) |
void |
DynamicReportItem.generateValues(Queryable queryable,
KeplerLSID lsid,
int execId,
TableauFrame tableauFrame)
Retrieves values for a given execution
|
abstract void |
Item.generateValues(Queryable queryable,
KeplerLSID lsid,
int execId,
TableauFrame tableauFrame) |
static ReportInstance |
ReportAssembler.populateReport(Queryable queryable,
ReportLayout reportLayout,
KeplerLSID lsid,
int execId,
TableauFrame tableauFrame) |
static ReportInstance |
ReportAssembler.populateReportWithLatest(Queryable queryable,
ReportLayout reportLayout,
KeplerLSID lsid,
TableauFrame tableauFrame) |
Modifier and Type | Method and Description |
---|---|
static ProvenanceRecorder |
ProvenanceUtil.getProvenanceRecorder(KeplerLSID lsid) |
static Queryable |
ProvenanceUtil.getQueryable(KeplerLSID lsid,
TableauFrame tf) |
static void |
ProvenanceUtil.returnQueryable(KeplerLSID lsid) |
Modifier and Type | Field and Description |
---|---|
protected KeplerLSID |
ReportLayout.lsid |
protected KeplerLSID |
ReportLayout.workflowLsid |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
ReportLayout.getLsid() |
KeplerLSID |
ReportLayout.getWorkflowLSID() |
Modifier and Type | Method and Description |
---|---|
void |
ReportLayout.setLsid(KeplerLSID lsid) |
void |
ReportLayout.setWorkflowLSID(KeplerLSID workflowLsid) |
Modifier and Type | Method and Description |
---|---|
KeplerLSID |
WorkflowRunBuilder.getExecLSID() |
KeplerLSID |
WorkflowRun.getExecLSID() |
KeplerLSID |
RemoteStoreRunsTracker.getImportedKARRunLSID(java.lang.String lookup)
From the tracker file, get the LSID of the WorkflowRun
post KAR-import.
|
KeplerLSID |
WorkflowRunBuilder.getKARLSID() |
KeplerLSID |
RemoteStoreRunsTracker.getKARLSID(java.lang.String lookup)
From the tracker file, get the KAR LSID for a run.
|
KeplerLSID |
RemoteStoreRunsTracker.getOriginalRunLSID(java.lang.String lookup)
From the tracker file, get the original LSID of
the WorkflowRun in the KAR.
|
KeplerLSID |
RemoteStoreRunsTracker.getPreviewRunLSID(java.lang.String lookup)
From the tracker file, get the LSID of the preview WorkflowRun
(the WorkflowRun that was downloaded, modified, and imported
into the local reflection store).
|
KeplerLSID |
WorkflowRun.getWorkflowLSID()
Return the LSID of the workflow that this WorkflowRun was generated from.
|
Modifier and Type | Method and Description |
---|---|
java.util.Map<KeplerLSID,WorkflowRun> |
ProvenanceStore.downloadAllWorkflowRunsParsingKarXmls(boolean authenticate)
Deprecated.
use downloadAllWorkflowRuns instead. This method is less fragile
but requires downloading all karXmls, which is extremely inefficient.
|
java.util.List<KeplerLSID> |
RemoteStoreRunsTracker.getOriginalRunLSIDs()
From the tracker file, get all original
WorkflowRun LSIDs.
|
java.util.List<KeplerLSID> |
WorkflowRun.getReferralList() |
Modifier and Type | Method and Description |
---|---|
static WorkflowRun |
WorkflowRunUtil.lookupWorkflowRun(KeplerLSID workflowRunLSID,
Queryable queryable) |
static void |
RenameUtil.notifyWorkflowRenameListeners(ComponentEntity ce,
java.lang.String oldName,
java.lang.String newName,
KeplerLSID oldLSID,
KeplerLSID currentLSID) |
void |
WorkflowRenameManager.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
Notify all WorkflowRenameListeners that a workflow was renamed.
|
void |
WorkflowRenameListener.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
A workflow was renamed.
|
void |
WorkflowRun.rollRevision(KeplerLSID lsid,
Recording recording)
Whenever a run is changed, update revision in OM,
update run's execLSID, and update workflow_exec lsid in provenance.
|
boolean |
RemoteStoreRunsTracker.setExecId(KeplerLSID lookupLSID,
java.lang.Integer execId,
boolean serialize) |
boolean |
RemoteStoreRunsTracker.setImportedKARRunLSID(java.lang.String lookup,
KeplerLSID lsid,
boolean serialize)
Set importedKARRunLSID.
|
boolean |
RemoteStoreRunsTracker.setKARLSID(java.lang.String lookup,
KeplerLSID lsid,
boolean serialize) |
boolean |
RemoteStoreRunsTracker.setOriginalRunLSID(KeplerLSID lookupLSID,
KeplerLSID originalRunLSID,
boolean serialize) |
boolean |
RemoteStoreRunsTracker.setPreviewRunLSID(KeplerLSID lookupLSID,
KeplerLSID lsid,
boolean serialize) |
Constructor and Description |
---|
WorkflowRun(KeplerLSID runlsid,
java.lang.String referralList,
java.lang.String theUser,
java.lang.String workflowName,
KeplerLSID wfLSID,
java.util.Date start,
java.lang.Long dur,
java.lang.Integer execid,
java.util.Map<java.lang.Integer,java.lang.String> errorMsgs,
java.lang.String host_id,
java.lang.String anno,
java.lang.String module_dependencies,
java.lang.String type,
java.util.Map<NamedOntClass,java.lang.String> tagsList)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
WebViewRecording.executionError(Nameable source,
java.lang.Throwable throwable,
KeplerLSID executionLSID)
An actor threw an exception.
|
void |
WebViewRecording.executionStart(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the starting of workflow execution at a specific time.
|
void |
WebViewRecording.executionStop(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the stopping of workflow execution.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<KeplerLSID> |
WorkflowManager.getKeplerLSID(TableauFrame tableauFrame)
Return a List of LSIDS that are associated with the given TableauFrame.
|
Modifier and Type | Method and Description |
---|---|
Workflow |
WorkflowManager.getWorkflow(TableauFrame tableauFrame,
KeplerLSID workflowId) |
Workflow |
WorkflowManager.removeWorkflow(KeplerLSID workflowId) |
boolean |
WorkflowManager.workflowExists(KeplerLSID workflowId) |
Constructor and Description |
---|
Workflow(TableauFrame tableauFrame,
KeplerLSID lsid) |
Modifier and Type | Method and Description |
---|---|
java.util.List<KeplerLSID> |
WorkflowRunManagerEvent.getEventLSIDs() |
java.util.Vector<KeplerLSID> |
WorkflowRunManager.getSelectedRunsForSave() |
Modifier and Type | Method and Description |
---|---|
void |
WorkflowRunManager.addRunToSelectedRuns(KeplerLSID runLSID) |
boolean |
WorkflowRunManager.downloadRunKAR(KeplerLSID previewRunLSID,
boolean authenticate)
Download run KAR using the LSID of the preview run stand-in.
|
void |
WorkflowRunManagerRecording.executionError(Nameable source,
java.lang.Throwable throwable,
KeplerLSID execLSID)
update WRM table after an execution gives an error.
|
void |
WorkflowRunManagerRecording.executionImported(KeplerLSID execLSID)
update WRM table after an execution has been imported.
|
void |
WorkflowRunManagerRecording.executionStart(KeplerLSID execLSID)
update WRM table to see a run as it's running.
|
void |
WorkflowRunManagerRecording.executionStop(KeplerLSID execLSID)
update WRM table after an execution finishes.
|
void |
WorkflowRunManager.fireWorkflowRunManagerEvent(java.lang.String eventName,
KeplerLSID lsid,
boolean isLastEvent) |
ComponentEntity |
WorkflowRunManager.getAssociatedWorkflowForWorkflowRun(KeplerLSID runLSID)
Return the ComponenteEntity that was run to create the WorkflowRun that
is identified by the given LSID.
|
WorkflowRun |
WorkflowRunManager.getRun(KeplerLSID execLSID) |
java.util.Vector<WorkflowRun> |
WorkflowRunManager.getWorkflowRunsForWorkflow(KeplerLSID workflowLSID)
Return runs from the list in memory that are associated with particular workflow.
|
void |
WorkflowRunManagerRecording.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
A workflow was renamed.
|
Modifier and Type | Method and Description |
---|---|
int |
WorkflowRunManager.deleteRuns(Recording recording,
java.util.List<KeplerLSID> lsids,
boolean authenticate)
Delete runs in provenance and from local list.
|
int |
WorkflowRunManager.deleteRunsLocally(java.util.List<KeplerLSID> execLSIDs)
Delete runs from local list, CacheManager, and ObjectManager, but not
from provenance.
|
void |
WorkflowRunManager.fireWorkflowRunManagerEvent(java.lang.String eventName,
java.util.List<KeplerLSID> lsids,
boolean isLastEvent,
java.lang.Object eventData) |
Constructor and Description |
---|
WorkflowRunManagerEvent(java.lang.Object source,
java.lang.String eventName,
java.util.List<KeplerLSID> lsids,
boolean isLastEvent,
java.lang.Object eventData) |
Constructor and Description |
---|
ExportRunsArchiveAction(TableauFrame parent,
java.util.List<KeplerLSID> execLSIDs,
java.lang.String overrideModuleDependencies) |