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

Methods

Modifier and Type	Method and Description
void	announceTaskAnnouncement(TaskAnnouncement announcement)
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	makePathIfNotExisting(String path, org.apache.zookeeper.CreateMode mode, Object data)
void	start()
void	stop()
void	unannounceTask(String taskId)
void	updateAnnouncement(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

makePathIfNotExisting

public void makePathIfNotExisting(String path,
                         org.apache.zookeeper.CreateMode mode,
                         Object data)
                           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()

unannounceTask

public void unannounceTask(String taskId)

announceTaskAnnouncement

public void announceTaskAnnouncement(TaskAnnouncement announcement)

updateAnnouncement

public void updateAnnouncement(TaskAnnouncement announcement)

getAnnouncements

public List<TaskAnnouncement> getAnnouncements()

updateWorkerAnnouncement

public void updateWorkerAnnouncement(Worker newWorker)
                              throws Exception

Throws:

Exception