Modifier and Type | Method and Description |
---|---|
void |
ExecutionMonitorPanel.ExecutionMonitorRecording.actorFire(FiringEvent event,
java.util.Date timestamp)
Record an actor firing.
|
void |
ExecutionMonitorPanel.ExecutionMonitorRecording.executionError(Nameable source,
java.lang.Throwable throwable)
The workflow had an error.
|
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.
|
void |
ExecutionMonitorPanel.ExecutionMonitorRecording.portEvent(IOPortEvent event,
java.util.Date timestamp)
Record a port event.
|
void |
ExecutionMonitorPanel.ExecutionMonitorRecording.specificationStart()
Clear data structures before starting.
|
Constructor and Description |
---|
ExecutionMonitorRecording() |
Modifier and Type | Method and Description |
---|---|
protected void |
Recording._debugWrite(java.lang.String str)
Write to any debug writer.
|
protected void |
Recording._debugWrite(java.lang.String str,
java.lang.Throwable t)
Write to any debug writer.
|
protected void |
TextFileRecording._write(java.lang.String str)
Output a string.
|
protected void |
TextFileRecording._write(java.lang.String str,
boolean outputDebug)
Output a string.
|
protected void |
TextFileRecording._writeOutput(java.lang.String str)
Output a string, optionally adding a timestamp.
|
protected void |
TextFileRecording._writeOutput(java.lang.String str,
boolean outputDebug)
Output a string, optionally adding a timestamp.
|
protected void |
TextFileRecording._writeOutput(java.lang.String str,
boolean outputDebug,
java.util.Date timestamp)
Output a string, optionally adding a timestamp.
|
protected void |
TextFileRecording._writeOutput(java.lang.String str,
java.util.Date timestamp)
Output a string, optionally adding a timestamp.
|
void |
Recording.actorFire(FiringEvent event)
Record an actor firing at the current time.
|
void |
XMLRecording.actorFire(FiringEvent event)
Deprecated.
Record starting an actor fire event.
|
void |
Recording.actorFire(FiringEvent event,
java.util.Date timestamp)
Record an actor firing at a specific time.
|
void |
TextFileRecording.actorFire(FiringEvent event,
java.util.Date timestamp)
Record starting an actor fire event.
|
void |
Recording.addFileForLastExecution(java.util.Map<java.lang.String,java.lang.String> metadataMap,
java.io.File file)
Associate the contents of a file with the most recent workflow execution.
|
boolean |
Recording.changeExecutionLSID(int execId,
KeplerLSID newExecLSID,
Queryable q)
Change execution LSID for an execution Id.
|
void |
PortConnector.createConnections(IOPort port)
Create connections for a port.
|
void |
Recording.customProvEvent(ProvenanceEvent event)
Record a custom provenance event.
|
void |
TextFileRecording.customProvEvent(ProvenanceEvent event)
Record a custom provenance event.
|
void |
Recording.disconnect()
Stop recording.
|
void |
TextFileRecording.disconnect()
Stop recording.
|
void |
Recording.evolutionStart()
Start an evolution.
|
void |
TextFileRecording.evolutionStart() |
void |
Recording.evolutionStop()
Stop an evolution.
|
void |
TextFileRecording.evolutionStop() |
void |
Recording.executionError(Nameable source,
java.lang.Throwable throwable)
An actor threw an exception.
|
void |
TextFileRecording.executionError(Nameable source,
java.lang.Throwable throwable)
An actor threw an exception.
|
void |
Recording.executionError(Nameable source,
java.lang.Throwable throwable,
KeplerLSID executionLSID)
An actor threw an exception.
|
void |
Recording.executionStart()
Record the starting of workflow execution.
|
void |
TextFileRecording.executionStart()
Record the starting of workflow execution.
|
void |
Recording.executionStart(java.util.Date timestamp)
Record the starting of workflow execution at a specific time.
|
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()
Record the stopping of workflow execution.
|
void |
TextFileRecording.executionStop()
Record the stopping of workflow execution.
|
void |
XMLRecording.executionStop()
Deprecated.
Record the stopping of workflow execution.
|
void |
Recording.executionStop(java.util.Date timestamp)
Record the stopping 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.
|
static Queryable |
ProvenanceRecorder.getDefaultQueryable(NamedObj namedObj)
Get a queryable from the default provenance recorder for a NamedObj.
|
Id |
PortConnector.getNextId(IOPort port,
int channel)
Get the next Id for an input port and channel.
|
FiringEvent.FiringEventType |
FireState.getNextStopFiringType()
Get the expected firing type for stopping the firing iteration.
|
Queryable |
Recording.getQueryable(boolean allowReconnectWF)
Get a Queryable connected to the Recording output.
|
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.
|
void |
Recording.portEvent(IOPortEvent event)
Record a port event at the current time.
|
void |
XMLRecording.portEvent(IOPortEvent event)
Deprecated.
Record a port event.
|
void |
Recording.portEvent(IOPortEvent event,
java.util.Date timestamp)
Record a port event at a specific time.
|
void |
TextFileRecording.portEvent(IOPortEvent event,
java.util.Date timestamp)
Record a port event.
|
void |
PortConnector.receiveId(IOPort receiverPort,
int channel,
Id pass)
A port should receive an id on a specific channel.
|
void |
PortConnector.refillId(IOPort port,
int channel)
Restore the previous Id to a port and channel.
|
void |
Recording.refillPortEvent(IOPortRefillEvent event)
Record a port event.
|
boolean |
Recording.regActor(Actor actor)
Register an actor.
|
boolean |
TextFileRecording.regActor(Actor actor)
Register an actor.
|
boolean |
XMLRecording.regActor(Actor actor)
Deprecated.
|
boolean |
SimpleFiringRecording.regActor(Actor actor)
Register an actor.
|
boolean |
Recording.regContents()
Returns true if provenance recorder should register workflow
contents should be registered.
|
boolean |
Recording.regDirector(Director director)
Register a director.
|
boolean |
TextFileRecording.regDirector(Director director)
Register a director.
|
boolean |
XMLRecording.regDirector(Director director)
Deprecated.
|
boolean |
Recording.regLink(NamedObj endPoint1,
NamedObj endPoint2)
Register a link between two endpoints.
|
boolean |
TextFileRecording.regLink(NamedObj endPoint1,
NamedObj endPoint2)
Register a link between two endpoints.
|
boolean |
XMLRecording.regLink(NamedObj endPoint1,
NamedObj endPoint2)
Deprecated.
Register a link between two endpoints.
|
boolean |
Recording.regParameter(NamedObj parameter)
Register a parameter.
|
boolean |
TextFileRecording.regParameter(NamedObj parameter)
Register a parameter.
|
boolean |
XMLRecording.regParameter(NamedObj parameter)
Deprecated.
|
boolean |
Recording.regPort(TypedIOPort port)
Register a port or portparameter.
|
boolean |
TextFileRecording.regPort(TypedIOPort port)
Register a port or portparameter.
|
boolean |
XMLRecording.regPort(TypedIOPort port)
Deprecated.
Register a port or portparameter.
|
boolean |
Recording.regRelation(IORelation relation)
Register a relation.
|
boolean |
TextFileRecording.regRelation(IORelation relation)
Register a relation.
|
boolean |
XMLRecording.regRelation(IORelation relation)
Deprecated.
Register a relation.
|
void |
Recording.remove(java.lang.String name)
A NamedObj was removed.
|
void |
TextFileRecording.remove(java.lang.String name) |
void |
Recording.removeLink(java.lang.String endPoint1,
java.lang.String endPoint2)
Remove a link between two endpoints.
|
void |
TextFileRecording.removeLink(java.lang.String endPoint1,
java.lang.String endPoint2) |
void |
Recording.rename(java.lang.String oldName,
java.lang.String newName)
A NamedObj was renamed.
|
void |
TextFileRecording.rename(java.lang.String oldName,
java.lang.String newName)
A NamedObj was renamed.
|
void |
Recording.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
A workflow was renamed.
|
void |
PortConnector.sendIdToConnections(IOPort senderPort,
int channel,
Id pass)
Send an Id to an output port's connections on a channel.
|
void |
Recording.specificationStart()
Called before registering workflow contents.
|
void |
TextFileRecording.specificationStart()
Called before registering workflow contents.
|
void |
SimpleFiringRecording.specificationStart()
Called before registering workflow contents.
|
void |
Recording.specificationStop()
Called when finished registering workflow contents.
|
void |
TextFileRecording.specificationStop()
Called when finished registering workflow contents.
|
void |
Recording.tagAdded(TagEvent event) |
void |
TextFileRecording.tagAdded(TagEvent event)
A tag was added.
|
void |
Recording.tagRemoved(TagEvent event) |
void |
TextFileRecording.tagRemoved(TagEvent event)
A tag was removed.
|
Constructor and Description |
---|
Recording()
Create a new provenance recording.
|
SimpleFiringRecording() |
TextFileRecording()
Create a new provenance recording.
|
XMLRecording()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
OpenProvenanceModelXML._recordPortEvent(IOPort port,
org.openprovenance.model.ProcessId processId,
boolean isRead,
int channel,
Token token)
Deprecated.
Record a port read or write.
|
void |
OpenProvenanceModelXML.actorFire(FiringEvent event)
Deprecated.
Record an actor firing.
|
void |
OpenProvenanceModelXML.executionStart()
Deprecated.
Record the starting of workflow execution.
|
void |
OpenProvenanceModelXML.executionStop()
Deprecated.
Record the stopping of workflow execution.
|
void |
OpenProvenanceModelXML.portEvent(IOPortEvent event)
Deprecated.
Record a port event.
|
boolean |
OpenProvenanceModelXML.regActor(Actor actor)
Deprecated.
Register an actor.
|
boolean |
OpenProvenanceModelXML.regPort(TypedIOPort port)
Deprecated.
Register a port or portparameter.
|
Constructor and Description |
---|
OpenProvenanceModelXML()
Deprecated.
Construct a new OpenProvenanceModelXML.
|
Modifier and Type | Method and Description |
---|---|
protected void |
ProvRecording._recordPortEvent(IOPort port,
org.openprovenance.prov.model.Activity activity,
boolean isRead,
int channel,
Token token,
java.util.Date timestamp)
Record a port read or write.
|
void |
ProvRecording.actorFire(FiringEvent event,
java.util.Date timestamp)
Record an actor firing.
|
void |
ProvRecording.executionStart(KeplerLSID executionLSID,
java.util.Date timestamp) |
void |
ProvRecording.executionStop(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the stopping of workflow execution.
|
void |
ProvRecording.portEvent(IOPortEvent event,
java.util.Date timestamp)
Record a port event.
|
boolean |
ProvRecording.regPort(TypedIOPort port)
Register a port or portparameter.
|
static void |
ProvUtilities.writeProv(java.io.OutputStream stream,
org.openprovenance.prov.interop.InteropFramework.ProvFormat format,
java.lang.Integer execId)
Write PROV to an output stream.
|
static void |
ProvUtilities.writeProv(java.io.OutputStream stream,
java.lang.String formatStr,
java.lang.Integer execId)
Write PROV to an output stream.
|
static void |
ProvUtilities.writeProv(java.lang.String fileName,
org.openprovenance.prov.interop.InteropFramework.ProvFormat format,
java.lang.Integer execId)
Write PROV to a file.
|
static void |
ProvUtilities.writeProv(java.lang.String fileName,
java.lang.String formatStr,
java.lang.Integer execId)
Write PROV to a file.
|
Constructor and Description |
---|
ProvRecording()
Construct a new ProvRecording.
|
Modifier and Type | Method and Description |
---|---|
protected org.kepler.provenance.sql.RegEntity |
SQLRecordingV7._addEntity(int containerId,
RegEntity.EntityType type,
java.lang.String fullName,
java.lang.String displayName,
int prevId)
Add a new row to the entity table.
|
protected org.kepler.provenance.sql.RegEntity |
SQLRecording._addEntity(int containerId,
RegEntity.EntityType type,
java.lang.String fullName,
java.lang.String displayName,
int prevId)
Add a new row to the entity table.
|
protected org.kepler.provenance.sql.RegEntity |
SQLRecordingV8._addEntity(int containerId,
RegEntity.EntityType type,
java.lang.String fullName,
java.lang.String displayName,
int prevId)
Add a new row to the entity table.
|
protected void |
SQLRecordingV7._addWorkflow()
Add a new row to the workflow table.
|
protected void |
SQLRecording._addWorkflow()
Add a new row to the workflow table.
|
protected void |
SQLRecordingV8._addWorkflow()
Add a new row to the workflow table.
|
protected void |
SQLRecordingV7._addWorkflowChange()
Create a new row in the workflow_change table.
|
protected void |
SQLRecordingV8._addWorkflowChange()
Create a new row in the workflow_change table.
|
protected void |
SQLRecordingV8._changeWorkflowNameColumn(java.lang.String newName)
Change the workflow.name column for the current workflow.
|
protected void |
SQLRecordingV8._changeWorkflowNameColumn(java.lang.String newName,
KeplerLSID lsid)
Change the workflow.name column for a specific LSID.
|
protected void |
SQLRecording._checkConnection(boolean allowReconnectWF)
This method opens the database connection if necessary.
|
protected java.lang.String |
SQLRecordingV8._checkData(byte[] data)
Adds data to the data table if not already there.
|
protected java.lang.String |
SQLRecordingV8._checkData(java.io.File file)
Adds data to the data table if not already there.
|
protected org.kepler.provenance.sql.RegEntity |
SQLRecording._checkEntity(Nameable namedObj,
RegEntity.EntityType type)
Check if a NamedObj has been inserted into the entity table.
|
protected java.lang.String |
SQLRecordingV8._checkForFileData(Token token)
See if a token contains a valid filename.
|
protected void |
SQLRecording._checkParameters()
Check parameters before (re)connecting to database or workflow.
|
protected void |
SQLRecording._checkWorkflowName()
Check validity of workflow name parameter.
|
protected void |
SQLRecordingV8._checkWorkflowName()
Check validity of workflow name parameter.
|
protected void |
SQLRecording._dbReset()
Reset when we use a different db connection.
|
protected void |
SQLRecordingV8._dbReset()
Reset when we use a different db connection.
|
protected void |
SQLRecordingV7._errorReset()
Reset when we encounter an error.
|
protected void |
SQLRecording._errorReset()
Reset when we encounter an error.
|
protected int |
SQLRecording._getContainerId(Nameable namedObj)
Find the container id of an entity.
|
protected int |
SQLRecordingV8._getContainerId(Nameable namedObj)
Find the container id of an entity.
|
protected int |
SQLRecording._getWorkflowId()
Get the internal workflow id.
|
protected int |
SQLRecordingV8._getWorkflowId()
Get the internal workflow id.
|
protected int |
SQLRecording._getWorkflowId(java.lang.String idStr)
Get the internal workflow id given a id string.
|
protected void |
SQLRecordingV7._possibleWorkflowChangeStart()
A workflow change may be starting.
|
protected void |
SQLRecordingV7._possibleWorkflowChangeStop()
A possible workflow change is stopping.
|
protected void |
SQLRecording._reconnectDatabase(boolean resetDB)
Reconnect to the database.
|
protected void |
SQLRecordingV8._reconnectDatabase(boolean resetDB)
Reconnect to the database.
|
protected void |
SQLRecording._reconnectWorkflow()
Re-acquire the current workflow id.
|
protected void |
SQLRecordingV8._reconnectWorkflow()
Re-acquire the current workflow id.
|
protected void |
SQLRecording._recordFiringEvent(Actor actor,
FiringEvent.FiringEventType type,
java.util.Date timestamp)
Record a specific type of firing for an actor.
|
protected void |
SQLRecordingV8._recordFiringEvent(Actor actor,
FiringEvent.FiringEventType type,
java.util.Date timestamp)
Record a specific type of firing for an actor.
|
protected void |
SQLRecording._recordPortEvent(IOPort port,
int fireId,
int rwfireId,
boolean isRead,
int channel,
Token token,
IOPort destPort,
java.util.Date timestamp)
Record a port read or write to the token_flow table.
|
protected void |
SQLRecordingV8._recordPortEvent(IOPort port,
int fireId,
int rwfireId,
boolean isRead,
int channel,
Token token,
IOPort destPort,
java.util.Date timestamp)
Record a specific type of firing for an actor.
|
protected int |
SQLRecording._regActorDirector(NamedObj namedObj,
boolean actor)
Convenience routine that regActor and regDirector can use since
the schema for actors and directors only differs by "actor" vs
"director".
|
protected void |
SQLRecording._regParameterReal(NamedObj parameter,
org.kepler.provenance.sql.RegEntity re)
Add an entity to the parameter table.
|
protected void |
SQLRecording._regPortReal(TypedIOPort port,
org.kepler.provenance.sql.RegEntity re)
Add a port to the port table.
|
protected void |
SQLRecordingV8._regPortReal(TypedIOPort port,
org.kepler.provenance.sql.RegEntity re)
Add a port to the port table.
|
protected void |
SQLRecordingV8._updateParameterExecTable()
Add all the parameter ids to the parameter_exec table.
|
protected int |
SQLRecording._updateWorkflowID(boolean isNew)
Update workflow ID either by retrieving the id from an existing
workflow in the database or creating a new one.
|
void |
SQLRecording.actorFire(FiringEvent event,
java.util.Date timestamp)
Record an actor fire event.
|
void |
SQLRecordingV8.addFileForExecution(java.util.Map<java.lang.String,java.lang.String> metadataMap,
java.io.File file,
int execId)
Associate the contents of a file with the most recent workflow execution.
|
void |
SQLRecordingV8.addFileForLastExecution(java.util.Map<java.lang.String,java.lang.String> metadataMap,
java.io.File file)
Associate the contents of a file with the most recent workflow execution.
|
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.customProvEvent(ProvenanceEvent event)
Record a custom provenance event.
|
int |
SQLRecordingV8.deleteExecutions(java.util.List<KeplerLSID> lsidList)
Delete executions given a list of execution LSIDs.
|
int |
SQLRecordingV8.deleteWorkflowsWithNoExecutions()
Delete workflows from the database that have no executions.
|
void |
SQLRecording.disconnect()
Stop recording.
|
void |
SQLRecordingV7.evolutionStart()
Start an evolution.
|
void |
SQLRecordingV7.evolutionStop()
Stop an evolution.
|
void |
SQLRecordingV8.executionError(Nameable source,
java.lang.Throwable throwable,
KeplerLSID executionLSID)
An actor threw an exception.
|
void |
SQLRecording.executionStart(java.util.Date timestamp)
Record the starting of workflow execution.
|
void |
SQLRecordingV8.executionStart(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the starting of workflow execution.
|
void |
SQLRecording.executionStop(java.util.Date timestamp)
Record the stopping of workflow execution.
|
void |
SQLRecordingV8.executionStop(KeplerLSID executionLSID,
java.util.Date timestamp)
Record the stopping of workflow execution.
|
Queryable |
SQLRecordingV8.getQueryable(boolean allowReconnectWF)
Get a Queryable connected to the Recording output.
|
boolean |
SQLRecordingV8.insertHuskRun(KARFile karFile,
WorkflowRun run)
If run's exec LSID does not already exist in provenance, insert WorkflowRun
into provenance.
|
boolean |
SQLRecordingV8.insertPreviewRun(WorkflowRun run)
If run's exec LSID does not already exist in provenance, insert WorkflowRun
into provenance.
|
void |
SQLRecordingV8.insertTag(java.lang.String type,
java.lang.String tagStr,
java.lang.String urnStr,
int execId)
Insert a new row into the tag table.
|
void |
SQLRecording.portEvent(IOPortEvent event,
java.util.Date timestamp)
Record a port event.
|
void |
SQLRecordingV8.refillPortEvent(IOPortRefillEvent event)
Record a port refill event.
|
boolean |
SQLRecording.regActor(Actor actor)
Register an actor.
|
boolean |
SQLRecordingV8.regContents()
Returns true if workflow contents should be registered.
|
boolean |
SQLRecording.regDirector(Director director)
Register a director.
|
boolean |
SQLRecording.regLink(NamedObj endPoint1,
NamedObj endPoint2)
Register a link between two endpoints.
|
boolean |
SQLRecordingV8.regLink(NamedObj endPoint1,
NamedObj endPoint2)
Register a link between two endpoints.
|
boolean |
SQLRecordingV7.regParameter(NamedObj parameter)
Register a parameter.
|
boolean |
SQLRecording.regParameter(NamedObj parameter)
Register a parameter.
|
boolean |
SQLRecordingV8.regParameter(NamedObj parameter)
Register a parameter.
|
boolean |
SQLRecording.regPort(TypedIOPort port)
Register a port or portparameter.
|
boolean |
SQLRecordingV8.regPort(TypedIOPort port)
Register a port or portparameter.
|
boolean |
SQLRecording.regRelation(IORelation relation)
Register a relation.
|
boolean |
SQLRecordingV8.regRelation(IORelation relation)
Register a relation.
|
void |
SQLRecordingV8.renamedWorkflow(NamedObj namedObj,
KeplerLSID oldLSID,
KeplerLSID newLSID,
java.lang.String oldName,
java.lang.String newName)
A workflow was renamed.
|
void |
SQLRecordingV7.specificationStart()
Called before registering workflow contents.
|
void |
SQLRecording.specificationStart()
Called before registering workflow contents.
|
void |
SQLRecordingV7.specificationStop()
Called when finished registering workflow contents.
|
void |
SQLRecordingV8.tagAdded(TagEvent event)
A tag was added, insert it
|
void |
SQLRecordingV8.tagRemoved(TagEvent event)
A tag was removed.
|
Constructor and Description |
---|
SQLRecording()
Construct a new SQLRecording.
|
SQLRecordingV7() |
SQLRecordingV8() |
Modifier and Type | Method and Description |
---|---|
void |
WebViewRecording.actorFire(FiringEvent event,
java.util.Date timestamp) |
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.
|
Constructor and Description |
---|
WebViewRecording() |
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.
|
void |
WorkflowRunManagerRecording.executionError(Nameable source,
java.lang.Throwable throwable,
KeplerLSID execLSID)
update WRM table after an execution gives an error.
|
void |
WorkflowRunManagerRecording.tagAdded(TagEvent event)
update WRM table after a run tag has been added.
|
void |
WorkflowRunManagerRecording.tagRemoved(TagEvent event)
update WRM table after a run tag has been removed.
|
Constructor and Description |
---|
WorkflowRunManagerRecording(WorkflowRunManager manager)
Construct a new WorkflowRunManagerRecording.
|