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)
ImmutableWorkerInfo(Worker worker, int currCapacityUsed, Set<String> availabilityGroups, Collection<String> runningTasks, org.joda.time.DateTime lastCompletedTaskTime, org.joda.time.DateTime blacklistedUntil)

Method Summary

Modifier and Type	Method and Description
boolean	canRunTask(Task task)
boolean	equals(Object o)
Set<String>	getAvailabilityGroups()
int	getAvailableCapacity()
org.joda.time.DateTime	getBlacklistedUntil()
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,
                           @Nullable
                           org.joda.time.DateTime blacklistedUntil)

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()

getAvailableCapacity

public int getAvailableCapacity()

getRunningTasks

public Set<String> getRunningTasks()

getLastCompletedTaskTime

public org.joda.time.DateTime getLastCompletedTaskTime()

getBlacklistedUntil

public org.joda.time.DateTime getBlacklistedUntil()

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