org.apache.ambari.server.state.scheduler

Class RequestExecutionImpl

java.lang.Object

org.apache.ambari.server.state.scheduler.RequestExecutionImpl

All Implemented Interfaces:

RequestExecution

public class RequestExecutionImpl
extends Object
implements RequestExecution

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.ambari.server.state.scheduler.RequestExecution

RequestExecution.Status

Constructor Summary

Constructors

Constructor and Description
RequestExecutionImpl(Cluster cluster, Batch batch, Schedule schedule, com.google.inject.Injector injector)
RequestExecutionImpl(Cluster cluster, RequestScheduleEntity requestScheduleEntity, com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
RequestScheduleResponse	convertToResponse() Get @RequestScheduleResponse for this Request Execution
RequestScheduleResponse	convertToResponseWithBody() Get response with request body
void	delete() Delete Request Schedule entity
Integer	getAuthenticatedUserId() Get authenticated user
Batch	getBatch() Get the batch of requests along with batch settings
BatchRequest	getBatchRequest(long batchId) Get batch request with specified order id
Collection<Long>	getBatchRequestRequestsIDs(long batchId) Get the requests IDs for the batch
String	getClusterName() Cluster name to which request schedule belongs
String	getCreateTime() Get created time
String	getCreateUser() Get create user
String	getDescription() Get description of the request execution
Long	getId() Primary key of Request Execution
String	getLastExecutionStatus() Get status of the last batch of requests
String	getRequestBody(Long batchId) Get the request body for a batch request
Schedule	getSchedule() Get schedule for the execution
String	getStatus() Get status of schedule
String	getUpdateTime() Get updated time
String	getUpdateUser() Get update user
void	persist() Persist the Request Execution and schedule
void	refresh() Refresh entity from DB.
void	setAuthenticatedUserId(Integer username) Set authenticated user
void	setBatch(Batch batch) Set batch of requests and batch settings
void	setCreateUser(String username) Set create username
void	setDescription(String description) Set request execution description
void	setLastExecutionStatus(String status) Set datetime:status of last request that was executed
void	setSchedule(Schedule schedule) Set schedule for the execution
void	setStatus(RequestExecution.Status status) Set status of the schedule
void	setUpdateUser(String username) Set create username
void	updateBatchRequest(long batchId, BatchRequestResponse batchRequestResponse, boolean statusOnly) Updates batch request data
void	updateStatus(RequestExecution.Status status) Update status and save RequestExecution

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestExecutionImpl

public RequestExecutionImpl(Cluster cluster,
                            Batch batch,
                            @Nullable
                            Schedule schedule,
                            com.google.inject.Injector injector)

RequestExecutionImpl

public RequestExecutionImpl(Cluster cluster,
                            RequestScheduleEntity requestScheduleEntity,
                            com.google.inject.Injector injector)

Method Detail

getId

public Long getId()

Description copied from interface: RequestExecution

Primary key of Request Execution

Specified by:

getId in interface RequestExecution

Returns:

getClusterName

public String getClusterName()

Description copied from interface: RequestExecution

Cluster name to which request schedule belongs

Specified by:

getClusterName in interface RequestExecution

Returns:

getBatch

public Batch getBatch()

Description copied from interface: RequestExecution

Get the batch of requests along with batch settings

Specified by:

getBatch in interface RequestExecution

Returns:

setBatch

public void setBatch(Batch batch)

Description copied from interface: RequestExecution

Set batch of requests and batch settings

Specified by:

setBatch in interface RequestExecution

getSchedule

public Schedule getSchedule()

Description copied from interface: RequestExecution

Get schedule for the execution

Specified by:

getSchedule in interface RequestExecution

Returns:

setSchedule

public void setSchedule(Schedule schedule)

Description copied from interface: RequestExecution

Set schedule for the execution

Specified by:

setSchedule in interface RequestExecution

convertToResponse

public RequestScheduleResponse convertToResponse()

Description copied from interface: RequestExecution

Get @RequestScheduleResponse for this Request Execution

Specified by:

convertToResponse in interface RequestExecution

Returns:

persist

public void persist()

Description copied from interface: RequestExecution

Persist the Request Execution and schedule

Specified by:

persist in interface RequestExecution

refresh

public void refresh()

Description copied from interface: RequestExecution

Refresh entity from DB.

Specified by:

refresh in interface RequestExecution

delete

public void delete()

Description copied from interface: RequestExecution

Delete Request Schedule entity

Specified by:

delete in interface RequestExecution

getStatus

public String getStatus()

Description copied from interface: RequestExecution

Get status of schedule

Specified by:

getStatus in interface RequestExecution

setDescription

public void setDescription(String description)

Description copied from interface: RequestExecution

Set request execution description

Specified by:

setDescription in interface RequestExecution

getDescription

public String getDescription()

Description copied from interface: RequestExecution

Get description of the request execution

Specified by:

getDescription in interface RequestExecution

setStatus

public void setStatus(RequestExecution.Status status)

Description copied from interface: RequestExecution

Set status of the schedule

Specified by:

setStatus in interface RequestExecution

setLastExecutionStatus

public void setLastExecutionStatus(String status)

Description copied from interface: RequestExecution

Set datetime:status of last request that was executed

Specified by:

setLastExecutionStatus in interface RequestExecution

setAuthenticatedUserId

public void setAuthenticatedUserId(Integer username)

Description copied from interface: RequestExecution

Set authenticated user

Specified by:

setAuthenticatedUserId in interface RequestExecution

setCreateUser

public void setCreateUser(String username)

Description copied from interface: RequestExecution

Set create username

Specified by:

setCreateUser in interface RequestExecution

setUpdateUser

public void setUpdateUser(String username)

Description copied from interface: RequestExecution

Set create username

Specified by:

setUpdateUser in interface RequestExecution

getCreateTime

public String getCreateTime()

Description copied from interface: RequestExecution

Get created time

Specified by:

getCreateTime in interface RequestExecution

getUpdateTime

public String getUpdateTime()

Description copied from interface: RequestExecution

Get updated time

Specified by:

getUpdateTime in interface RequestExecution

getAuthenticatedUserId

public Integer getAuthenticatedUserId()

Description copied from interface: RequestExecution

Get authenticated user

Specified by:

getAuthenticatedUserId in interface RequestExecution

getCreateUser

public String getCreateUser()

Description copied from interface: RequestExecution

Get create user

Specified by:

getCreateUser in interface RequestExecution

getUpdateUser

public String getUpdateUser()

Description copied from interface: RequestExecution

Get update user

Specified by:

getUpdateUser in interface RequestExecution

getLastExecutionStatus

public String getLastExecutionStatus()

Description copied from interface: RequestExecution

Get status of the last batch of requests

Specified by:

getLastExecutionStatus in interface RequestExecution

Returns:

convertToResponseWithBody

public RequestScheduleResponse convertToResponseWithBody()

Description copied from interface: RequestExecution

Get response with request body

Specified by:

convertToResponseWithBody in interface RequestExecution

getRequestBody

public String getRequestBody(Long batchId)

Description copied from interface: RequestExecution

Get the request body for a batch request

Specified by:

getRequestBody in interface RequestExecution

getBatchRequestRequestsIDs

public Collection<Long> getBatchRequestRequestsIDs(long batchId)

Description copied from interface: RequestExecution

Get the requests IDs for the batch

Specified by:

getBatchRequestRequestsIDs in interface RequestExecution

getBatchRequest

public BatchRequest getBatchRequest(long batchId)

Description copied from interface: RequestExecution

Get batch request with specified order id

Specified by:

getBatchRequest in interface RequestExecution

updateBatchRequest

public void updateBatchRequest(long batchId,
                               BatchRequestResponse batchRequestResponse,
                               boolean statusOnly)

Description copied from interface: RequestExecution

Updates batch request data

Specified by:

updateBatchRequest in interface RequestExecution

Parameters:

batchId - order id of batch request

statusOnly - true if only status should be updated

updateStatus

public void updateStatus(RequestExecution.Status status)

Description copied from interface: RequestExecution

Update status and save RequestExecution

Specified by:

updateStatus in interface RequestExecution