alluxio.master.job

Class JobCoordinator

java.lang.Object

alluxio.master.job.JobCoordinator

@ThreadSafe
public final class JobCoordinator
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 JobCoordinator	create(CommandManager commandManager, JobServerContext jobServerContext, List<WorkerInfo> workerInfoList, Long jobId, JobConfig jobConfig, java.util.function.Consumer<JobInfo> statusChangeCallback) Creates a new instance of the JobCoordinator.
boolean	equals(Object o)
void	failTasksForWorker(long workerId) Fails any incomplete tasks being run on the specified worker.
long	getJobId()
JobInfo	getJobInfoWire()
int	hashCode()
boolean	isJobFinished()
void	setJobAsFailed(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 JobCoordinator create(CommandManager commandManager,
                                    JobServerContext jobServerContext,
                                    List<WorkerInfo> workerInfoList,
                                    Long jobId,
                                    JobConfig jobConfig,
                                    java.util.function.Consumer<JobInfo> statusChangeCallback)
                             throws JobDoesNotExistException

Creates a new instance of the JobCoordinator.

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 errorMessage)

Sets the job as failed with given error message.

Parameters:

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

getJobInfoWire

public JobInfo getJobInfoWire()

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