Package | Description |
---|---|
alluxio.client.job | |
alluxio.master.job | |
alluxio.worker.job |
Modifier and Type | Method and Description |
---|---|
List<JobWorkerHealth> |
JobMasterClient.getAllWorkerHealth()
Gets all worker health.
|
List<JobWorkerHealth> |
RetryHandlingJobMasterClient.getAllWorkerHealth() |
Modifier and Type | Method and Description |
---|---|
List<JobWorkerHealth> |
JobMaster.getAllWorkerHealth() |
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 |
---|---|
List<JobCommand> |
RetryHandlingJobMasterClient.heartbeat(JobWorkerHealth jobWorkerHealth,
List<JobInfo> taskInfoList) |
List<JobCommand> |
JobMasterClient.heartbeat(JobWorkerHealth jobWorkerHealth,
List<JobInfo> taskInfoList)
Periodic heartbeats to update the tasks' status from a worker, and returns the commands.
|
Copyright © 2023. All Rights Reserved.