alluxio.job.wire

Class JobWorkerHealth

java.lang.Object

alluxio.job.wire.JobWorkerHealth

public class JobWorkerHealth
extends Object

The job worker health information.

Constructor Summary

Constructors

Constructor and Description
JobWorkerHealth(JobWorkerHealth jobWorkerHealth) Constructor from the grpc representation.
JobWorkerHealth(long workerId, List<Double> loadAverage, int taskPoolSize, int numActiveTasks, int unfinishedTasks, String hostname) Default constructor.
JobWorkerHealth(long workerId, List<Double> loadAverage, int taskPoolSize, int numActiveTasks, int unfinishedTasks, String hostname, BuildVersion version) Default constructor.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getHostname()
List<Double>	getLoadAverage() Returns system load average for 1, 5, and 15 minutes.
int	getNumActiveTasks()
int	getTaskPoolSize()
int	getUnfinishedTasks()
BuildVersion	getVersion()
long	getWorkerId()
int	hashCode()
JobWorkerHealth	toProto()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

JobWorkerHealth

public JobWorkerHealth(long workerId,
                       List<Double> loadAverage,
                       int taskPoolSize,
                       int numActiveTasks,
                       int unfinishedTasks,
                       String hostname)

Default constructor.

Parameters:

workerId - the worker id

loadAverage - output of CentralProcessor.getSystemLoadAverage on the worker

taskPoolSize - task pool size

numActiveTasks - number of active tasks in the worker

unfinishedTasks - number of unfinished tasks that the worker has

hostname - hostname of the worker

JobWorkerHealth

public JobWorkerHealth(long workerId,
                       List<Double> loadAverage,
                       int taskPoolSize,
                       int numActiveTasks,
                       int unfinishedTasks,
                       String hostname,
                       BuildVersion version)

Default constructor.

Parameters:

workerId - the worker id

loadAverage - output of CentralProcessor.getSystemLoadAverage on the worker

taskPoolSize - task pool size

numActiveTasks - number of active tasks in the worker

unfinishedTasks - number of unfinished tasks that the worker has

hostname - hostname of the worker

version - the worker's version info

JobWorkerHealth

public JobWorkerHealth(JobWorkerHealth jobWorkerHealth)

Constructor from the grpc representation.

Parameters:

jobWorkerHealth - grpc representation

Method Detail

getWorkerId

public long getWorkerId()

Returns:

the worker id

getLoadAverage

public List<Double> getLoadAverage()

Returns system load average for 1, 5, and 15 minutes. System load average is the sum of runnable entities. See http://oshi.github.io/oshi/apidocs/oshi/hardware/CentralProcessor.html#getSystemLoadAverage

Returns:

the load average for 1, 5, and 15 minutes. negative values if not available

getTaskPoolSize

public int getTaskPoolSize()

Returns:

task pool size

getNumActiveTasks

public int getNumActiveTasks()

Returns:

number of active tasks

getUnfinishedTasks

public int getUnfinishedTasks()

Returns:

the number of unfinished tasks

getHostname

public String getHostname()

Returns:

the worker hostname

getVersion

public BuildVersion getVersion()

Returns:

the worker version info

toProto

public JobWorkerHealth toProto()

Returns:

proto representation of JobWorkerInfo

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object