org.apache.ambari.server.state.scheduler

Class BatchRequestJob

java.lang.Object

org.apache.ambari.server.scheduler.AbstractLinearExecutionJob

org.apache.ambari.server.state.scheduler.BatchRequestJob

All Implemented Interfaces:

ExecutionJob, org.quartz.Job

@PersistJobDataAfterExecution
 @DisallowConcurrentExecution
public class BatchRequestJob
extends AbstractLinearExecutionJob

Field Summary

Fields

Modifier and Type	Field and Description
static String	BATCH_REQUEST_BATCH_ID_KEY
static String	BATCH_REQUEST_CLUSTER_NAME_KEY
static String	BATCH_REQUEST_EXECUTION_ID_KEY
static String	BATCH_REQUEST_FAILED_TASKS_IN_CURRENT_BATCH_KEY
static String	BATCH_REQUEST_FAILED_TASKS_KEY
static String	BATCH_REQUEST_TOTAL_TASKS_KEY

Fields inherited from class org.apache.ambari.server.scheduler.AbstractLinearExecutionJob

executionScheduleManager

Fields inherited from interface org.apache.ambari.server.scheduler.ExecutionJob

LINEAR_EXECUTION_JOB_GROUP, LINEAR_EXECUTION_TRIGGER_GROUP, NEXT_EXECUTION_JOB_GROUP_KEY, NEXT_EXECUTION_JOB_NAME_KEY, NEXT_EXECUTION_SEPARATION_SECONDS

Constructor Summary

Constructors

Constructor and Description
BatchRequestJob(ExecutionScheduleManager executionScheduleManager, long statusCheckInterval)

Method Summary

Modifier and Type	Method and Description
protected void	doWork(Map<String,Object> properties) Do the actual work of the fired job.
protected void	finalizeExecution(Map<String,Object> properties)

Methods inherited from class org.apache.ambari.server.scheduler.AbstractLinearExecutionJob

execute

Methods inherited from class java.lang.Object

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

Field Detail

BATCH_REQUEST_EXECUTION_ID_KEY

public static final String BATCH_REQUEST_EXECUTION_ID_KEY

See Also:

Constant Field Values

BATCH_REQUEST_BATCH_ID_KEY

public static final String BATCH_REQUEST_BATCH_ID_KEY

See Also:

Constant Field Values

BATCH_REQUEST_CLUSTER_NAME_KEY

public static final String BATCH_REQUEST_CLUSTER_NAME_KEY

See Also:

Constant Field Values

BATCH_REQUEST_FAILED_TASKS_KEY

public static final String BATCH_REQUEST_FAILED_TASKS_KEY

See Also:

Constant Field Values

BATCH_REQUEST_FAILED_TASKS_IN_CURRENT_BATCH_KEY

public static final String BATCH_REQUEST_FAILED_TASKS_IN_CURRENT_BATCH_KEY

See Also:

Constant Field Values

BATCH_REQUEST_TOTAL_TASKS_KEY

public static final String BATCH_REQUEST_TOTAL_TASKS_KEY

See Also:

Constant Field Values

Constructor Detail

BatchRequestJob

@Inject
public BatchRequestJob(ExecutionScheduleManager executionScheduleManager,
                               long statusCheckInterval)

Method Detail

doWork

protected void doWork(Map<String,Object> properties)
               throws org.apache.ambari.server.AmbariException

Description copied from class: AbstractLinearExecutionJob

Do the actual work of the fired job.

Specified by:

doWork in class AbstractLinearExecutionJob

Throws:

org.apache.ambari.server.AmbariException

finalizeExecution

protected void finalizeExecution(Map<String,Object> properties)
                          throws org.apache.ambari.server.AmbariException

Specified by:

finalizeExecution in class AbstractLinearExecutionJob

Throws:

org.apache.ambari.server.AmbariException