io.druid.indexing.overlord

Class ZkWorker

java.lang.Object

io.druid.indexing.overlord.ZkWorker

All Implemented Interfaces:

Closeable, AutoCloseable

public class ZkWorker
extends Object
implements Closeable

Holds information about a worker and a listener for task status changes associated with the worker.

Constructor Summary

Constructors

Constructor and Description
ZkWorker(Worker worker, org.apache.curator.framework.recipes.cache.PathChildrenCache statusCache, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
void	addListener(org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)
void	close()
Set<String>	getAvailabilityGroups()
int	getCountinouslyFailedTasksCount()
int	getCurrCapacityUsed()
org.joda.time.DateTime	getLastCompletedTaskTime()
Collection<String>	getRunningTaskIds()
Map<String,TaskAnnouncement>	getRunningTasks()
Worker	getWorker()
void	incrementCountinouslyFailedTasksCount()
boolean	isRunningTask(String taskId)
boolean	isValidVersion(String minVersion)
void	resetCountinouslyFailedTasksCount()
void	setLastCompletedTaskTime(org.joda.time.DateTime completedTaskTime)
void	setWorker(Worker newWorker)
void	start()
ImmutableWorkerInfo	toImmutable()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ZkWorker

public ZkWorker(Worker worker,
                org.apache.curator.framework.recipes.cache.PathChildrenCache statusCache,
                com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

addListener

public void addListener(org.apache.curator.framework.recipes.cache.PathChildrenCacheListener listener)

getWorker

public Worker getWorker()

getRunningTaskIds

public Collection<String> getRunningTaskIds()

getRunningTasks

public Map<String,TaskAnnouncement> getRunningTasks()

getCurrCapacityUsed

public int getCurrCapacityUsed()

getAvailabilityGroups

public Set<String> getAvailabilityGroups()

getLastCompletedTaskTime

public org.joda.time.DateTime getLastCompletedTaskTime()

isRunningTask

public boolean isRunningTask(String taskId)

isValidVersion

public boolean isValidVersion(String minVersion)

setWorker

public void setWorker(Worker newWorker)

setLastCompletedTaskTime

public void setLastCompletedTaskTime(org.joda.time.DateTime completedTaskTime)

toImmutable

public ImmutableWorkerInfo toImmutable()

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

getCountinouslyFailedTasksCount

public int getCountinouslyFailedTasksCount()

resetCountinouslyFailedTasksCount

public void resetCountinouslyFailedTasksCount()

incrementCountinouslyFailedTasksCount

public void incrementCountinouslyFailedTasksCount()

toString

public String toString()

Overrides:

toString in class Object