org.apache.ambari.server.api.services

Class WorkflowService

java.lang.Object

org.apache.ambari.server.api.services.BaseService

org.apache.ambari.server.api.services.WorkflowService

public class WorkflowService
extends BaseService

Service responsible for workflow resource requests.

Field Summary

Fields inherited from class org.apache.ambari.server.api.services.BaseService

DATA_TYPE_INT, DATA_TYPE_STRING, DEFAULT_FROM, DEFAULT_PAGE_SIZE, FIELDS_SEPARATOR, MEDIA_TYPE_TEXT_CSV_TYPE, MSG_CLUSTER_NOT_FOUND, MSG_CLUSTER_OR_HOST_NOT_FOUND, MSG_INVALID_ARGUMENTS, MSG_INVALID_REQUEST, MSG_NOT_AUTHENTICATED, MSG_PERMISSION_DENIED, MSG_REQUEST_ACCEPTED, MSG_RESOURCE_ALREADY_EXISTS, MSG_RESOURCE_NOT_FOUND, MSG_SERVER_ERROR, MSG_SUCCESSFUL_OPERATION, MSG_VIEW_NOT_FOUND, PARAM_TYPE_BODY, PARAM_TYPE_QUERY, QUERY_FIELDS, QUERY_FILTER_DESCRIPTION, QUERY_FROM, QUERY_FROM_DESCRIPTION, QUERY_FROM_VALUES, QUERY_PAGE_SIZE, QUERY_PAGE_SIZE_DESCRIPTION, QUERY_PREDICATE, QUERY_PREDICATE_DESCRIPTION, QUERY_SORT, QUERY_SORT_DESCRIPTION, QUERY_TO, QUERY_TO_DESCRIPTION, QUERY_TO_TYPE, QUERY_TO_VALUES, requestAuditLogger, RESPONSE_CONTAINER_LIST

Constructor Summary

Constructors

Constructor and Description
WorkflowService(String clusterName) Constructor.

Method Summary

Modifier and Type	Method and Description
JobService	getJobHandler(String workflowId) Gets the jobs sub-resource.
javax.ws.rs.core.Response	getWorkflow(String body, javax.ws.rs.core.HttpHeaders headers, javax.ws.rs.core.UriInfo ui, String workflowId) Handles: GET /workflows/{workflowId} Get a specific workflow.
javax.ws.rs.core.Response	getWorkflows(String body, javax.ws.rs.core.HttpHeaders headers, javax.ws.rs.core.UriInfo ui) Handles: GET /workflows Get all workflows.

Methods inherited from class org.apache.ambari.server.api.services.BaseService

createResource, getBodyParser, getResultSerializer, getResultSerializer, handleRequest, handleRequest, init

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkflowService

public WorkflowService(String clusterName)

Constructor.

Parameters:

clusterName - cluster id

Method Detail

getWorkflow

public javax.ws.rs.core.Response getWorkflow(String body,
                                             @Context
                                             javax.ws.rs.core.HttpHeaders headers,
                                             @Context
                                             javax.ws.rs.core.UriInfo ui,
                                             String workflowId)

Handles: GET /workflows/{workflowId} Get a specific workflow.

Parameters:

headers - http headers

ui - uri info

workflowId - workflow id

Returns:

workflow instance representation

getWorkflows

public javax.ws.rs.core.Response getWorkflows(String body,
                                              @Context
                                              javax.ws.rs.core.HttpHeaders headers,
                                              @Context
                                              javax.ws.rs.core.UriInfo ui)

Handles: GET /workflows Get all workflows.

Parameters:

headers - http headers

ui - uri info

Returns:

workflow collection resource representation

getJobHandler

public JobService getJobHandler(String workflowId)

Gets the jobs sub-resource.