Package | Description |
---|---|
net.sourceforge.seqware.pipeline.workflowV2.engine.oozie.object |
Implementation of workflow steps for Oozie.
|
net.sourceforge.seqware.pipeline.workflowV2.model |
Classes that implement the tasks within workflows.
|
Modifier and Type | Field and Description |
---|---|
protected AbstractJob |
OozieJob.jobObj |
Modifier and Type | Method and Description |
---|---|
AbstractJob |
OozieJob.getJobObject() |
Constructor and Description |
---|
BatchedOozieBashJob(AbstractJob job,
String name,
String oozie_working_dir,
boolean useSge,
File seqwareJar,
String threadsSgeParamFormat,
String maxMemorySgeParamFormat,
StringTruncator truncator) |
BatchedOozieProvisionFileJob(AbstractJob job,
String name,
String oozie_working_dir,
boolean useSge,
File seqwareJar,
String threadsSgeParamFormat,
String maxMemorySgeParamFormat,
StringTruncator truncator) |
OozieBashJob(AbstractJob job,
String name,
String oozie_working_dir,
boolean useSge,
File seqwareJar,
String threadsSgeParamFormat,
String maxMemorySgeParamFormat,
StringTruncator truncator) |
OozieJob(AbstractJob job,
String longName,
String oozie_working_dir,
boolean useSge,
File seqwareJar,
String threadsSgeParamFormat,
String maxMemorySgeParamFormat,
StringTruncator truncator) |
OozieProvisionFileJob(AbstractJob job,
SqwFile file,
String name,
String oozie_working_dir,
boolean useSge,
File seqwareJar,
String slotsSgeParamFormat,
String maxMemorySgeParamFormat,
StringTruncator truncator) |
Modifier and Type | Class and Description |
---|---|
class |
BashJob |
class |
JavaJob |
class |
JavaSeqwareModuleJob |
class |
JobBatch |
class |
PerlJob |
Modifier and Type | Method and Description |
---|---|
AbstractJob |
AbstractJob.setMaxMemory(String mem) |
AbstractJob |
JobBatch.setThreads(int count) |
AbstractJob |
AbstractJob.setThreads(int count) |
Modifier and Type | Method and Description |
---|---|
List<AbstractJob> |
Workflow.getJobs()
get all jobs in current workflow
|
Modifier and Type | Method and Description |
---|---|
void |
Workflow.addJobs(AbstractJob job)
add job to the workflow
|
void |
AbstractJob.addParent(AbstractJob parent)
add a parent
|
Copyright © 2015 SeqWare. All rights reserved.