public class IntermediateProvenance extends AbstractDispatchLayer<String>
Invoke
layer and collects information about the
current workflow run to be stored by the ProvenanceConnector
.Modifier and Type | Field and Description |
---|---|
static String |
URI |
CLEANUP_DELAY_MS, cleanupTimer, dispatchStack
Constructor and Description |
---|
IntermediateProvenance() |
Modifier and Type | Method and Description |
---|---|
void |
configure(String o)
When the item is built from the workflow definition XML the object is
first constructed with a default constructor then this method is called,
passing in the configuration bean returned by getConfiguration().
|
static Object |
DeserializeParam(String SerializedParam) |
void |
finishedWith(String owningProcess)
A set of provenance events for a particular owning process has been
finished with so you can remove all the
IterationProvenanceItem s
from the map |
String |
getConfiguration()
Each item stores configuration within a bean of type ConfigurationType,
this method returns the configuration.
|
protected Map<String,IterationProvenanceItem> |
getIndexesByProcess(String owningProcess) |
protected IterationProvenanceItem |
getIterationProvItem(Event<?> event) |
ProvenanceReporter |
getReporter() |
void |
receiveError(DispatchErrorEvent errorEvent)
Create an
ErrorProvenanceItem and send across to the
ProvenanceConnector |
void |
receiveJob(DispatchJobEvent jobEvent)
Create the
ProvenanceItem s and send them all across to the
ProvenanceConnector except for the
IterationProvenanceItem , this one is told what it's inputs are
but has to wait until the results are received before being sent across. |
void |
receiveJobQueue(DispatchJobQueueEvent jobQueueEvent)
Receive a pointer to the job queue along with a set of activities, this
is received from the layer above in the dispatch stack or from the
DispatchStackImpl object itself if this is the top layer.
|
void |
receiveResult(DispatchResultEvent resultEvent)
Populate an
OutputDataProvenanceItem with the results and attach
it to the appropriate IterationProvenanceItem . |
void |
receiveResultCompletion(DispatchCompletionEvent completionEvent)
Receive a (possibly partial) completion event from the layer below.
|
static String |
SerializeParam(Object ParamValue) |
void |
setReporter(ProvenanceReporter connector)
Tell this layer what
ProvenanceConnector implementation is being
used to capture the ProvenanceItem s. |
void |
setWorkflow(WorkflowProvenanceItem workflowItem)
So that the
ProvenanceItem s know which Dataflow has been
enacted this layer has to know about the WorkflowProvenanceItem |
getAbove, getBelow, getProcessor, setDispatchStack
public static final String URI
public void configure(String o)
Configurable
public void finishedWith(String owningProcess)
IterationProvenanceItem
s
from the mapfinishedWith
in interface DispatchLayer<String>
finishedWith
in class AbstractDispatchLayer<String>
public String getConfiguration()
Configurable
protected Map<String,IterationProvenanceItem> getIndexesByProcess(String owningProcess)
protected IterationProvenanceItem getIterationProvItem(Event<?> event)
public void receiveError(DispatchErrorEvent errorEvent)
ErrorProvenanceItem
and send across to the
ProvenanceConnector
receiveError
in interface DispatchLayer<String>
receiveError
in class AbstractDispatchLayer<String>
public void receiveJob(DispatchJobEvent jobEvent)
ProvenanceItem
s and send them all across to the
ProvenanceConnector
except for the
IterationProvenanceItem
, this one is told what it's inputs are
but has to wait until the results are received before being sent across.
Each item has a unique identifier and also knows who its parent item isreceiveJob
in interface DispatchLayer<String>
receiveJob
in class AbstractDispatchLayer<String>
public void receiveJobQueue(DispatchJobQueueEvent jobQueueEvent)
DispatchLayer
receiveJobQueue
in interface DispatchLayer<String>
receiveJobQueue
in class AbstractDispatchLayer<String>
public void receiveResult(DispatchResultEvent resultEvent)
OutputDataProvenanceItem
with the results and attach
it to the appropriate IterationProvenanceItem
. Then send the
IterationProvenanceItem
across to the ProvenanceConnector
receiveResult
in interface DispatchLayer<String>
receiveResult
in class AbstractDispatchLayer<String>
public void receiveResultCompletion(DispatchCompletionEvent completionEvent)
DispatchLayer
receiveResultCompletion
in interface DispatchLayer<String>
receiveResultCompletion
in class AbstractDispatchLayer<String>
public void setReporter(ProvenanceReporter connector)
ProvenanceConnector
implementation is being
used to capture the ProvenanceItem
s. NOTE: should probably use
the connector from the result events context where possibleconnector
- public ProvenanceReporter getReporter()
public void setWorkflow(WorkflowProvenanceItem workflowItem)
ProvenanceItem
s know which Dataflow
has been
enacted this layer has to know about the WorkflowProvenanceItem
workflowItem
- Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.