Package | Description |
---|---|
alluxio.cli.fsadmin.report | |
alluxio.client.job | |
alluxio.master.job | |
alluxio.worker.job |
Constructor and Description |
---|
JobServiceOutput(List<JobMasterStatus> allMasterStatus,
List<JobWorkerHealth> allWorkerHealth,
JobServiceSummary jobServiceSummary)
Creates a new instance of
JobServiceOutput . |
Modifier and Type | Method and Description |
---|---|
List<JobWorkerHealth> |
RetryHandlingJobMasterClient.getAllWorkerHealth() |
List<JobWorkerHealth> |
JobMasterClient.getAllWorkerHealth()
Gets all worker health.
|
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.