Package | Description |
---|---|
org.apache.oodt.cas.workflow.engine | |
org.apache.oodt.cas.workflow.engine.processor | |
org.apache.oodt.cas.workflow.structs |
Modifier and Type | Method and Description |
---|---|
List<WorkflowProcessor> |
TaskQuerier.getRunnableProcessors() |
Modifier and Type | Class and Description |
---|---|
class |
ConditionProcessor
WorkflowProcessor which handles Workflow Pre/Post Conditions.
|
class |
ParallelProcessor
WorkflowProcessor which handles running sub-workflow processors in parallel.
|
class |
SequentialProcessor
WorkflowProcessor which handles running sub-processors in sequence.
|
class |
TaskProcessor
WorkflowProcessor which handles running task workflows.
|
Modifier and Type | Method and Description |
---|---|
WorkflowProcessor |
WorkflowProcessorBuilder.build(Class<? extends WorkflowProcessor> clazz) |
WorkflowProcessor |
WorkflowProcessorHelper.buildProcessor(String instanceId,
ParentChildWorkflow model,
boolean isCondition,
Map<String,Class<? extends WorkflowProcessor>> modelToProcessorMap) |
WorkflowProcessor |
WorkflowProcessorHelper.buildProcessor(String instanceId,
ParentChildWorkflow workflow,
Map<String,Class<? extends WorkflowProcessor>> modelToProcessorMap,
boolean preCond) |
protected WorkflowProcessor |
WorkflowProcessorHelper.findProcessor(List<WorkflowProcessor> processors,
String modelId) |
WorkflowProcessor |
WorkflowProcessorHelper.findProcessor(WorkflowProcessor wp,
String modelId) |
protected WorkflowProcessor |
WorkflowProcessorHelper.findSkeleton(List<WorkflowProcessor> skeletons,
String modelId) |
WorkflowProcessor |
WorkflowProcessorHelper.findSkeleton(WorkflowProcessor skeleton,
String modelId) |
WorkflowProcessor |
WorkflowProcessor.getPostConditions() |
WorkflowProcessor |
WorkflowProcessor.getPreConditions() |
Modifier and Type | Method and Description |
---|---|
List<WorkflowProcessor> |
WorkflowProcessorQueue.getProcessors()
Should return the list of available, Queued,
WorkflowProcessor s. |
protected abstract List<WorkflowProcessor> |
WorkflowProcessor.getRunnableSubProcessors()
This is the core method of the WorkflowProcessor class in the new Wengine
style workflows.
|
List<WorkflowProcessor> |
TaskProcessor.getRunnableSubProcessors() |
List<WorkflowProcessor> |
SequentialProcessor.getRunnableSubProcessors() |
List<WorkflowProcessor> |
ParallelProcessor.getRunnableSubProcessors() |
List<WorkflowProcessor> |
WorkflowProcessor.getSubProcessors() |
List<WorkflowProcessor> |
WorkflowProcessorHelper.getWorkflowProcessorsByCategory(List<WorkflowProcessor> workflowProcessors,
String categoryName)
Sub-selects all WorkflowProcessors provided by the provided category
identified by categoryName.
|
List<WorkflowProcessor> |
WorkflowProcessorHelper.getWorkflowProcessorsByState(List<WorkflowProcessor> workflowProcessors,
String stateName)
Sub-selects all WorkflowProcessors provided by the provided state
identified by stateName.
|
List<WorkflowProcessor> |
WorkflowProcessorHelper.toTasks(WorkflowProcessor processor) |
Modifier and Type | Method and Description |
---|---|
int |
WorkflowProcessor.compareTo(WorkflowProcessor workflowProcessor) |
String |
WorkflowProcessorHelper.describe(WorkflowProcessor skeleton) |
WorkflowProcessor |
WorkflowProcessorHelper.findProcessor(WorkflowProcessor wp,
String modelId) |
WorkflowProcessor |
WorkflowProcessorHelper.findSkeleton(WorkflowProcessor skeleton,
String modelId) |
WorkflowLifecycle |
WorkflowProcessorHelper.getLifecycleForProcessor(WorkflowProcessor processor) |
protected abstract void |
WorkflowProcessor.handleSubProcessorMetadata(WorkflowProcessor workflowProcessor) |
void |
TaskProcessor.handleSubProcessorMetadata(WorkflowProcessor workflowProcessor) |
void |
SequentialProcessor.handleSubProcessorMetadata(WorkflowProcessor workflowProcessor) |
protected void |
ParallelProcessor.handleSubProcessorMetadata(WorkflowProcessor workflowProcessor) |
void |
WorkflowProcessorListener.notifyChange(WorkflowProcessor processor,
ChangeType changeType) |
void |
WorkflowProcessor.notifyChange(WorkflowProcessor processor,
ChangeType changeType) |
void |
WorkflowProcessor.setPostConditions(WorkflowProcessor postConditions) |
void |
ConditionProcessor.setPostConditions(WorkflowProcessor postConditions) |
void |
WorkflowProcessor.setPreConditions(WorkflowProcessor preConditions) |
void |
ConditionProcessor.setPreConditions(WorkflowProcessor preConditions) |
String |
WorkflowProcessorHelper.toString(WorkflowProcessor skeleton) |
List<WorkflowProcessor> |
WorkflowProcessorHelper.toTasks(WorkflowProcessor processor) |
Modifier and Type | Method and Description |
---|---|
boolean |
WorkflowProcessorHelper.allProcessorsSameCategory(List<WorkflowProcessor> workflowProcessors,
String categoryName)
Verifies that all provided WorkflowProcessors are in a state belonging to
the given categoryName.
|
WorkflowProcessor |
WorkflowProcessorBuilder.build(Class<? extends WorkflowProcessor> clazz) |
WorkflowProcessor |
WorkflowProcessorHelper.buildProcessor(String instanceId,
ParentChildWorkflow model,
boolean isCondition,
Map<String,Class<? extends WorkflowProcessor>> modelToProcessorMap) |
WorkflowProcessor |
WorkflowProcessorHelper.buildProcessor(String instanceId,
ParentChildWorkflow workflow,
Map<String,Class<? extends WorkflowProcessor>> modelToProcessorMap,
boolean preCond) |
boolean |
WorkflowProcessorHelper.containsCategory(List<WorkflowProcessor> workflowProcessors,
String categoryName) |
protected WorkflowProcessor |
WorkflowProcessorHelper.findProcessor(List<WorkflowProcessor> processors,
String modelId) |
protected WorkflowProcessor |
WorkflowProcessorHelper.findSkeleton(List<WorkflowProcessor> skeletons,
String modelId) |
List<WorkflowProcessor> |
WorkflowProcessorHelper.getWorkflowProcessorsByCategory(List<WorkflowProcessor> workflowProcessors,
String categoryName)
Sub-selects all WorkflowProcessors provided by the provided category
identified by categoryName.
|
List<WorkflowProcessor> |
WorkflowProcessorHelper.getWorkflowProcessorsByState(List<WorkflowProcessor> workflowProcessors,
String stateName)
Sub-selects all WorkflowProcessors provided by the provided state
identified by stateName.
|
void |
WorkflowProcessor.setSubProcessors(List<WorkflowProcessor> subProcessors) |
void |
TaskProcessor.setSubProcessors(List<WorkflowProcessor> subProcessors) |
WorkflowProcessorBuilder |
WorkflowProcessorBuilder.with(WorkflowProcessorBuilder wpb,
Class<? extends WorkflowProcessor> clazz) |
Modifier and Type | Method and Description |
---|---|
void |
PrioritySorter.sort(List<WorkflowProcessor> candidates)
Sorts the
List of WorkflowProcessor s that are ready to run
in a particular order specified by the sub-class implementing this method. |
void |
HighestPrioritySorter.sort(List<WorkflowProcessor> candidates) |
void |
HighestFIFOPrioritySorter.sort(List<WorkflowProcessor> candidates) |
void |
FILOPrioritySorter.sort(List<WorkflowProcessor> candidates) |
Copyright © 1999-2015 Apache OODT. All Rights Reserved.