ds.granules.operation

Interface JobLifecycleObserver

All Known Implementing Classes:

ComputationManager, ECGCompManager, ECGDeployer, EEGCompManager, EEGDeployer, GzipCompManager, InstanceDeployer, RespirationMonitorDeployer, ThoraxCompManager, UpperCaseDeployer, WordCountDeployer

public interface JobLifecycleObserver

JobLifecycleObserver is the interface which needs to be implemented by an entity which wishes to observe the execution of a Job and its constituent tasks. As the job progresses in it's execution phase, the observer is used to report on the highlights -- such as the start and end of a task -- of the job's execution.

Author:

Shrideep Pallickara

Method Summary

Modifier and Type	Method and Description
void	completedExecution(java.lang.String jobIdentifier, java.lang.String taskIdentifier, TaskLifecycleMetrics taskLifecycleMetrics) This method is invoked when a task has completed execution either successfully or due to an abnormal termination or previously issued abort request.
void	completedSuccessfully(java.lang.String jobIdentifier, ProgressTracker progressTracker) This method is invoked when all the constituent distributed tasks have finished executing successfully.
void	completedWithErrors(java.lang.String jobIdentifier, ProgressTracker progressTracker) This method is invoked when we have heard from all the sub-tasks, and one or more errors have been encountered in the execution of constituent tasks.
void	startedExecution(java.lang.String jobIdentifier, java.lang.String taskIdentifier, TaskLifecycleMetrics taskLifecycleMetrics) This method is invoked when the first task reports that it has begun execution.

Method Detail

completedSuccessfully

void completedSuccessfully(java.lang.String jobIdentifier,
                           ProgressTracker progressTracker)

This method is invoked when all the constituent distributed tasks have finished executing successfully.

Parameters:

jobIdentifier - The ID of the Job being reported on

progressTracker - Contains information about the lifecycle metrics associated with the constituent tasks.

completedWithErrors

void completedWithErrors(java.lang.String jobIdentifier,
                         ProgressTracker progressTracker)

This method is invoked when we have heard from all the sub-tasks, and one or more errors have been encountered in the execution of constituent tasks.

Parameters:

jobIdentifier - The ID of the Job being reported on

progressTracker - Contains information about the lifecycle metrics associated with the constituent tasks.

startedExecution

void startedExecution(java.lang.String jobIdentifier,
                      java.lang.String taskIdentifier,
                      TaskLifecycleMetrics taskLifecycleMetrics)

This method is invoked when the first task reports that it has begun execution.

Parameters:

jobIdentifier - The ID of the Job being reported on

taskIdentifier - The taskId of one of the constituent tasks that has started execution.

taskLifecycleMetrics - The metrics associated with the task in question.

completedExecution

void completedExecution(java.lang.String jobIdentifier,
                        java.lang.String taskIdentifier,
                        TaskLifecycleMetrics taskLifecycleMetrics)

This method is invoked when a task has completed execution either successfully or due to an abnormal termination or previously issued abort request. Invoking the taskLifecycleMetrics.getExecutionStatus() method and comparing it to the constants in the metrics, reveals the completion status of the task.

Parameters:

jobIdentifier - The ID of the Job being reported on

taskIdentifier - The taskId of one of the constituent tasks

taskLifecycleMetrics - The metrics associated with the task in question.