ds.granules.interfere.computation

Class ComputationManager

java.lang.Object

ds.granules.interfere.computation.ComputationManager

All Implemented Interfaces:

JobLifecycleObserver

Direct Known Subclasses:

ECGCompManager, EEGCompManager, GzipCompManager, ThoraxCompManager

public abstract class ComputationManager
extends java.lang.Object
implements JobLifecycleObserver

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ComputationManager.ComputationManagerState

Method Summary

Modifier and Type	Method and Description
void	completedExecution(java.lang.String jobId, java.lang.String taskId, TaskLifecycleMetrics metrics) 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 jobId, ProgressTracker inTracker) This method is invoked when all the constituent distributed tasks have finished executing successfully.
void	completedWithErrors(java.lang.String jobId, ProgressTracker tracker) 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	completeJob()
void	deployJob(int inStreamGrp, java.lang.String inDeployStream, boolean inActive)
java.lang.String	getDeployedStream()
ComputationDescription	getDescription()
java.lang.String	getJobID()
ComputationUsage	getPredictedUsage()
ComputationManager.ComputationManagerState	getState()
void	setComputations(GIComputation... inComps)
void	startedExecution(java.lang.String jobId, java.lang.String taskId, TaskLifecycleMetrics metrics) This method is invoked when the first task reports that it has begun execution.
void	terminateJob()

Methods inherited from class java.lang.Object

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

Method Detail

getJobID

public java.lang.String getJobID()

getDescription

public ComputationDescription getDescription()

getPredictedUsage

public ComputationUsage getPredictedUsage()

getDeployedStream

public java.lang.String getDeployedStream()

getState

public ComputationManager.ComputationManagerState getState()

setComputations

public void setComputations(GIComputation... inComps)

deployJob

public void deployJob(int inStreamGrp,
                      java.lang.String inDeployStream,
                      boolean inActive)
               throws DatasetException,
                      CommunicationsException,
                      DeploymentException,
                      MapReduceException,
                      MarshallingException,
                      ComponentException

Throws:

DatasetException

CommunicationsException

DeploymentException

MapReduceException

MarshallingException

ComponentException

completeJob

public void completeJob()

terminateJob

public void terminateJob()
                  throws DeploymentException,
                         CommunicationsException,
                         MarshallingException

Throws:

DeploymentException

CommunicationsException

MarshallingException

completedSuccessfully

public void completedSuccessfully(java.lang.String jobId,
                                  ProgressTracker inTracker)

Description copied from interface: JobLifecycleObserver

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

Specified by:

completedSuccessfully in interface JobLifecycleObserver

Parameters:

jobId - The ID of the Job being reported on

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

completedWithErrors

public void completedWithErrors(java.lang.String jobId,
                                ProgressTracker tracker)

Description copied from interface: JobLifecycleObserver

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.

Specified by:

completedWithErrors in interface JobLifecycleObserver

Parameters:

jobId - The ID of the Job being reported on

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

startedExecution

public void startedExecution(java.lang.String jobId,
                             java.lang.String taskId,
                             TaskLifecycleMetrics metrics)

Description copied from interface: JobLifecycleObserver

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

Specified by:

startedExecution in interface JobLifecycleObserver

Parameters:

jobId - The ID of the Job being reported on

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

metrics - The metrics associated with the task in question.

completedExecution

public void completedExecution(java.lang.String jobId,
                               java.lang.String taskId,
                               TaskLifecycleMetrics metrics)

Description copied from interface: JobLifecycleObserver

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.

Specified by:

completedExecution in interface JobLifecycleObserver

Parameters:

jobId - The ID of the Job being reported on

taskId - The taskId of one of the constituent tasks

metrics - The metrics associated with the task in question.