io.druid.indexing.worker

Class WorkerCuratorCoordinator

java.lang.Object

io.druid.indexing.worker.WorkerCuratorCoordinator

public class WorkerCuratorCoordinator
extends Object

The CuratorCoordinator provides methods to use Curator. Persistent ZK paths are created on start().

Constructor Summary

Constructors

Constructor and Description
WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, IndexerZkConfig indexerZkConfig, RemoteTaskRunnerConfig config, org.apache.curator.framework.CuratorFramework curatorFramework, Worker worker)

Method Summary

Modifier and Type	Method and Description
List<TaskAnnouncement>	getAnnouncements()
String	getAnnouncementsPathForWorker()
String	getPath(Iterable<String> parts)
String	getStatusPathForId(String statusId)
String	getStatusPathForWorker()
String	getTaskPathForId(String taskId)
String	getTaskPathForWorker()
Worker	getWorker()
void	removeTaskRunZnode(String taskId)
void	start()
void	stop()
void	updateTaskStatusAnnouncement(TaskAnnouncement announcement)
void	updateWorkerAnnouncement(Worker newWorker)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerCuratorCoordinator

@Inject
public WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                        IndexerZkConfig indexerZkConfig,
                                        RemoteTaskRunnerConfig config,
                                        org.apache.curator.framework.CuratorFramework curatorFramework,
                                        Worker worker)

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

getPath

public String getPath(Iterable<String> parts)

getAnnouncementsPathForWorker

public String getAnnouncementsPathForWorker()

getTaskPathForWorker

public String getTaskPathForWorker()

getTaskPathForId

public String getTaskPathForId(String taskId)

getStatusPathForWorker

public String getStatusPathForWorker()

getStatusPathForId

public String getStatusPathForId(String statusId)

getWorker

public Worker getWorker()

removeTaskRunZnode

public void removeTaskRunZnode(String taskId)
                        throws Exception

Throws:

Exception

updateTaskStatusAnnouncement

public void updateTaskStatusAnnouncement(TaskAnnouncement announcement)
                                  throws Exception

Throws:

Exception

getAnnouncements

public List<TaskAnnouncement> getAnnouncements()
                                        throws Exception

Throws:

Exception

updateWorkerAnnouncement

public void updateWorkerAnnouncement(Worker newWorker)
                              throws Exception

Throws:

Exception