public class IterativeWorkflowProcessorThread extends Object implements WorkflowStatus, CoreMetKeys, Runnable
WorkflowProcessorThread
that processes through an
iterative WorkflowInstance
. This class keeps an Iterator
that allows it to move from one end of a sequential Workflow
processing pipeline to another. This class should only be used to process
science pipeline style Workflow
s, i.e., those which resemble an
iterative processing pipelines, with no forks, or concurrent task executions.CREATED, ERROR, FINISHED, METADATA_MISSING, PAUSED, QUEUED, RESMGR_SUBMIT, STARTED
JOB_ID, PROCESSING_NODE, QUEUE_NAME, TASK_ID, TASK_LOAD, WORKFLOW_INST_ID, WORKFLOW_MANAGER_URL
Constructor and Description |
---|
IterativeWorkflowProcessorThread(WorkflowInstance wInst,
WorkflowInstanceRepository instRep,
URL wParentUrl) |
Modifier and Type | Method and Description |
---|---|
String |
getCurrentTaskId() |
WorkflowInstanceRepository |
getInstanceRepository() |
XmlRpcResourceManagerClient |
getRClient() |
long |
getWaitforConditionSatisfy() |
URL |
getWmgrParentUrl() |
WorkflowInstance |
getWorkflowInstance() |
boolean |
isPaused() |
boolean |
isStopped() |
void |
pause() |
void |
resume() |
void |
run() |
void |
setInstanceRepository(WorkflowInstanceRepository instRep) |
void |
setRClient(XmlRpcResourceManagerClient client) |
void |
setWaitforConditionSatisfy(long waitforConditionSatisfy) |
void |
setWmgrParentUrl(URL wmgrParentUrl) |
void |
setWorkflowInst(WorkflowInstance workflowInst) |
void |
stop() |
public IterativeWorkflowProcessorThread(WorkflowInstance wInst, WorkflowInstanceRepository instRep, URL wParentUrl)
public WorkflowInstance getWorkflowInstance()
public void stop()
public void resume()
public void pause()
public boolean isPaused()
public boolean isStopped()
public String getCurrentTaskId()
public void setWorkflowInst(WorkflowInstance workflowInst)
workflowInst
- The fWorkflowInst to set.public long getWaitforConditionSatisfy()
public void setWaitforConditionSatisfy(long waitforConditionSatisfy)
waitforConditionSatisfy
- The waitForConditionSatisfy to set.public WorkflowInstanceRepository getInstanceRepository()
public void setInstanceRepository(WorkflowInstanceRepository instRep)
instRep
- the instRep to setpublic XmlRpcResourceManagerClient getRClient()
public void setRClient(XmlRpcResourceManagerClient client)
client
- the rClient to setpublic URL getWmgrParentUrl()
public void setWmgrParentUrl(URL wmgrParentUrl)
wmgrParentUrl
- the wmgrParentUrl to setCopyright © 1999-2015 Apache OODT. All Rights Reserved.