org.apache.ambari.server.scheduler

Class AbstractLinearExecutionJob

java.lang.Object

org.apache.ambari.server.scheduler.AbstractLinearExecutionJob

All Implemented Interfaces:

ExecutionJob, org.quartz.Job

Direct Known Subclasses:

BatchRequestJob

public abstract class AbstractLinearExecutionJob
extends Object
implements ExecutionJob

Job that knows how to get the job name and group out of the JobDataMap using pre-defined keys (constants) and contains code to schedule the identified job. This abstract Job's implementation of execute() delegates to an abstract template method "doWork()" (where the extending Job class's real work goes) and then it schedules the follow-up job.

Field Summary

Fields

Modifier and Type	Field and Description
protected ExecutionScheduleManager	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
AbstractLinearExecutionJob(ExecutionScheduleManager executionScheduleManager)

Method Summary

Modifier and Type	Method and Description
protected abstract void	doWork(Map<String,Object> properties) Do the actual work of the fired job.
void	execute(org.quartz.JobExecutionContext context) Get the next job id from context and create a trigger to fire the next job.
protected abstract void	finalizeExecution(Map<String,Object> properties)

Methods inherited from class java.lang.Object

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

Field Detail

executionScheduleManager

protected ExecutionScheduleManager executionScheduleManager

Constructor Detail

AbstractLinearExecutionJob

public AbstractLinearExecutionJob(ExecutionScheduleManager executionScheduleManager)

Method Detail

doWork

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

Do the actual work of the fired job.

Parameters:

properties -

Throws:

org.apache.ambari.server.AmbariException

finalizeExecution

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

Throws:

org.apache.ambari.server.AmbariException

execute

public void execute(org.quartz.JobExecutionContext context)
             throws org.quartz.JobExecutionException

Get the next job id from context and create a trigger to fire the next job.

Specified by:

execute in interface org.quartz.Job

Parameters:

context -

Throws:

org.quartz.JobExecutionException