org.kepler.provenance.prov

Class ProvRecording

java.lang.Object

org.kepler.provenance.Recording

org.kepler.provenance.SimpleFiringRecording<org.openprovenance.prov.model.Activity>

org.kepler.provenance.prov.ProvRecording

public class ProvRecording
extends SimpleFiringRecording<org.openprovenance.prov.model.Activity>

A Recording for PROV output.

Author:

Daniel Crawl

Field Summary

Fields inherited from class org.kepler.provenance.SimpleFiringRecording

_fireStateTable

Fields inherited from class org.kepler.provenance.Recording

_containerFullName, _containerLSID, _containerName, _debugPrint, _debugWriter, _machineStr, _recorder, _recorderContainer, _stateSerializer

Constructor Summary

Constructors

Constructor and Description
ProvRecording() Construct a new ProvRecording.

Method Summary

Modifier and Type	Method and Description
protected void	_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	actorFire(FiringEvent event, java.util.Date timestamp) Record an actor firing.
void	attributeChanged(Attribute attribute) React to a parameter change.
void	executionStart(KeplerLSID executionLSID, java.util.Date timestamp) Record the starting of workflow execution at a specific time.
void	executionStop(KeplerLSID executionLSID, java.util.Date timestamp) Record the stopping of workflow execution.
RecordingParameters	generateParameters(NamedObj no) Add Parameters for ProvenanceListener.
void	portEvent(IOPortEvent event, java.util.Date timestamp) Record a port event.
boolean	regPort(TypedIOPort port) Register a port or portparameter.
void	setOutput(java.io.OutputStream stream) Set the output.
void	setOutputType(org.openprovenance.prov.interop.InteropFramework.ProvFormat type) Set the output type.

Methods inherited from class org.kepler.provenance.SimpleFiringRecording

regActor, regContents, specificationStart

Methods inherited from class org.kepler.provenance.Recording

_debug, _debug, _debugWrite, _debugWrite, _error, _getExceptionMessage, _getNameableFullName, _needWorkflowContents, _updateContainerName, _warn, actorFire, addFileForLastExecution, changeExecutionLSID, customProvEvent, disconnect, evolutionStart, evolutionStop, executionError, executionError, executionImported, executionImported, executionStart, executionStart, executionStart, executionStop, executionStop, executionStop, getContainer, getQueryable, portEvent, refillPortEvent, regDirector, regLink, regParameter, regRelation, remove, removeLink, removeStateSerializer, rename, renamedWorkflow, setContainer, setContainerLSID, setContainerName, setDebugWriter, setStateSerializer, specificationStop, tagAdded, tagRemoved

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProvRecording

public ProvRecording()
              throws RecordingException

Construct a new ProvRecording.

Throws:

RecordingException

Method Detail

attributeChanged

public void attributeChanged(Attribute attribute)
                      throws IllegalActionException

React to a parameter change.

Overrides:

attributeChanged in class Recording

Throws:

IllegalActionException

regPort

public boolean regPort(TypedIOPort port)
                throws RecordingException

Register a port or portparameter.

Overrides:

regPort in class Recording

Returns:

if true, register contents of port.

Throws:

RecordingException

executionStart

public void executionStart(KeplerLSID executionLSID,
                           java.util.Date timestamp)
                    throws RecordingException

Description copied from class: Recording

Record the starting of workflow execution at a specific time.

Overrides:

executionStart in class Recording

Throws:

RecordingException

executionStop

public void executionStop(KeplerLSID executionLSID,
                          java.util.Date timestamp)
                   throws RecordingException

Record the stopping of workflow execution.

Overrides:

executionStop in class Recording

Throws:

RecordingException

actorFire

public void actorFire(FiringEvent event,
                      java.util.Date timestamp)
               throws RecordingException

Record an actor firing.

Overrides:

actorFire in class Recording

Throws:

RecordingException

portEvent

public void portEvent(IOPortEvent event,
                      java.util.Date timestamp)
               throws RecordingException

Record a port event.

Overrides:

portEvent in class Recording

Throws:

RecordingException

generateParameters

public RecordingParameters generateParameters(NamedObj no)
                                       throws IllegalActionException,
                                              NameDuplicationException

Add Parameters for ProvenanceListener.

Overrides:

generateParameters in class Recording

Throws:

IllegalActionException

NameDuplicationException

setOutput

public void setOutput(java.io.OutputStream stream)

Set the output. The stream is written and closed after the workflow execution stops.

setOutputType

public void setOutputType(org.openprovenance.prov.interop.InteropFramework.ProvFormat type)

Set the output type.

_recordPortEvent

protected void _recordPortEvent(IOPort port,
                                org.openprovenance.prov.model.Activity activity,
                                boolean isRead,
                                int channel,
                                Token token,
                                java.util.Date timestamp)
                         throws RecordingException

Record a port read or write.

Throws:

RecordingException