Project Documentation
Software Documentation
The following document contains the results of RAT (Release Audit Tool).
*****************************************************
Summary
-------
Notes: 0
Binaries: 13
Archives: 0
Standards: 209
Apache Licensed: 192
Generated Documents: 0
JavaDocs are generated and so license header is optional
Generated files do not required license headers
17 Unknown Licenses
*******************************
Archives (+ indicates readable, $ unreadable):
*****************************************************
Files with AL headers will be marked L
Binary files (which do not require AL headers) will be marked B
Compressed archives will be marked A
Notices, licenses etc will be marked N
AL /Users/mattmann/git/oodt/workflow/pom.xml
AL /Users/mattmann/git/oodt/workflow/src/main/assembly/assembly.xml
AL /Users/mattmann/git/oodt/workflow/src/main/bin/wmgr
AL /Users/mattmann/git/oodt/workflow/src/main/bin/wmgr-client
AL /Users/mattmann/git/oodt/workflow/src/main/bin/wmkill
AL /Users/mattmann/git/oodt/workflow/src/main/bin/wmkillallbystatus
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/DynWorkflowCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetConditionByIdCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetFirstPageCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetLastPageCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetNextPageCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetPrevPageCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetRegisteredEventsCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskByIdCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskWallClockTimeCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWallClockTimeCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowByIdCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstMetCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstsCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/PauseWorkflowInstCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/ResumeWorkflowInstCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/SendEventCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/StopWorkflowInstCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/WorkflowCliAction.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ChangeType.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/IterativeWorkflowProcessorThread.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/PrioritizedQueueBasedWorkflowEngine.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/PrioritizedQueueBasedWorkflowEngineFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/ConditionProcessor.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/ParallelProcessor.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/SequentialProcessor.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/TaskProcessor.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessor.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorBuilder.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorHelper.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorListener.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/processor/WorkflowProcessorQueue.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/runner/AbstractEngineRunnerBase.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/runner/AsynchronousLocalEngineRunner.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/runner/AsynchronousLocalEngineRunnerFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/runner/EngineRunner.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/runner/EngineRunnerFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/runner/ResourceRunner.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/runner/ResourceRunnerFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/TaskQuerier.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/TaskRunner.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngine.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/ThreadPoolWorkflowEngineFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/WorkflowEngine.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/WorkflowEngineFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/BranchRedirector.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/CheckForMetadataKeys.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/ExternScriptTaskInstance.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/FalseCondition.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/FilterTask.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/GoodbyeWorld.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/HelloWorld.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/LongCondition.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/LongTask.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/MailTask.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/NoOpTask.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/NumIncrementTask.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/PrerequisiteCondition.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/RandomStatusUpdateTask.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/ResmgrJobCondition.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/examples/TrueCondition.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/exceptions/WorkflowException.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/AbstractPaginatibleInstanceRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/DataSourceWorkflowInstanceRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/DataSourceWorkflowInstanceRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/LuceneWorkflowInstanceRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/LuceneWorkflowInstanceRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/MemoryWorkflowInstanceRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/MemoryWorkflowInstanceRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/WorkflowInstanceMetadataReader.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/WorkflowInstanceMetMap.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/WorkflowInstanceMetMapKeys.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/WorkflowInstanceRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/instrepo/WorkflowInstanceRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/lifecycle/WorkflowLifecycle.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/lifecycle/WorkflowLifecycleManager.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/lifecycle/WorkflowLifecycleMetKeys.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/lifecycle/WorkflowLifecyclesReader.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/lifecycle/WorkflowLifecycleStage.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/lifecycle/WorkflowState.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/metadata/CoreMetKeys.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/EnvSavingConfiguration.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/EnvVarSavingConfigReader.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/PolicyAwareWorkflowTask.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskPolicyMetKeys.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskPolicyReader.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskPolicyWriter.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskRequestFactory.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskRequestProcessorMetKeys.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/DataSourceWorkflowRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/DataSourceWorkflowRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/PackagedWorkflowRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/PackagedWorkflowRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/WorkflowRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/WorkflowRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/XMLWorkflowRepository.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/repository/XMLWorkflowRepositoryFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/ConditionTaskInstance.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/exceptions/EngineException.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/exceptions/InstanceRepositoryException.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/exceptions/RepositoryException.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/exceptions/WorkflowTaskInstanceException.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/FILOPrioritySorter.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/Graph.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestFIFOPrioritySorter.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/HighestPrioritySorter.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/ParentChildWorkflow.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/Priority.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/PrioritySorter.java
!????? /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/RollbackableWorkflowTaskInstance.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/TaskJob.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/TaskJobInput.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/Workflow.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowCondition.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowConditionConfiguration.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowConditionInstance.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowInstance.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowInstancePage.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowStatus.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowTask.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowTaskConfiguration.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/WorkflowTaskInstance.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/system/XmlRpcWorkflowManager.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/system/XmlRpcWorkflowManagerClient.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/tools/InstanceRepoCleaner.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/util/CygwinScriptFile.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/util/DbStructFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/util/GenericWorkflowObjectFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/util/Pagination.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/util/ScriptFile.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/util/XmlRpcStructFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/util/XmlStructFactory.java
AL /Users/mattmann/git/oodt/workflow/src/main/resources/cmd-line-actions.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/cmd-line-options.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/backwardsTestWorkflow.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/condition.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/conditions.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/events.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/externalScript.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/longWorkflow.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/mailWorkflow.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/optional.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/tasks.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/testMetadataUpdate.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/testMetError.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/testStatusUpdate.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/testWorkflow.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/timeout.workflow.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/wengine/GranuleMaps.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/wengine/hello-goodbye.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/wengine/wengine-lifecycle.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/workflow-instance-met.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/examples/workflow-lifecycle.xml
AL /Users/mattmann/git/oodt/workflow/src/main/resources/logging.properties
AL /Users/mattmann/git/oodt/workflow/src/main/resources/REMOVE.log
AL /Users/mattmann/git/oodt/workflow/src/main/resources/workflow.properties
AL /Users/mattmann/git/oodt/workflow/src/main/resources/workflow.sql
AL /Users/mattmann/git/oodt/workflow/src/main/resources/workflow_oracle_create_sequences.sql
AL /Users/mattmann/git/oodt/workflow/src/site/resources/css/guides.css
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/cas-workflow.jpg
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/cas-workflow.psd
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/error.png
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/info.png
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/success.png
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/warning.png
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/wm_extension_points.png
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/wm_object_model.png
B /Users/mattmann/git/oodt/workflow/src/site/resources/images/wm_use_case1.jpg
AL /Users/mattmann/git/oodt/workflow/src/site/site.xml
AL /Users/mattmann/git/oodt/workflow/src/site/xdoc/development/developer.xml
AL /Users/mattmann/git/oodt/workflow/src/site/xdoc/development/maven.xml
AL /Users/mattmann/git/oodt/workflow/src/site/xdoc/user/advanced.xml
AL /Users/mattmann/git/oodt/workflow/src/site/xdoc/user/basic.xml
AL /Users/mattmann/git/oodt/workflow/src/site/xdoc/user/index.xml
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/cli/TestWorkflowCli.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/cli/UseMockClientCmdLineActionStore.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/MetSetterTaskQuerier.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/MockProcessorQueue.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/QuerierAndRunnerUtils.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/SimpleTester.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/TestAsynchronousLocalEngineRunner.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/TestTaskQuerier.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/TestTaskRunner.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/engine/TestThreadPoolWorkflowEngine.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/examples/TestExternScriptTaskInstance.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/examples/TestFilterTask.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/instrepo/TestLuceneWorkflowInstanceRepository.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/lifecycle/TestWorkflowLifecycleManager.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/repository/MockWorkflowRepository.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/repository/TestPackagedWorkflowRepository.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/repository/TestWorkflowDataSourceRepository.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/repository/TestWorkflowRepository.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/structs/TestFILOPrioritySorter.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/structs/TestHighestFIFOPrioritySorter.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/structs/TestHighestPrioritySorter.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/structs/TestWorkflowInstance.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/system/MockXmlRpcWorkflowManagerClient.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManager.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/tools/TestInstanceRepoCleaner.java
AL /Users/mattmann/git/oodt/workflow/src/test/java/org/apache/oodt/cas/workflow/util/TestGenericWorkflowObjectFactory.java
!????? /Users/mattmann/git/oodt/workflow/src/test/resources/myScript-Output.txt
AL /Users/mattmann/git/oodt/workflow/src/test/resources/myScript.sh
AL /Users/mattmann/git/oodt/workflow/src/test/resources/test.logging.properties
B /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_4.cfe
!????? /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_4.cfs
!????? /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_4.si
B /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_5.cfe
!????? /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_5.cfs
!????? /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_5.si
B /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/pending_segments_b
B /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/segments_a
!????? /Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/write.lock
!????? /Users/mattmann/git/oodt/workflow/src/test/resources/workflow.sql
*****************************************************
Printing headers for files without AL header...
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/exceptions/WorkflowException.java
=======================================================================
package org.apache.oodt.cas.workflow.exceptions;
/**
* Created by bugg on 27/10/15.
*/
public class WorkflowException extends Exception {
public WorkflowException(String message){
super(message);
}
}
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/EnvSavingConfiguration.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
//JDK imports
import java.util.Properties;
//OODT imports
import org.apache.oodt.cas.workflow.structs.WorkflowTaskConfiguration;
/**
* @author mattmann
* @version $Revision$
*
* <p>
* A {@link WorkflowTaskConfiguration} that preserves whether or not a task config
* property was envReplace'd or not.
* </p>.
*/
public class EnvSavingConfiguration extends WorkflowTaskConfiguration {
private Properties envReplaceMap;
public EnvSavingConfiguration() {
super();
envReplaceMap = new Properties();
}
/*
* (non-Javadoc)
*
* @see gov.nasa.jpl.oodt.cas.workflow.structs.WorkflowTaskConfiguration#addConfigProperty(java.lang.String,
* java.lang.String)
*/
public void addConfigProperty(String propName, String propVal) {
addConfigProperty(propName, propVal, false);
}
/**
* Adds a configuration property, along with its envReplace
* information.
*
* @param propName The workflow config property name.
* @param propVal The workflow config property val.
* @param isReplace Whether or not the property should be envReplaced.
*/
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/EnvVarSavingConfigReader.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
//JDK imports
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
/**
* @author mattmann
* @version $Revision$
*
* <p>
* Provides a utility method to read in a {@link WorkflowConfiguration} from an
* XML {@link Node}, preserving its envReplace information.
* </p>.
*/
public class EnvVarSavingConfigReader {
private EnvVarSavingConfigReader() throws InstantiationException {
throw new InstantiationException("Don't construct readers!");
}
public static EnvSavingConfiguration getConfiguration(Node node) {
Element configNode = (Element) node;
NodeList configProperties = configNode.getElementsByTagName("property");
EnvSavingConfiguration config = null;
if (configProperties == null) {
return null;
}
config = new EnvSavingConfiguration();
for (int i = 0; i < configProperties.getLength(); i++) {
Element propElem = (Element) configProperties.item(i);
String value = propElem.getAttribute("value");
boolean doReplace = Boolean.valueOf(
propElem.getAttribute("envReplace")).booleanValue();
config.addConfigProperty(propElem.getAttribute("name"), value,
doReplace);
}
return config;
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/PolicyAwareWorkflowTask.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
//OODT imports
import java.util.Iterator;
import org.apache.oodt.cas.workflow.structs.WorkflowCondition;
import org.apache.oodt.cas.workflow.structs.WorkflowTask;
/**
* @author mattmann
* @version $Revision$
*
* <p>
* A {@link WorkflowTask} that is aware of what policy directory
* that it comes from.
* </p>.
*/
public class PolicyAwareWorkflowTask extends WorkflowTask {
private String policyDirPath;
public PolicyAwareWorkflowTask() {
super();
this.policyDirPath = null;
}
public PolicyAwareWorkflowTask(WorkflowTask task) {
super(task.getTaskId(), task.getTaskName(), task.getTaskConfig(), task
.getConditions(), task.getTaskInstanceClassName(), task
.getOrder());
this.setRequiredMetFields(task.getRequiredMetFields());
}
/**
* @return the policyDirPath
*/
public String getPolicyDirPath() {
return policyDirPath;
}
/**
* @param policyDirPath
* the policyDirPath to set
*/
public void setPolicyDirPath(String policyDirPath) {
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskPolicyMetKeys.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
/**
* @author mattmann
* @version $Revision$
*
* <p>Met keys for writing out the tasks.xml policy file</p>.
*/
public interface TaskPolicyMetKeys {
public static final String CAS_TASKS_OUTER_ELEM = "cas:tasks";
public static final String CAS_XML_NS_DESC = "xmlns:cas";
public static final String CAS_NS = "http://oodt.jpl.nasa.gov/1.0/cas";
public static final String TASK_ELEM = "task";
public static final String TASK_ID_ATTR= "id";
public static final String TASK_NAME_ATTR = "name";
public static final String TASK_INST_CLASS_ATTR = "class";
public static final String TASK_CONDITIONS_ELEM = "conditions";
public static final String TASK_COND_ELEM = "condition";
public static final String TASK_COND_ID_ATTR = "id";
public static final String TASK_REQ_MET_FIELDS_ELEM = "requiredMetFields";
public static final String TASK_REQ_MET_FIELD_ELEM = "metfield";
public static final String TASK_REQ_MET_FIELD_NAME_ATTR = "name";
public static final String TASK_CONFIG_ELEM = "configuration";
public static final String PROPERTY_ELEM = "property";
public static final String PROPERTY_ELEM_NAME_ATTR = "name";
public static final String PROPERTY_ELEM_VALUE_ATTR = "value";
public static final String PROPERTY_ELEM_ENVREPLACE_ATTR = "envReplace";
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskPolicyReader.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
//OODT imports
import org.apache.oodt.cas.workflow.repository.XMLWorkflowRepository;//for javadoc
import org.apache.oodt.cas.workflow.structs.WorkflowCondition;
import org.apache.oodt.cas.workflow.structs.WorkflowTask;
import org.apache.oodt.cas.workflow.util.XmlStructFactory;
//JDK imports
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.net.URI;
import java.net.URISyntaxException;
import java.util.Comparator;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.NodeList;
import org.xml.sax.InputSource;
/**
* @author mattmann
* @version $Revision$
*
* <p>
* A reader to read in the {@link WorkflowTask} policy managed by the
* {@link XMLWorkflowRepository}
* </p>.
*/
public final class TaskPolicyReader {
/* our log stream */
private static final Logger LOG = Logger.getLogger(TaskPolicyReader.class
.getName());
private TaskPolicyReader() throws InstantiationException {
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskPolicyWriter.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
//OODT imports
import org.apache.oodt.commons.xml.XMLUtils;
import org.apache.oodt.cas.workflow.repository.XMLWorkflowRepository;
import org.apache.oodt.cas.workflow.structs.WorkflowCondition;
//JDK imports
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.util.Comparator;
import java.util.Iterator;
import java.util.Map;
import java.util.TreeMap;
import java.util.logging.Level;
import java.util.logging.Logger;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
/**
* @author mattmann
* @version $Revision$
*
* <p>
* A writer class to write out {@link WorkflowTask} policy that is managed by
* the {@link XMLWorkflowRepository}
* </p>.
*/
public final class TaskPolicyWriter implements TaskPolicyMetKeys {
private static final String TASKS_XML_FILE_NAME = "tasks.xml";
/* our log stream */
private static final Logger LOG = Logger.getLogger(TaskPolicyWriter.class
.getName());
private TaskPolicyWriter() throws InstantiationException {
throw new InstantiationException("Don't construct writers!");
}
public static void writeTask(PolicyAwareWorkflowTask updateTask, Map taskMap) {
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskRequestFactory.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
//OODT imports
import org.apache.oodt.cas.workflow.structs.WorkflowCondition;
//JDK imports
import java.util.Collections;
import java.util.List;
import java.util.Map;
import java.util.Vector;
/**
* @author mattmann
* @version $Revision$
*
* <p>
* A Jsp utility that processes a {@link PolicyAwareWorkflowTask} that is given
* in the form of a HttpServletRequestWrapper#getParameterMap().
* </p>.
*/
public class TaskRequestFactory implements TaskRequestProcessorMetKeys {
private TaskRequestFactory() throws InstantiationException {
throw new InstantiationException("Don't construct factories!");
}
/**
* Processes a given {@link PolicyAwareWorkflowTask} and unmarshalls it out
* of the given {@link Map}.
*
* @param paramMap
* A parameter {@link Map}, generated by a call to
* {@link HttpServletRequestWrapper#getParameterMap()}.
* @return An unmarshalled, {@link PolicyAwareWorkflowTask}.
*/
public static PolicyAwareWorkflowTask getTask(Map paramMap) {
PolicyAwareWorkflowTask task = new PolicyAwareWorkflowTask();
task.setTaskName(getFirst((String[]) paramMap.get(TASK_NAME)));
task.setTaskId(getFirst((String[]) paramMap.get(UPDATE_TASK_ID)));
task.setPolicyDirPath(getFirst((String[]) paramMap
.get(TASK_POLICY_DIR_PATH)));
task.setTaskInstanceClassName(getFirst((String[]) paramMap
.get(TASK_CLASS_NAME)));
int reqMetFieldCount = Integer.parseInt(getFirst((String[]) paramMap
.get(REQ_MET_FIELDS_COUNT)));
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/policy/TaskRequestProcessorMetKeys.java
=======================================================================
//Copyright (c) 2008, California Institute of Technology.
//ALL RIGHTS RESERVED. U.S. Government sponsorship acknowledged.
//
//$Id$
package org.apache.oodt.cas.workflow.policy;
/**
* @author mattmann
* @version $Revision$
*
* <p>Met keys for unpackaging a {@link PolicyAwareWorkflowTask} out of a
* {@link HttpServletRequestWrapper}</p>.
*/
public interface TaskRequestProcessorMetKeys {
public static final String TASK_POLICY_DIR_PATH = "taskPolicyDirPath";
public static final String UPDATE_TASK_ID = "updateTaskId";
public static final String TASK_NAME = "task_name";
public static final String TASK_CLASS_NAME = "task_class_name";
public static final String TASK_CONDITION_IDS = "selectedConditionIds";
public static final String REQ_MET_FIELDS_COUNT = "reqMetFieldCnt";
public static final String REQ_MET_FIELD_TAGBASE = "reqMetField";
public static final String TASK_CONFIG_FIELD_COUNT = "taskConfigCnt";
public static final String TASK_CONFIG_PROPNAME_BASE = "taskConfigPropName";
public static final String TASK_CONFIG_PROPVAL_BASE = "taskConfigPropValue";
}
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/main/java/org/apache/oodt/cas/workflow/structs/RollbackableWorkflowTaskInstance.java
=======================================================================
package org.apache.oodt.cas.workflow.structs;
//JDK imports
import java.net.MalformedURLException;
import java.net.URL;
import java.util.List;
//OODT imports
import org.apache.oodt.cas.metadata.Metadata;
import org.apache.oodt.cas.workflow.metadata.CoreMetKeys;
import org.apache.oodt.cas.workflow.structs.exceptions.WorkflowTaskInstanceException;
import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
public abstract class RollbackableWorkflowTaskInstance implements
WorkflowTaskInstance {
protected XmlRpcWorkflowManagerClient wmc;
protected String workflowInstId;
public void run(Metadata metadata, WorkflowTaskConfiguration config)
throws WorkflowTaskInstanceException {
workflowInstId = getWorkflowInstanceId(metadata);
wmc = createWorkflowMangerClient(metadata);
//clean generated metadata
clearAllMetadata(metadata);
//Determine next workflow state
updateState(metadata);
//clean up task instance from instance rep?
clearInstRep();
}
protected String getWorkflowInstanceId(Metadata metadata) {
String instId = metadata.getMetadata(CoreMetKeys.WORKFLOW_INST_ID);
return instId;
}
protected XmlRpcWorkflowManagerClient createWorkflowMangerClient(Metadata metadata) {
URL url;
try {
url = new URL(metadata.getMetadata(CoreMetKeys.WORKFLOW_MANAGER_URL));
wmc = new XmlRpcWorkflowManagerClient(url);
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/test/resources/myScript-Output.txt
=======================================================================
Hi my first name is Faranak and my last name is Davoodi.
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_4.cfs
=======================================================================
??l??Lucene50CompoundData??????BGش?A?Z(eֿg????l??Lucene50StoredFieldsFastData??????BGش?A?Z(eֿg????????2???c?$0f80a46e-4755-11e6-9991-411a8387995f??0??QUEUED??urn:oodt:HelloWorld ?(?0?2016-07-11T11:48:53.926+01:008?@?5.0H?????longWorkflowP
Long ???Xe??!`?q??%???ldh?1p0org.apache.??c.cas.wR??.examples.6??????x?True Condition??????????????3\?? 6??????1???-1???false???Person???ChrisX??qGoodbye??#`
??????2p2????8??F?+?????????????"P???1????????????????O??
IntensiveTask`?Processor ??? ??_h?3p.????!??3?%X????L?????WithWait`???? ??_erh?4e??0???p??+?????????+???+?? 6?`???1??+???+????myvalue???(????????????i???l??Lucene60FieldInfos??????BGش?A?Z(eֿg??&?workflow_inst_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_inst_timesblocked??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_inst_status??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_inst_current_task_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?'workflow_inst_currenttask_startdatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0?%workflow_inst_currenttask_enddatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0??workflow_inst_startdatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0??workflow_inst_enddatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0??workflow_inst_priority??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_id ?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?
workflow_name
?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??task_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0? task_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?
task_order
?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?
task_class??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?"urn:oodt:HelloWorld_condition_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0? urn:oodt:HelloWorld_condition_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?#urn:oodt:HelloWorld_condition_class??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?#urn:oodt:HelloWorld_condition_order??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?%urn:oodt:HelloWorld_condition_timeout??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?&urn:oodt:HelloWorld_condition_optional??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?(urn:oodt:HelloWorld_config_property_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?)urn:oodt:HelloWorld_config_property_value??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?$urn:oodt:GoodbyeWorld_condition_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?"urn:oodt:GoodbyeWorld_condition_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?%urn:oodt:GoodbyeWorld_condition_class??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?%urn:oodt:GoodbyeWorld_condition_order??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?'urn:oodt:GoodbyeWorld_condition_timeout??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?(urn:oodt:GoodbyeWorld_condition_optional??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?*urn:oodt:GoodbyeWorld_config_property_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?+urn:oodt:GoodbyeWorld_config_property_value??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?-urn:oodt:IntensiveTaskWithWait_condition_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?+urn:oodt:IntensiveTaskWithWait_condition_id ?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?.urn:oodt:IntensiveTaskWithWait_condition_class!?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?.urn:oodt:IntensiveTaskWithWait_condition_order"?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?0urn:oodt:IntensiveTaskWithWait_condition_timeout#?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?1urn:oodt:IntensiveTaskWithWait_condition_optional$?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??myfield%?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??(??????????Px|???l??Lucene54DocValuesData??????BGش?A?Z(eֿg?
Lucene54_0????????2016-07-11T11:48:53.926+01:00?????????(????????????=a??l??BlockTreeTermsIndex??????BGش?A?Z(eֿg?
Lucene50_0??l??FST????????????????l??FST????????????????l??FST??????? ????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST??????? ????????l??FST???????!????????l??FST???????!????????l??FST???????!????????l??FST???????!????????l??FST???????#????????l??FST???????#????????l??FST???????$????????l??FST???????%????????l??FST???????%??????7Mcy???????????????????????????????????????????????????????????????????????????{?(??????????3????l??Lucene50StoredFieldsFastIndex??????BGش?A?Z(eֿg????????:???????(????????????, ??l??Lucene54DocValuesMetadata??????BGش?A?Z(eֿg?
Lucene54_0???????????????????????9??????????????????9?????????????????=???????????????????????=??????????????????=?????????????????A???????????????????????A??????????????????^?????????????????b???????????????????????b??????????????????b?????????????????f??????(??????????u?Ɛ??l??Lucene50PostingsWriterDoc??????BGش?A?Z(eֿg?
Lucene50_0? !?#?????
??
???????????????????(??????????'m????l??BlockTreeTermsDict??????BGش?A?Z(eֿg?
Lucene50_0???l??Lucene50PostingsWriterTerms??????BGش?A?Z(eֿg?
Lucene50_0?????myvalue???^????2org.apache.oodt.cas.workflow.examples.GoodbyeWorld0org.apache.oodt.cas.workflow.examples.HelloWorld.org.apache.oodt.cas.workflow.examples.LongTask?????^????? ???urn:oodt:GoodbyeWorld?urn:oodt:HelloWorld?urn:oodt:IntensiveTask?urn:oodt:IntensiveTaskWithWait??????^??????? ??
Goodbye World?Hello World?Intensive Waiter?Processor Intensive Task??????^??????? ??1?2?3?4??????^????????i3org.apache.oodt.cas.workflow.examples.TrueCondition???^??/?urn:oodt:TrueCondition???^????True Condition???^??
?false???^????1???^????-1???^????Person???^??
?Chris???^??i3org.apache.oodt.cas.workflow.examples.TrueCondition???^??/?urn:oodt:TrueCondition???^????True Condition???^??
?false???^????1???^????-1???^????Person???^??
?Chris???^??i3org.apache.oodt.cas.workflow.examples.LongCondition???^??/?urn:oodt:LongCondition???^????Long Condition???^??
?false???^????1???^????-1???^??-?urn:oodt:longWorkflow???^??)?urn:oodt:HelloWorld???^???????^???????^???????^??K$0f80a46e-4755-11e6-9991-411a8387995f???^?? ?5.0???^??=?2016-07-11T11:48:53.926+01:00???^????QUEUED???^????0???^???
Long Workflow???^?&%????????myvalue?myvalue????????2org.apache.oodt.cas.workflow.examples.GoodbyeWorld.org.apache.oodt.cas.workflow.examples.LongTask???? ????urn:oodt:GoodbyeWorld?urn:oodt:IntensiveTaskWithWait????????
Goodbye World?Processor Intensive Task
????????1?4????????3org.apache.oodt.cas.workflow.examples.TrueCondition3org.apache.oodt.cas.workflow.examples.TrueCondition?????????urn:oodt:TrueCondition?urn:oodt:TrueCondition?????????True Condition?True Condition?????????false?false?????????1?1?????????-1?-1?????????Person?Person?????????Chris?Chris????????3org.apache.oodt.cas.workflow.examples.TrueCondition3org.apache.oodt.cas.workflow.examples.TrueCondition?????????urn:oodt:TrueCondition?urn:oodt:TrueCondition?????????True Condition?True Condition?????????false?false?????????1?1?????????-1?-1?????????Person?Person?????????Chris?Chris!???????3org.apache.oodt.cas.workflow.examples.LongCondition3org.apache.oodt.cas.workflow.examples.LongCondition ????????urn:oodt:LongCondition?urn:oodt:LongCondition?????????Long Condition?Long Condition$????????false?false"????????1?1#????????-1?-1 ????????urn:oodt:longWorkflow?urn:oodt:longWorkflow???? ????urn:oodt:HelloWorld?urn:oodt:HelloWorld????!?????????!?????????!?????????!???$0f80a46e-4755-11e6-9991-411a8387995f$0f80a46e-4755-11e6-9991-411a8387995f????#????5.0?5.0????#????2016-07-11T11:48:53.926+01:00?2016-07-11T11:48:53.926+01:00????$????QUEUED?QUEUED????%????0?0
???%???
Long Workflow
Long Workflow?????????(???????????ы??(???????????
H?
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_4.si
=======================================================================
??l??Lucene50SegmentInfo??????BGش?A?Z(eֿg???????????????????
?os?Linux?java.vendor?Oracle Corporation?java.version?1.8.0_91?java.vm.version 25.91-b14?lucene.version?6.1.0?os.arch?amd64?java.runtime.version&1.8.0_91-8u91-b14-0ubuntu4~16.04.1-b14?source?flush
os.version?4.4.0-28-generic timestamp
1468234134121??_4.cfe?_4.cfs?_4.si??Lucene50StoredFieldsFormat.mode
BEST_SPEED?(?????????????}
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_5.cfs
=======================================================================
??l??Lucene50CompoundData??????BGش?A?Z(eֿg????l??Lucene54DocValuesMetadata??????BGش?A?Z(eֿg?
Lucene54_0???????????????????????9??????????????????9?????????????????=???????????????????????=??????????????????=?????????????????A???????????????????????A??????????????????^?????????????????b???????????????????????b??????????????????b?????????????????f??????(???????????-?*??l??Lucene60FieldInfos??????BGش?A?Z(eֿg??&?workflow_inst_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_inst_timesblocked??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_inst_status??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_inst_current_task_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?'workflow_inst_currenttask_startdatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0?%workflow_inst_currenttask_enddatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0??workflow_inst_startdatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0??workflow_inst_enddatetime??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldDocValuesFormat.format?Lucene54?PerFieldPostingsFormat.suffix?0?PerFieldDocValuesFormat.suffix?0??workflow_inst_priority??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??workflow_id ?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?
workflow_name
?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??task_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0? task_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?
task_order
?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?
task_class??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?"urn:oodt:HelloWorld_condition_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0? urn:oodt:HelloWorld_condition_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?#urn:oodt:HelloWorld_condition_class??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?#urn:oodt:HelloWorld_condition_order??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?%urn:oodt:HelloWorld_condition_timeout??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?&urn:oodt:HelloWorld_condition_optional??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?(urn:oodt:HelloWorld_config_property_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?)urn:oodt:HelloWorld_config_property_value??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?$urn:oodt:GoodbyeWorld_condition_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?"urn:oodt:GoodbyeWorld_condition_id??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?%urn:oodt:GoodbyeWorld_condition_class??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?%urn:oodt:GoodbyeWorld_condition_order??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?'urn:oodt:GoodbyeWorld_condition_timeout??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?(urn:oodt:GoodbyeWorld_condition_optional??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?*urn:oodt:GoodbyeWorld_config_property_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?+urn:oodt:GoodbyeWorld_config_property_value??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?-urn:oodt:IntensiveTaskWithWait_condition_name??????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?+urn:oodt:IntensiveTaskWithWait_condition_id ?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?.urn:oodt:IntensiveTaskWithWait_condition_class!?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?.urn:oodt:IntensiveTaskWithWait_condition_order"?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?0urn:oodt:IntensiveTaskWithWait_condition_timeout#?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0?1urn:oodt:IntensiveTaskWithWait_condition_optional$?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??myfield%?????????????PerFieldPostingsFormat.format?Lucene50?PerFieldPostingsFormat.suffix?0??(??????????Z?f???l??Lucene50StoredFieldsFastData??????BGش?A?Z(eֿg????????2???c?$0f630a4d-4755-11e6-9991-411a8387995f??0??QUEUED??urn:oodt:HelloWorld ?(?0?2016-07-11T11:48:53.925+01:008?@?5.0H?????longWorkflowP
Long ???Xe??!`?q??%???ldh?1p0org.apache.??c.cas.wR??.examples.6??????x?True Condition??????????????3\?? 6??????1???-1???false???Person???ChrisX??qGoodbye??#`
??????2p2????8??F?+?????????????"P???1????????????????O??
IntensiveTask`?Processor ??? ??_h?3p.????!??3?%X????L?????WithWait`???? ??_erh?4e??0???p??+?????????+???+?? 6?`???1??+???+????myvalue???(???????????<??l??Lucene54DocValuesData??????BGش?A?Z(eֿg?
Lucene54_0????????2016-07-11T11:48:53.925+01:00?????????(?????????????W??l??BlockTreeTermsIndex??????BGش?A?Z(eֿg?
Lucene50_0??l??FST????????????????l??FST????????????????l??FST??????? ????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST????????????????l??FST??????? ????????l??FST???????!????????l??FST???????!????????l??FST???????!????????l??FST???????!????????l??FST???????#????????l??FST???????#????????l??FST???????$????????l??FST???????%????????l??FST???????%??????7Mcy???????????????????????????????????????????????????????????????????????????{?(??????????ЂdU??l??Lucene50PostingsWriterDoc??????BGش?A?Z(eֿg?
Lucene50_0? !?#?????
??
???????????????????(??????????9??P??l??BlockTreeTermsDict??????BGش?A?Z(eֿg?
Lucene50_0???l??Lucene50PostingsWriterTerms??????BGش?A?Z(eֿg?
Lucene50_0?????myvalue???^????2org.apache.oodt.cas.workflow.examples.GoodbyeWorld0org.apache.oodt.cas.workflow.examples.HelloWorld.org.apache.oodt.cas.workflow.examples.LongTask?????^????? ???urn:oodt:GoodbyeWorld?urn:oodt:HelloWorld?urn:oodt:IntensiveTask?urn:oodt:IntensiveTaskWithWait??????^??????? ??
Goodbye World?Hello World?Intensive Waiter?Processor Intensive Task??????^??????? ??1?2?3?4??????^????????i3org.apache.oodt.cas.workflow.examples.TrueCondition???^??/?urn:oodt:TrueCondition???^????True Condition???^??
?false???^????1???^????-1???^????Person???^??
?Chris???^??i3org.apache.oodt.cas.workflow.examples.TrueCondition???^??/?urn:oodt:TrueCondition???^????True Condition???^??
?false???^????1???^????-1???^????Person???^??
?Chris???^??i3org.apache.oodt.cas.workflow.examples.LongCondition???^??/?urn:oodt:LongCondition???^????Long Condition???^??
?false???^????1???^????-1???^??-?urn:oodt:longWorkflow???^??)?urn:oodt:HelloWorld???^???????^???????^???????^??K$0f630a4d-4755-11e6-9991-411a8387995f???^?? ?5.0???^??=?2016-07-11T11:48:53.925+01:00???^????QUEUED???^????0???^???
Long Workflow???^?&%????????myvalue?myvalue????????2org.apache.oodt.cas.workflow.examples.GoodbyeWorld.org.apache.oodt.cas.workflow.examples.LongTask???? ????urn:oodt:GoodbyeWorld?urn:oodt:IntensiveTaskWithWait????????
Goodbye World?Processor Intensive Task
????????1?4????????3org.apache.oodt.cas.workflow.examples.TrueCondition3org.apache.oodt.cas.workflow.examples.TrueCondition?????????urn:oodt:TrueCondition?urn:oodt:TrueCondition?????????True Condition?True Condition?????????false?false?????????1?1?????????-1?-1?????????Person?Person?????????Chris?Chris????????3org.apache.oodt.cas.workflow.examples.TrueCondition3org.apache.oodt.cas.workflow.examples.TrueCondition?????????urn:oodt:TrueCondition?urn:oodt:TrueCondition?????????True Condition?True Condition?????????false?false?????????1?1?????????-1?-1?????????Person?Person?????????Chris?Chris!???????3org.apache.oodt.cas.workflow.examples.LongCondition3org.apache.oodt.cas.workflow.examples.LongCondition ????????urn:oodt:LongCondition?urn:oodt:LongCondition?????????Long Condition?Long Condition$????????false?false"????????1?1#????????-1?-1 ????????urn:oodt:longWorkflow?urn:oodt:longWorkflow???? ????urn:oodt:HelloWorld?urn:oodt:HelloWorld????!?????????!?????????!?????????!???$0f630a4d-4755-11e6-9991-411a8387995f$0f630a4d-4755-11e6-9991-411a8387995f????#????5.0?5.0????#????2016-07-11T11:48:53.925+01:00?2016-07-11T11:48:53.925+01:00????$????QUEUED?QUEUED????%????0?0
???%???
Long Workflow
Long Workflow?????????(??????????@?????l??Lucene50StoredFieldsFastIndex??????BGش?A?Z(eֿg????????:???????(??????????-!$A?(???????????8??
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/_5.si
=======================================================================
??l??Lucene50SegmentInfo??????BGش?A?Z(eֿg???????????????????
?os?Linux?java.vendor?Oracle Corporation?java.version?1.8.0_91?java.vm.version 25.91-b14?lucene.version?6.1.0?os.arch?amd64?java.runtime.version&1.8.0_91-8u91-b14-0ubuntu4~16.04.1-b14?source?flush
os.version?4.4.0-28-generic timestamp
1468234134219??_5.cfs?_5.cfe?_5.si??Lucene50StoredFieldsFormat.mode
BEST_SPEED?(??????????????
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/test/resources/testinstrepo/write.lock
=======================================================================
=======================================================================
==/Users/mattmann/git/oodt/workflow/src/test/resources/workflow.sql
=======================================================================
DROP TABLE workflows IF EXISTS;
DROP TABLE workflow_condition_map IF EXISTS;
DROP TABLE event_workflow_map IF EXISTS;
DROP TABLE workflow_tasks IF EXISTS;
DROP TABLE workflow_task_map IF EXISTS;
DROP TABLE workflow_instances IF EXISTS;
DROP TABLE workflow_instance_metadata IF EXISTS;
DROP TABLE workflow_conditions IF EXISTS;
DROP TABLE task_condition_map IF EXISTS;
DROP TABLE workflow_task_configuration IF EXISTS;
DROP TABLE workflow_condition_configuration IF EXISTS;
CREATE TABLE workflows
(workflow_id int NOT NULL PRIMARY KEY,
workflow_name varchar(255));
CREATE TABLE workflow_condition_map
(workflow_id int NOT NULL,
workflow_condition_id int NOT NULL,
condition_order int NOT NULL);
CREATE TABLE event_workflow_map
(workflow_id int NOT NULL,
event_name varchar(255) NOT NULL);
CREATE TABLE workflow_tasks
(workflow_task_id int NOT NULL PRIMARY KEY,
workflow_task_name varchar(255),
workflow_task_class varchar(255));
CREATE TABLE workflow_task_map
(workflow_id int NOT NULL,
workflow_task_id int NOT NULL,
task_order int NOT NULL);
CREATE TABLE workflow_instances
(workflow_instance_id int NOT NULL PRIMARY KEY,
workflow_instance_status varchar(255),
workflow_id int NOT NULL,
current_task_id int NOT NULL,
start_date_time varchar(255),
end_date_time varchar(255),
current_task_start_date_time varchar(255),
current_task_end_date_time varchar(255),
priority float NOT NULL,
times_blocked int DEFAULT 0);
CREATE TABLE workflow_instance_metadata
(workflow_instance_id int NOT NULL,