Uses of Class
org.apache.oozie.DagEngineException

Packages that use DagEngineException

Package	Description
org.apache.oozie

Uses of DagEngineException in org.apache.oozie

Methods in org.apache.oozie that throw DagEngineException

Modifier and Type	Method and Description
void	DagEngine.change(String jobId, String changeValue)
String	DagEngine.getDefinition(String jobId) Return the a job definition.
String	BaseEngine.getJMSTopicName(String jobId) Return the jms topic name for the job.
WorkflowJob	DagEngine.getJob(String jobId) Return the info about a job.
WorkflowJob	DagEngine.getJob(String jobId, int start, int length) Return the info about a job with actions subset.
String	DagEngine.getJobIdForExternalId(String externalId) Return the workflow Job ID for an external ID.
WorkflowsInfo	DagEngine.getJobs(String filter, int start, int len) Return the info about a set of jobs.
String	DagEngine.getJobStatus(String jobId) Return the status for a Job ID
void	DagEngine.kill(String jobId) Kill a job.
WorkflowsInfo	DagEngine.killJobs(String filter, int start, int len) return the jobs that've been killed
protected Map<String,List<String>>	DagEngine.parseFilter(String filter) Validate a jobs filter.
void	DagEngine.processCallback(String actionId, String externalStatus, Properties actionData) Process an action callback.
void	DagEngine.reRun(String jobId, org.apache.hadoop.conf.Configuration conf) Rerun a job.
void	DagEngine.resume(String jobId) Resume a job.
WorkflowsInfo	DagEngine.resumeJobs(String filter, int start, int len) return the jobs that've been resumed
void	DagEngine.start(String jobId) Start a job.
protected void	DagEngine.streamJobLog(XLogStreamer logStreamer, String jobId, Writer writer)
String	DagEngine.submitHttpJob(org.apache.hadoop.conf.Configuration conf, String jobType) Submit a pig/hive/mapreduce job through HTTP.
String	DagEngine.submitJob(org.apache.hadoop.conf.Configuration conf, boolean startJob) Submit a workflow job.
String	DagEngine.submitJobFromCoordinator(org.apache.hadoop.conf.Configuration conf, String parentId) Submit a workflow through a coordinator.
void	DagEngine.suspend(String jobId) Suspend a job.
WorkflowsInfo	DagEngine.suspendJobs(String filter, int start, int len) return the jobs that've been suspended