Package | Description |
---|---|
alluxio.job.plan.meta | |
alluxio.job.wire | |
alluxio.master.job | |
alluxio.master.job.plan | |
alluxio.worker.job.task |
Modifier and Type | Method and Description |
---|---|
TaskInfo |
PlanInfo.getTaskInfo(long taskId) |
Modifier and Type | Method and Description |
---|---|
List<TaskInfo> |
PlanInfo.getTaskInfoList() |
Modifier and Type | Method and Description |
---|---|
void |
PlanInfo.setTaskInfo(long taskId,
TaskInfo taskInfo)
Sets the information of a task.
|
Modifier and Type | Method and Description |
---|---|
TaskInfo |
TaskInfo.setErrorMessage(String errorMessage) |
TaskInfo |
TaskInfo.setJobId(long jobId) |
TaskInfo |
TaskInfo.setResult(Serializable result) |
TaskInfo |
TaskInfo.setStatus(Status status) |
TaskInfo |
TaskInfo.setTaskId(long taskId) |
TaskInfo |
TaskInfo.setWorkerHost(String workerHost) |
Modifier and Type | Method and Description |
---|---|
List<JobCommand> |
JobMaster.workerHeartbeat(JobWorkerHealth jobWorkerHealth,
List<TaskInfo> taskInfoList)
Updates the tasks' status when a worker periodically heartbeats with the master, and sends the
commands for the worker to execute.
|
Modifier and Type | Method and Description |
---|---|
void |
PlanCoordinator.updateTasks(List<TaskInfo> taskInfoList)
Updates internal status with given tasks.
|
Modifier and Type | Method and Description |
---|---|
List<TaskInfo> |
TaskExecutorManager.getAndClearTaskUpdates() |
Modifier and Type | Method and Description |
---|---|
void |
TaskExecutorManager.restoreTaskUpdates(List<TaskInfo> tasks)
Adds the given tasks to the task updates data structure.
|
Copyright © 2023. All Rights Reserved.