alluxio.master.job.plan

Class PlanCoordinator

java.lang.Object

alluxio.master.job.plan.PlanCoordinator

@ThreadSafe
public final class PlanCoordinator
extends Object

A job coordinator that coordinates the distributed task execution on the worker nodes.

Method Summary

Modifier and Type	Method and Description
void	cancel() Cancels the current job.
static PlanCoordinator	create(CommandManager commandManager, JobServerContext jobServerContext, List<WorkerInfo> workerInfoList, Long jobId, JobConfig jobConfig, java.util.function.Consumer<PlanInfo> statusChangeCallback) Creates a new instance of the PlanCoordinator.
boolean	equals(Object o)
void	failTasksForWorker(long workerId) Fails any incomplete tasks being run on the specified worker.
long	getJobId()
PlanInfo	getPlanInfoWire(boolean verbose)
int	hashCode()
boolean	isJobFinished()
void	setJobAsFailed(String errorType, String errorMessage) Sets the job as failed with given error message.
void	updateTasks(List<TaskInfo> taskInfoList) Updates internal status with given tasks.

Methods inherited from class java.lang.Object

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

Method Detail

create

public static PlanCoordinator create(CommandManager commandManager,
                                     JobServerContext jobServerContext,
                                     List<WorkerInfo> workerInfoList,
                                     Long jobId,
                                     JobConfig jobConfig,
                                     java.util.function.Consumer<PlanInfo> statusChangeCallback)
                              throws JobDoesNotExistException

Creates a new instance of the PlanCoordinator.

Parameters:

commandManager - the command manager

jobServerContext - the context with information used to select executors

workerInfoList - the list of workers to use

jobId - the job Id

jobConfig - configuration for the job

statusChangeCallback - Callback to be called for status changes on the job

Returns:

the created coordinator

Throws:

JobDoesNotExistException - when the job definition doesn't exist

cancel

public void cancel()

Cancels the current job.

updateTasks

public void updateTasks(List<TaskInfo> taskInfoList)

Updates internal status with given tasks.

Parameters:

taskInfoList - List of @TaskInfo instances to update

isJobFinished

public boolean isJobFinished()

Returns:

true if the job is finished

getJobId

public long getJobId()

Returns:

the id corresponding to the job

setJobAsFailed

public void setJobAsFailed(String errorType,
                           String errorMessage)

Sets the job as failed with given error message.

Parameters:

errorType - Error type to set for failure

errorMessage - Error message to set for failure

failTasksForWorker

public void failTasksForWorker(long workerId)

Fails any incomplete tasks being run on the specified worker.

Parameters:

workerId - the id of the worker to fail tasks for

getPlanInfoWire

public PlanInfo getPlanInfoWire(boolean verbose)

Parameters:

verbose - whether the output should be verbose or not

Returns:

the on the wire job info for the job being coordinated

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object