Package | Description |
---|---|
org.apache.oozie | |
org.apache.oozie.servlet |
Modifier and Type | Class and Description |
---|---|
class |
BundleEngineException
Exception thrown by the
BundleEngine . |
class |
CoordinatorEngineException
Exception thrown by the
CoordinatorEngine . |
class |
DagEngineException
Exception thrown by the
DagEngine . |
Modifier and Type | Method and Description |
---|---|
abstract void |
BaseEngine.change(String jobId,
String changeValue)
Change a coordinator job.
|
void |
DagEngine.changeSLA(String id,
String actions,
String dates,
String childIds,
String newParams) |
void |
CoordinatorEngine.changeSLA(String id,
String actions,
String dates,
String childIds,
String newParams) |
void |
BundleEngine.changeSLA(String id,
String actions,
String dates,
String childIds,
String newParams) |
abstract void |
BaseEngine.changeSLA(String id,
String actions,
String dates,
String childIds,
String newParams)
Change SLA properties for job
|
void |
DagEngine.disableSLAAlert(String id,
String actions,
String dates,
String childIds) |
void |
CoordinatorEngine.disableSLAAlert(String id,
String actions,
String dates,
String childIds) |
void |
BundleEngine.disableSLAAlert(String id,
String actions,
String dates,
String childIds) |
abstract void |
BaseEngine.disableSLAAlert(String id,
String actions,
String dates,
String childIds)
Disable SLA alert for job
|
String |
DagEngine.dryRunSubmit(org.apache.hadoop.conf.Configuration conf) |
abstract String |
BaseEngine.dryRunSubmit(org.apache.hadoop.conf.Configuration conf)
Dry run a job; like
BaseEngine.submitJob(org.apache.hadoop.conf.Configuration, boolean) but doesn't actually execute
the job. |
void |
DagEngine.enableSLAAlert(String id,
String actions,
String dates,
String childIds) |
void |
CoordinatorEngine.enableSLAAlert(String id,
String actions,
String dates,
String childIds) |
void |
BundleEngine.enableSLAAlert(String id,
String actions,
String dates,
String childIds) |
abstract void |
BaseEngine.enableSLAAlert(String id,
String actions,
String dates,
String childIds)
Enable SLA alert for job
|
CoordinatorActionBean |
CoordinatorEngine.getCoordAction(String actionId) |
CoordinatorJob |
DagEngine.getCoordJob(String jobId) |
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(String jobId) |
abstract CoordinatorJob |
BaseEngine.getCoordJob(String jobId)
Return the info about a coord job.
|
CoordinatorJob |
DagEngine.getCoordJob(String jobId,
String filter,
int start,
int length,
boolean desc) |
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(String jobId,
String filter,
int offset,
int length,
boolean desc) |
abstract CoordinatorJob |
BaseEngine.getCoordJob(String jobId,
String filter,
int start,
int length,
boolean desc)
Return the info about a coord job with actions subset.
|
String |
CoordinatorEngine.getDefinition(String jobId) |
abstract String |
BaseEngine.getDefinition(String jobId)
Return the a job definition.
|
WorkflowJob |
CoordinatorEngine.getJob(String jobId) |
abstract WorkflowJob |
BaseEngine.getJob(String jobId)
Return the info about a wf job.
|
WorkflowJob |
CoordinatorEngine.getJob(String jobId,
int start,
int length) |
abstract WorkflowJob |
BaseEngine.getJob(String jobId,
int start,
int length)
Return the info about a wf job with actions subset.
|
abstract String |
BaseEngine.getJobIdForExternalId(String externalId)
Return the workflow Job ID for an external ID.
|
abstract String |
BaseEngine.getJobStatus(String jobId)
Return the status for a Job ID
|
WorkflowActionBean |
DagEngine.getWorkflowAction(String actionId) |
List<Map<String,String>> |
DagEngine.getWorkflowActionRetries(String actionId)
Gets the workflow action retries.
|
abstract void |
BaseEngine.kill(String jobId)
Kill a job.
|
void |
CoordinatorEngine.reRun(String jobId,
org.apache.hadoop.conf.Configuration conf)
Deprecated.
|
abstract void |
BaseEngine.reRun(String jobId,
org.apache.hadoop.conf.Configuration conf)
Rerun a job.
|
void |
BundleEngine.reRun(String jobId,
String coordScope,
String dateScope,
boolean refresh,
boolean noCleanup)
Rerun Bundle actions for given rerunType
|
CoordinatorActionInfo |
CoordinatorEngine.reRun(String jobId,
String rerunType,
String scope,
boolean refresh,
boolean noCleanup,
boolean failed,
org.apache.hadoop.conf.Configuration conf)
Rerun coordinator actions for given rerunType
|
abstract void |
BaseEngine.resume(String jobId)
Resume a job.
|
void |
CoordinatorEngine.start(String jobId)
Deprecated.
|
abstract void |
BaseEngine.start(String jobId)
Start a job.
|
void |
BaseEngine.streamAuditLog(String jobId,
Writer writer,
Map<String,String[]> requestParameters)
Stream Audit log of a job.
|
void |
BaseEngine.streamErrorLog(String jobId,
Writer writer,
Map<String,String[]> requestParameters)
Stream error log of a job.
|
protected void |
CoordinatorEngine.streamJobLog(XLogStreamer logStreamer,
String jobId,
Writer writer) |
protected abstract void |
BaseEngine.streamJobLog(XLogStreamer logStreamer,
String jobId,
Writer writer)
Stream job log.
|
void |
CoordinatorEngine.streamLog(String jobId,
String logRetrievalScope,
String logRetrievalType,
Writer writer,
Map<String,String[]> requestParameters)
Add list of actions to the filter based on conditions
|
void |
BaseEngine.streamLog(String jobId,
Writer writer,
Map<String,String[]> requestParameters)
Stream the log of a job.
|
abstract String |
BaseEngine.submitJob(org.apache.hadoop.conf.Configuration conf,
boolean startJob)
Submit a job.
|
abstract void |
BaseEngine.suspend(String jobId)
Suspend a job.
|
Modifier and Type | Method and Description |
---|---|
protected JsonBean |
V1JobServlet.getCoordinatorJob(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response)
Get coord job info
|
protected JsonBean |
V1JobServlet.getJob(javax.servlet.http.HttpServletRequest request,
javax.servlet.http.HttpServletResponse response) |
Copyright © 2018 Apache Software Foundation. All rights reserved.