| Package | Description |
|---|---|
| org.kepler.provenance | |
| org.kepler.provenance.prov | |
| org.kepler.provenance.sql | |
| org.kepler.workflowrunmanager |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.Integer |
DefaultQuery._getLastExecutionId(KeplerLSID workflow)
Get the last execution id for a workflow.
|
void |
DefaultQuery.disconnect() |
void |
Queryable.disconnect()
Disconnect from provenance store.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getActorFiringForToken(int tokenId,
boolean read)
Get the firing id(s) of the actor(s) that read or wrote a token.
|
java.util.List<java.lang.Integer> |
Queryable.getActorFiringForToken(int tokenId,
boolean read)
Get the firing id(s) of the actor(s) that read or wrote a token.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getActorFiringIds(java.lang.String actorName,
java.lang.Integer wfExecId) |
java.util.List<java.lang.Integer> |
Queryable.getActorFiringIds(java.lang.String actorName,
java.lang.Integer wfExecId)
Get actor fire ids based on its full name and workflow exec ID.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getActorFirings(int wfExecId) |
java.util.List<java.lang.Integer> |
Queryable.getActorFirings(int wfExecId)
Get all actor fire ids for a workflow exec ID.
|
java.lang.String |
DefaultQuery.getActorName(int fireId) |
java.lang.String |
Queryable.getActorName(int fireId)
Get an actor's name for a firing id.
|
java.lang.String |
DefaultQuery.getActorType(int fireId) |
java.lang.String |
Queryable.getActorType(int fireId)
Get an actor's type for a firing id.
|
java.util.List<byte[]> |
DefaultQuery.getAssociatedDataForExecution(int execId,
java.util.Map<java.lang.String,java.lang.String> metadataMap,
boolean matchAny) |
java.util.List<byte[]> |
Queryable.getAssociatedDataForExecution(int execId,
java.util.Map<java.lang.String,java.lang.String> metadataMap,
boolean matchAny)
Get a file associated with an execution.
|
java.util.Map<java.lang.String,java.lang.String> |
DefaultQuery.getAssociatedKeysValuesForExecution(int execId)
Get any associated keys-values for an execution.
|
java.util.Map<java.lang.String,java.lang.String> |
Queryable.getAssociatedKeysValuesForExecution(int execId)
Get any associated keys-values for an execution.
|
java.lang.Integer |
DefaultQuery.getChannelForToken(int tokenId,
boolean read,
java.lang.Integer fireId)
Get the channel that a token was read or written on.
|
java.lang.Integer |
Queryable.getChannelForToken(int tokenId,
boolean read,
java.lang.Integer fireId)
Get the channel that a token was read or written on.
|
static Queryable |
ProvenanceRecorder.getDefaultQueryable(NamedObj namedObj)
Get a queryable from the default provenance recorder for a NamedObj.
|
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.Integer |
DefaultQuery.getEntityId(java.lang.String entityName,
java.lang.String workflowName) |
java.lang.Integer |
Queryable.getEntityId(java.lang.String entityName,
java.lang.String workflowName)
Get the id of entity.
|
java.lang.String |
DefaultQuery.getEntityType(java.lang.Integer entityId) |
java.lang.String |
Queryable.getEntityType(java.lang.Integer entityId)
Get the type of entity.
|
java.lang.Integer |
DefaultQuery.getEntityWorkflowId(java.lang.Integer entityId) |
java.lang.Integer |
Queryable.getEntityWorkflowId(java.lang.Integer entityId)
Get the workflow 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.lang.Integer |
DefaultQuery.getExecutionForExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision) |
java.lang.Integer |
Queryable.getExecutionForExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision)
Get execution id for an execution LSID without revision.
|
java.lang.Integer |
DefaultQuery.getExecutionForOldestReferralExecutionLSIDWithoutRevision(java.lang.String stringWithoutRevision) |
java.lang.Integer |
Queryable.getExecutionForOldestReferralExecutionLSIDWithoutRevision(java.lang.String stringWithoutRevision)
Get execution id for execution that has the given LSID as its
oldest referral.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getExecutionIdsForTags(java.lang.String tagsSearchString) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionIdsForTags(java.lang.String tagsSearchString)
Get execution ids for %tagsSearchString% (case insensitive)
|
KeplerLSID |
DefaultQuery.getExecutionLSIDForExecution(java.lang.Integer execId) |
KeplerLSID |
Queryable.getExecutionLSIDForExecution(java.lang.Integer execId)
Get the execution LSID for a specific execution id.
|
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<java.lang.Integer> |
DefaultQuery.getExecutions() |
java.util.List<java.lang.Integer> |
Queryable.getExecutions()
Get a list of all executions.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getExecutionsForAnnotation(java.lang.String annotation) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionsForAnnotation(java.lang.String annotation)
Get a list of executions for a specific execution annotation.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getExecutionsForTimespan(java.util.Date start,
java.util.Date end) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionsForTimespan(java.util.Date start,
java.util.Date end)
Get executions within a timespan.
|
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.List<java.lang.Integer> |
DefaultQuery.getExecutionsForWorkflow(java.lang.String workflow) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionsForWorkflow(java.lang.String workflow)
Get a list of executions for a specific workflow.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getExecutionsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName)
Get executions that have %workflowName% and %userName%.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getExecutionsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after,
java.util.Date before,
int execIdAfter,
int execIdBefore) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after,
java.util.Date before,
int execIdAfter,
int execIdBefore)
Get executions that have %workflowName% and %userName%. and
startTime >= after and startTime <= before.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getExecutionsForWorkflowRunsAfter(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionsForWorkflowRunsAfter(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after)
Get executions that have %workflowName% and %userName%. and
startTime > after.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getExecutionsForWorkflowRunsBefore(java.lang.String workflowName,
java.lang.String userName,
java.util.Date before) |
java.util.List<java.lang.Integer> |
Queryable.getExecutionsForWorkflowRunsBefore(java.lang.String workflowName,
java.lang.String userName,
java.util.Date before)
Get exections that have %workflowName% and %userName%, and
startTime < before.
|
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.lang.String |
DefaultQuery.getHostIdForExecution(java.lang.Integer execId) |
java.lang.String |
Queryable.getHostIdForExecution(java.lang.Integer execId)
Get the host id for a specific execution id.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getImmediateDependencies(int tokenId) |
java.util.List<java.lang.Integer> |
Queryable.getImmediateDependencies(int tokenId)
Get the token(s) that generated a token.
|
java.lang.String |
DefaultQuery.getInputRoleForTokenAndFireId(int tokenId,
int fireId) |
java.lang.String |
Queryable.getInputRoleForTokenAndFireId(int tokenId,
int fireId)
Get the input role (port name) of a token.
|
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.
|
java.lang.Integer |
DefaultQuery.getLastExecutionForWorkflow(java.lang.String workflow) |
java.lang.Integer |
Queryable.getLastExecutionForWorkflow(java.lang.String workflow)
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.
|
KeplerLSID |
DefaultQuery.getLastExecutionLSIDForWorkflow(java.lang.String workflow) |
KeplerLSID |
Queryable.getLastExecutionLSIDForWorkflow(java.lang.String workflow)
Get the last execution LSID for a workflow.
|
java.lang.String |
DefaultQuery.getMoMLForExecution(int execId) |
java.lang.String |
Queryable.getMoMLForExecution(int execId)
Get workflow MoML for an execution.
|
java.lang.String |
DefaultQuery.getMoMLForExecution(KeplerLSID lsid) |
java.lang.String |
Queryable.getMoMLForExecution(KeplerLSID lsid)
Get workflow MoML for an execution LSID
|
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.lang.String |
DefaultQuery.getOutputRoleToken(int tokenId) |
java.lang.String |
Queryable.getOutputRoleToken(int tokenId)
Get the output role (port name) of a token.
|
java.util.Map<java.lang.String,java.lang.String> |
DefaultQuery.getParameterAndPortParameterNameValuesForFiring(int fireId) |
java.util.Map<java.lang.String,java.lang.String> |
Queryable.getParameterAndPortParameterNameValuesForFiring(int fireId)
Get an actor's parameter and port parameter name value pairs for a firing id.
|
java.util.Map<java.lang.String,java.lang.String> |
DefaultQuery.getParameterNameValuesForExecution(int execId) |
java.util.Map<java.lang.String,java.lang.String> |
Queryable.getParameterNameValuesForExecution(int execId)
Get the parameter name value pairs for an execution.
|
java.util.Map<java.lang.String,java.lang.String> |
DefaultQuery.getParameterNameValuesForFiring(int fireId) |
java.util.Map<java.lang.String,java.lang.String> |
Queryable.getParameterNameValuesForFiring(int fireId)
Get an actor's parameter name value pairs for a firing id.
|
java.util.Map<java.lang.String,java.lang.String> |
DefaultQuery.getParameterNameValuesOfSpecificTypeForExecution(int execId) |
java.util.Map<java.lang.String,java.lang.String> |
Queryable.getParameterNameValuesOfSpecificTypeForExecution(int execId)
Get the parameter name value pairs for an execution, whose parameter type is
either '.Parameter' or '.StringParameter'
|
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.
|
Queryable |
Recording.getQueryable(boolean allowReconnectWF)
Get a Queryable connected to the Recording output.
|
java.util.Map<NamedOntClass,java.lang.String> |
DefaultQuery.getTagClassesForExecutionId(int execId) |
java.util.Map<NamedOntClass,java.lang.String> |
Queryable.getTagClassesForExecutionId(int execId)
Get a map of tags and their types (context, or tagee, currently "run"
or "workflow") for an executionLSID
|
java.util.List<java.lang.String> |
DefaultQuery.getTagsForExecutionId(int execId) |
java.util.List<java.lang.String> |
Queryable.getTagsForExecutionId(int execId)
Get tags for an execution LSID
|
java.util.Date |
DefaultQuery.getTimestampForTokenWrite(java.lang.Integer tokenId)
Get the timestamp when a token was written.
|
java.util.Date |
Queryable.getTimestampForTokenWrite(java.lang.Integer tokenId)
Get the timestamp when a token was written.
|
java.util.Date[] |
DefaultQuery.getTimestampsForActorFiring(int fireId) |
java.util.Date[] |
Queryable.getTimestampsForActorFiring(int fireId)
Get the start and end timestamps of an actor firing.
|
java.util.Date[] |
DefaultQuery.getTimestampsForExecution(int execId) |
java.util.Date[] |
Queryable.getTimestampsForExecution(int execId)
Get the start and end timestamps of an execution.
|
java.util.Date[] |
DefaultQuery.getTimestampsForTokenRead(java.lang.Integer tokenId)
Get the timestamp(s) when a token was read.
|
java.util.Date[] |
Queryable.getTimestampsForTokenRead(java.lang.Integer tokenId)
Get the timestamp(s) when a token was read.
|
Token |
DefaultQuery.getToken(int tokenId)
Get the Token.
|
Token |
Queryable.getToken(int tokenId)
Get the Token.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getTokensForExecution(int execId,
boolean last)
Get an sequence of tokens for an execution.
|
java.util.List<java.lang.Integer> |
Queryable.getTokensForExecution(int execId,
boolean last)
Get an sequence of tokens for an execution.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getTokensForExecution(int execId,
java.lang.Integer portId,
boolean last)
Get an sequence of tokens for an execution.
|
java.util.List<java.lang.Integer> |
Queryable.getTokensForExecution(int execId,
java.lang.Integer portId,
boolean last)
Get an sequence of tokens for an execution.
|
java.util.List<java.lang.Integer> |
DefaultQuery.getTokensForFiring(int fireId,
boolean read) |
java.util.List<java.lang.Integer> |
Queryable.getTokensForFiring(int fireId,
boolean read)
Get tokens for a firing.
|
java.lang.String |
DefaultQuery.getTokenType(int tokenId) |
java.lang.String |
Queryable.getTokenType(int tokenId)
Get the type of a token.
|
java.lang.String |
DefaultQuery.getTokenValue(int tokenId) |
java.lang.String |
Queryable.getTokenValue(int tokenId)
Get the value of a token.
|
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(java.lang.Integer execId) |
java.lang.String |
Queryable.getUserForExecution(java.lang.Integer execId)
Get the user for a specific execution id.
|
java.lang.String |
DefaultQuery.getUserForExecution(KeplerLSID execLSID) |
java.lang.String |
Queryable.getUserForExecution(KeplerLSID execLSID)
Get the user for a specific execution LSID.
|
NamedObj |
DefaultQuery.getWorkflowForExecution(java.lang.Integer execId)
Get the workflow object for a execution id.
|
NamedObj |
Queryable.getWorkflowForExecution(java.lang.Integer execId)
Get the workflow object for a execution id.
|
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.
|
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.
|
java.util.List<WorkflowRun> |
DefaultQuery.getWorkflowRunsForUser(java.lang.String user)
Get workflow runs for a user.
|
java.util.List<WorkflowRun> |
Queryable.getWorkflowRunsForUser(java.lang.String user)
Get workflow runs for a user.
|
java.util.List<java.lang.String> |
DefaultQuery.getWorkflows() |
java.util.List<java.lang.String> |
Queryable.getWorkflows()
Get a list of workflow names.
|
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 |
RecordPlayer.play(java.lang.Integer execId)
Play a specific execution.
|
void |
RecordPlayer.play(java.lang.Integer execId,
CompositeActor workflow)
Play a specific execution for a workflow.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ProvQuery.disconnect()
Disconnect from the underlying provenance store.
|
java.util.List<java.lang.Integer> |
ProvQuery.getActorFiringForToken(int tokenId,
boolean read)
Get the firing id(s) of the actor(s) that read or wrote a token.
|
java.util.List<java.lang.Integer> |
ProvQuery.getActorFirings(int execId)
Get the actor firing ids for a workflow execution id.
|
java.lang.String |
ProvQuery.getActorName(int fireId)
Get the actor name for a firing id.
|
java.lang.Integer |
ProvQuery.getChannelForToken(int tokenId,
boolean read,
java.lang.Integer fireId)
Get the channel that a token was read or written on.
|
KeplerLSID |
ProvQuery.getExecutionLSIDForExecution(java.lang.Integer execId)
Get the execution LSID for a workflow execution id.
|
java.util.List<java.lang.Integer> |
ProvQuery.getExecutions()
Get execution ids.
|
java.lang.String |
ProvQuery.getInputRoleForTokenAndFireId(int tokenId,
int fireId)
Get the input role (port name) of a token.
|
java.lang.String |
ProvQuery.getMoMLForExecution(int execId)
Get the MoML for an execution.
|
java.lang.String |
ProvQuery.getOutputRoleToken(int tokenId)
Get the output role (port name) of a token.
|
java.util.Date |
ProvQuery.getTimestampForTokenWrite(java.lang.Integer tokenId)
Get the timestamp when a token was written.
|
java.util.Date[] |
ProvQuery.getTimestampsForActorFiring(int fireId)
Get the start and end timestamps of an actor firing.
|
java.util.Date[] |
ProvQuery.getTimestampsForExecution(int execId)
Get the start and stop timestampes for a workflow execution id.
|
java.util.Date[] |
ProvQuery.getTimestampsForTokenRead(java.lang.Integer tokenId)
Get the timestamp(s) when a token was read.
|
java.util.List<java.lang.Integer> |
ProvQuery.getTokensForExecution(int execId,
java.lang.Integer portId,
boolean last)
Get an sequence of tokens for an execution.
|
java.util.List<java.lang.Integer> |
ProvQuery.getTokensForFiring(int fireId,
boolean read)
Get tokens for a firing.
|
java.lang.String |
ProvQuery.getTokenType(int tokenId)
Get the type of a token.
|
java.lang.String |
ProvQuery.getTokenValue(int tokenId)
Get the value of a token.
|
| Constructor and Description |
|---|
ProvQuery(java.io.InputStream stream,
org.openprovenance.prov.interop.InteropFramework.ProvFormat format)
Create a new ProvQuery from an input stream using a specific
format.
|
ProvQuery(java.lang.String filename)
Create a new ProvQuery for a PROV serialization in the
specified file.
|
| Modifier and Type | Method and Description |
|---|---|
protected java.util.List<java.lang.Integer> |
SQLQueryV8._getChangesForTimespan(java.util.Date start,
java.util.Date end,
java.lang.String workflow,
java.lang.String host)
Get changes performed on a host within a timespan.
|
protected java.util.List<java.lang.Integer> |
SQLQueryV8._getChangesSince(java.util.Date timeStamp,
java.lang.String workflowName,
java.lang.String hostName)
Get changes performed since a specific time.
|
protected java.util.List<java.lang.String> |
SQLQueryV8._getDataMD5s()
Get all the data MD5 checksums.
|
protected java.util.List<java.lang.Integer> |
SQLQueryV8._getEntitiesForChange(int changeId)
Get the entities for a workflow change.
|
protected java.util.List<java.lang.Integer> |
SQLQueryV8._getExecutionsForTimespan(java.util.Date start,
java.util.Date end,
java.lang.String workflow,
java.lang.String host)
Get executions for a worfkflow run on a host within a timespan.
|
protected java.util.List<java.lang.Integer> |
SQLQueryV8._getExecutionsStartedSince(java.util.Date timeStamp,
boolean including,
java.lang.String workflowName,
java.lang.String hostName)
Get executions started since a specific time.
|
protected java.util.Date |
SQLQueryV8._getLastChangeTime(int workflowId,
java.lang.String hostName)
Get the last change time for a workflow.
|
protected java.util.Date |
SQLQueryV8._getLastChangeTime(java.lang.String workflowName,
java.lang.String hostName)
Get the last change time for a workflow.
|
protected java.util.Date |
SQLQueryV8._getLastExecutionStartTime(int workflowId,
java.lang.String hostName)
Get the last execution start time.
|
protected java.util.Date |
SQLQueryV8._getLastExecutionStartTime(java.lang.String workflowName,
java.lang.String hostName)
Get the last execution start time.
|
protected static java.util.Map<java.lang.String,java.lang.String> |
SQLQueryV8._getParameterNameValues(java.sql.PreparedStatement statement)
A convenience method that executes a query returning parameter name
value pairs.
|
protected int |
SQLQueryV8._getWorkflow(java.lang.String workflow)
Get the id for a workflow.
|
protected void |
SQLQueryV8._init()
Check the schema version and initialize the prepared statements.
|
void |
SQLQueryV8.disconnect()
Disconnect from provenance store.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getActorFiringForToken(int tokenId,
boolean read)
Get the firing id(s) of the actor(s) that read or wrote a token.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getActorFiringIds(java.lang.String actorName,
java.lang.Integer wfExecId)
Get actor fire ids based on its full name and workflow exec ID.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getActorFirings(int wfExecId)
Get all actor fire ids for a workflow exec ID.
|
java.lang.String |
SQLQueryV8.getActorName(int fireId)
Get an actor's name for a firing id.
|
java.lang.String |
SQLQueryV8.getActorType(int fireId)
Get an actor's type for a firing id.
|
java.util.List<byte[]> |
SQLQueryV8.getAssociatedDataForExecution(int execId,
java.util.Map<java.lang.String,java.lang.String> metadataMap,
boolean matchAny)
Get a file associated with an execution.
|
java.util.Map<java.lang.String,java.lang.String> |
SQLQueryV8.getAssociatedKeysValuesForExecution(int execId)
Get any associated keys-values for an execution.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getChangesForTimespan(java.util.Date start,
java.util.Date end)
Get changes within a timespan.
|
java.lang.Integer |
SQLQueryV8.getChannelForToken(int tokenId,
boolean read,
java.lang.Integer fireId)
Get the channel that a token was read or written on.
|
java.lang.Integer |
SQLQueryV8.getEntityId(java.lang.String entityName,
KeplerLSID lsid)
Get the id of entity.
|
java.lang.Integer |
SQLQueryV8.getEntityId(java.lang.String entityName,
java.lang.String workflowName)
Get the id of entity.
|
java.lang.String |
SQLQueryV8.getEntityType(java.lang.Integer entityId) |
java.lang.Integer |
SQLQueryV8.getEntityWorkflowId(java.lang.Integer entityId) |
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.lang.Integer |
SQLQueryV8.getExecutionForExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision)
Get execution id for an execution LSID without revision.
|
java.lang.Integer |
SQLQueryV8.getExecutionForOldestReferralExecutionLSIDWithoutRevision(java.lang.String execLSIDWithoutRevision)
Get execution id for execution that has the given LSID as its
oldest referral.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionIdsForTags(java.lang.String tagsSearchString)
Get a list of executions for workflow(s) with tags that contain tagsSearchString
(case insensitive)
|
KeplerLSID |
SQLQueryV8.getExecutionLSIDForExecution(java.lang.Integer execId)
Get the execution LSID for a specific execution id.
|
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<java.lang.Integer> |
SQLQueryV8.getExecutions()
Get a list of all executions.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForAnnotation(java.lang.String annotation)
Get a list of executions for a specific execution annotation.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForTimespan(java.util.Date start,
java.util.Date end)
Get executions within a timespan.
|
java.util.List<KeplerLSID> |
SQLQueryV8.getExecutionsForType(WorkflowRun.type type)
Get a list of executions corresponding to a specific type.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForWorkflow(java.lang.String workflow)
Get a list of executions for a specific workflow.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForWorkflowNameContains(java.lang.String text)
Get a list of executions for workflow(s) with names that contain text (case insensitive).
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForWorkflowRuns(java.lang.String workflowName,
java.lang.String userName)
Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForWorkflowRuns(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<java.lang.Integer> |
SQLQueryV8.getExecutionsForWorkflowRunsAfter(java.lang.String workflowName,
java.lang.String userName,
java.util.Date after)
Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria
after a date.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForWorkflowRunsAt(java.lang.String workflowName,
java.lang.String userName,
java.lang.String date)
Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria
"at" a date.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getExecutionsForWorkflowRunsBefore(java.lang.String workflowName,
java.lang.String userName,
java.util.Date before)
Get a list of executions for workflow(s) that match Workflow Run Manager (WRM) search criteria
before a date.
|
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.lang.String |
SQLQueryV8.getHostIdForExecution(java.lang.Integer execId)
Get the host id for a specific execution id.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getImmediateDependencies(int tokenId)
Get the immediate tokens that generated a token.
|
java.lang.String |
SQLQueryV8.getInputRoleForTokenAndFireId(int tokenId,
int fireId)
Get the input role (port name) of a token.
|
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.
|
java.lang.Integer |
SQLQueryV8.getLastExecutionForWorkflow(java.lang.String workflow)
Get the last execution for a workflow.
|
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.
|
java.lang.String |
SQLQueryV8.getMoMLForExecution(int execId)
Get workflow MoML for an execution, using execution id
|
java.lang.String |
SQLQueryV8.getMoMLForExecution(KeplerLSID lsid)
Get workflow MoML for an execution, using execution lsid.
|
java.lang.String |
SQLQueryV8.getOutputRoleToken(int tokenId)
Get the output role (port name) of a token.
|
java.util.Map<java.lang.String,java.lang.String> |
SQLQueryV8.getParameterAndPortParameterNameValuesForFiring(int fireId)
Get an actor's parameter and port parameter name value pairs for a firing id.
|
java.util.Map<java.lang.String,java.lang.String> |
SQLQueryV8.getParameterNameValuesForExecution(int execId)
Get the parameter name value pairs for an execution.
|
java.util.Map<java.lang.String,java.lang.String> |
SQLQueryV8.getParameterNameValuesForFiring(int fireId)
Get an actor's parameter name value pairs for a firing id.
|
java.util.Map<java.lang.String,java.lang.String> |
SQLQueryV8.getParameterNameValuesOfSpecificTypeForExecution(int execId)
Get the parameter name value pairs for an execution, whose parameter type is
either '.Parameter' or '.StringParameter'
|
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.
|
Queryable |
SQLRecordingV8.getQueryable(boolean allowReconnectWF)
Get a Queryable connected to the Recording output.
|
java.util.List<java.lang.String> |
SQLQueryV8.getSavedFilenames()
Get a list of files saved in the database.
|
java.util.Map<NamedOntClass,java.lang.String> |
SQLQueryV8.getTagClassesForExecutionId(int execId) |
java.util.List<java.lang.String> |
SQLQueryV8.getTagsForExecutionId(int execId) |
java.util.List<java.lang.String> |
SQLQueryV8.getTagURNsForExecutionLSID(KeplerLSID execLSID) |
java.util.Date |
SQLQueryV8.getTimestampForTokenWrite(java.lang.Integer tokenId)
Get the timestamp when a token was written.
|
java.util.Date[] |
SQLQueryV8.getTimestampsForActorFiring(int fireId)
Get the start and end timestamps of an actor firing.
|
java.util.Date[] |
SQLQueryV8.getTimestampsForExecution(int execId)
Get the start and end timestamps of an execution.
|
java.util.Date[] |
SQLQueryV8.getTimestampsForTokenRead(java.lang.Integer tokenId)
Get the timestamp(s) when a token was read.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getTokensForExecution(int execId,
java.lang.Integer portId,
boolean last)
Get an sequence of tokens for an execution.
|
java.util.List<java.lang.Integer> |
SQLQueryV8.getTokensForFiring(int fireId,
boolean read)
Get tokens for a firing.
|
java.lang.String |
SQLQueryV8.getTokenType(int tokenId)
Get the type of a token.
|
java.lang.String |
SQLQueryV8.getTokenValue(int tokenId)
Get the value of a token.
|
java.lang.String |
SQLQueryV8.getUserForExecution(java.lang.Integer execId)
Get the user for a specific execution id.
|
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.
|
java.util.Map<KeplerLSID,WorkflowRun> |
SQLQueryV8.getWorkflowRunsForExecutionLSIDs(java.util.List<KeplerLSID> executionLSIDs)
Get WorkflowRuns for a list of execution LSIDs
|
java.util.List<WorkflowRun> |
SQLQueryV8.getWorkflowRunsForUser(java.lang.String user) |
java.util.List<java.lang.String> |
SQLQueryV8.getWorkflows()
Get a list of workflow names.
|
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.
|
| Constructor and Description |
|---|
SQLQueryV8(DatabaseType dbType)
Construct a new SQLQueryV8 from a connected DatabaseType.
|
SQLQueryV8(java.util.Map<java.lang.String,java.lang.String> parameters)
Construct a new SQLQueryV8 and connect to a database.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WorkflowRunManager.disconnect() |