Package | Description |
---|---|
alluxio.job.meta | |
alluxio.job.wire | |
alluxio.master.job |
Modifier and Type | Method and Description |
---|---|
TaskInfo |
JobInfo.getTaskInfo(int taskId) |
Modifier and Type | Method and Description |
---|---|
List<TaskInfo> |
JobInfo.getTaskInfoList() |
Modifier and Type | Method and Description |
---|---|
void |
JobInfo.setTaskInfo(int 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(byte[] result) |
TaskInfo |
TaskInfo.setStatus(Status status) |
TaskInfo |
TaskInfo.setTaskId(int taskId) |
Modifier and Type | Method and Description |
---|---|
List<TaskInfo> |
JobInfo.getTaskInfoList() |
Modifier and Type | Method and Description |
---|---|
void |
JobInfo.setTaskInfoList(List<TaskInfo> taskInfoList) |
Modifier and Type | Method and Description |
---|---|
static TaskInfo |
ProtoUtils.fromProto(Job.TaskInfo taskInfo) |
Modifier and Type | Method and Description |
---|---|
static Job.TaskInfo |
ProtoUtils.toProto(TaskInfo taskInfo) |
Modifier and Type | Method and Description |
---|---|
void |
JobCoordinator.updateTasks(List<TaskInfo> taskInfoList)
Updates internal status with given tasks.
|
List<JobCommand> |
JobMaster.workerHeartbeat(long workerId,
List<TaskInfo> taskInfoList)
Updates the tasks' status when a worker periodically heartbeats with the master, and sends the
commands for the worker to execute.
|
Copyright © 2023. All Rights Reserved.