io.druid.indexing.overlord

Class ImmutableWorkerInfo

java.lang.Object

io.druid.indexing.overlord.ImmutableWorkerInfo

public class ImmutableWorkerInfo
extends Object

A snapshot of a Worker and its current state i.e tasks assigned to that worker.

Constructor Summary

Constructors

Constructor and Description
ImmutableWorkerInfo(Worker worker, int currCapacityUsed, Set<String> availabilityGroups, Collection<String> runningTasks, org.joda.time.DateTime lastCompletedTaskTime)

Method Summary

Modifier and Type	Method and Description
boolean	canRunTask(Task task)
boolean	equals(Object o)
Set<String>	getAvailabilityGroups()
int	getCurrCapacityUsed()
org.joda.time.DateTime	getLastCompletedTaskTime()
Set<String>	getRunningTasks()
Worker	getWorker()
int	hashCode()
boolean	isValidVersion(String minVersion)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ImmutableWorkerInfo

public ImmutableWorkerInfo(Worker worker,
                           int currCapacityUsed,
                           Set<String> availabilityGroups,
                           Collection<String> runningTasks,
                           org.joda.time.DateTime lastCompletedTaskTime)

Method Detail

getWorker

public Worker getWorker()

getCurrCapacityUsed

public int getCurrCapacityUsed()

getAvailabilityGroups

public Set<String> getAvailabilityGroups()

getRunningTasks

public Set<String> getRunningTasks()

getLastCompletedTaskTime

public org.joda.time.DateTime getLastCompletedTaskTime()

isValidVersion

public boolean isValidVersion(String minVersion)

canRunTask

public boolean canRunTask(Task task)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object