org.apache.oozie.servlet

Class V1JobsServlet

java.lang.Object

javax.servlet.GenericServlet

javax.servlet.http.HttpServlet

org.apache.oozie.servlet.JsonRestServlet

org.apache.oozie.servlet.BaseJobsServlet

org.apache.oozie.servlet.V1JobsServlet

All Implemented Interfaces:

Serializable, javax.servlet.Servlet, javax.servlet.ServletConfig

public class V1JobsServlet
extends BaseJobsServlet

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.servlet.JsonRestServlet

JsonRestServlet.ParameterInfo, JsonRestServlet.ResourceInfo

Field Summary

Fields inherited from class org.apache.oozie.servlet.JsonRestServlet

AUDIT_ERROR_CODE, AUDIT_ERROR_MESSAGE, AUDIT_HTTP_STATUS_CODE, AUDIT_OPERATION, AUDIT_PARAM, AUTH_TOKEN, INSTRUMENTATION_GROUP, TEXT_UTF8, UNDEF, USER_NAME, XML_UTF8

Constructor Summary

Constructors

Constructor and Description
V1JobsServlet()

Method Summary

Modifier and Type	Method and Description
protected org.json.simple.JSONObject	getJobIdForExternalId(javax.servlet.http.HttpServletRequest request, String externalId) v1 service implementation to get a JSONObject representation of a job from its external ID
protected org.json.simple.JSONObject	getJobs(javax.servlet.http.HttpServletRequest request) v1 service implementation to get a list of workflows, coordinators, or bundles, with filtering or interested windows embedded in the request object
protected org.json.simple.JSONObject	killJobs(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) service implementation to bulk kill jobs
protected org.json.simple.JSONObject	resumeJobs(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) service implementation to bulk resume jobs
protected org.json.simple.JSONObject	submitJob(javax.servlet.http.HttpServletRequest request, org.apache.hadoop.conf.Configuration conf) v1 service implementation to submit a job, either workflow or coordinator
protected org.json.simple.JSONObject	suspendJobs(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response) service implementation to bulk suspend jobs

Methods inherited from class org.apache.oozie.servlet.BaseJobsServlet

doGet, doPost, doPut

Methods inherited from class org.apache.oozie.servlet.JsonRestServlet

addCron, getContentType, getProxyUser, getResourceName, getUser, incrCounter, init, sendErrorResponse, sendJsonResponse, sendJsonResponse, service, setAllowSafeModeChanges, setLogInfo, startCron, stopCron, validateContentType, validateRestUrl

Methods inherited from class javax.servlet.http.HttpServlet

doDelete, doHead, doOptions, doTrace, getLastModified, service

Methods inherited from class javax.servlet.GenericServlet

destroy, getInitParameter, getInitParameterNames, getServletConfig, getServletContext, getServletInfo, getServletName, init, log, log

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

V1JobsServlet

public V1JobsServlet()

Method Detail

submitJob

protected org.json.simple.JSONObject submitJob(javax.servlet.http.HttpServletRequest request,
                                               org.apache.hadoop.conf.Configuration conf)
                                        throws XServletException,
                                               IOException

v1 service implementation to submit a job, either workflow or coordinator

Returns:

JSONObject of job id

Throws:

XServletException

IOException

getJobIdForExternalId

protected org.json.simple.JSONObject getJobIdForExternalId(javax.servlet.http.HttpServletRequest request,
                                                           String externalId)
                                                    throws XServletException,
                                                           IOException

v1 service implementation to get a JSONObject representation of a job from its external ID

Returns:

JSONObject for the requested job

Throws:

XServletException

IOException

getJobs

protected org.json.simple.JSONObject getJobs(javax.servlet.http.HttpServletRequest request)
                                      throws XServletException,
                                             IOException

v1 service implementation to get a list of workflows, coordinators, or bundles, with filtering or interested windows embedded in the request object

Returns:

JSONObject of the requested jobs

Throws:

XServletException

IOException

killJobs

protected org.json.simple.JSONObject killJobs(javax.servlet.http.HttpServletRequest request,
                                              javax.servlet.http.HttpServletResponse response)
                                       throws XServletException,
                                              IOException

service implementation to bulk kill jobs

Parameters:

request -

response -

Returns:

bulkModifyJobs implementation to bulk kill jobs

Throws:

XServletException

IOException

suspendJobs

protected org.json.simple.JSONObject suspendJobs(javax.servlet.http.HttpServletRequest request,
                                                 javax.servlet.http.HttpServletResponse response)
                                          throws XServletException,
                                                 IOException

service implementation to bulk suspend jobs

Parameters:

request -

response -

Returns:

bulkModifyJobs implementation to bulk suspend jobs

Throws:

XServletException

IOException

resumeJobs

protected org.json.simple.JSONObject resumeJobs(javax.servlet.http.HttpServletRequest request,
                                                javax.servlet.http.HttpServletResponse response)
                                         throws XServletException,
                                                IOException

service implementation to bulk resume jobs

Parameters:

request -

response -

Returns:

bulkModifyJobs implementation to bulk resume jobs

Throws:

XServletException

IOException