net.sf.taverna.t2.provenance.lineageservice
Class WorkflowDataProcessor

java.lang.Object
  net.sf.taverna.t2.provenance.lineageservice.WorkflowDataProcessor

public class WorkflowDataProcessor
extends java.lang.Object

Author:

paolo this class manages the outputs from a workflow, as they come along through WorkflowData events

Constructor Summary

WorkflowDataProcessor()

Method Summary

void	addWorkflowDataItem(net.sf.taverna.t2.provenance.item.ProvenanceItem provenanceItem) adds the input ProvenanceItem event to the tree structure corresponding to the varname found in the item.
ProvenanceQuery	getPq()
ProvenanceWriter	getPw()
void	processTrees(java.lang.String dataflowID, java.lang.String wfInstanceRef) writes records to VarBinding or Collection by traversing the trees expect this to be invoked after workflow completion
void	setPq(ProvenanceQuery pq)
void	setPw(ProvenanceWriter pw)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkflowDataProcessor

public WorkflowDataProcessor()

Method Detail

addWorkflowDataItem

public void addWorkflowDataItem(net.sf.taverna.t2.provenance.item.ProvenanceItem provenanceItem)

adds the input ProvenanceItem event to the tree structure corresponding to the varname found in the item. Repeated invocations of this method incrementally reconstruct the tree structure for each of the workflow outputs

Parameters:

root -

processTrees

public void processTrees(java.lang.String dataflowID,
                         java.lang.String wfInstanceRef)

writes records to VarBinding or Collection by traversing the trees
expect this to be invoked after workflow completion

Parameters:

wfInstanceRef - the runID

dataflowID - the external name of the dataflow (not the UUID)

getPq

public ProvenanceQuery getPq()

Returns:

the pq

setPq

public void setPq(ProvenanceQuery pq)

Parameters:

pq - the pq to set

getPw

public ProvenanceWriter getPw()

Returns:

the pw

setPw

public void setPw(ProvenanceWriter pw)

Parameters:

pw - the pw to set