io.druid.indexing.overlord

Class TaskMaster

java.lang.Object

io.druid.indexing.overlord.TaskMaster

public class TaskMaster
extends Object

Encapsulates the indexer leadership lifecycle.

Constructor Summary

Constructors

Constructor and Description

TaskMaster(TaskQueueConfig taskQueueConfig, TaskLockbox taskLockbox, TaskStorage taskStorage, TaskActionClientFactory taskActionClientFactory, DruidNode node, ZkPathsConfig zkPaths, TaskRunnerFactory runnerFactory, ResourceManagementSchedulerFactory managementSchedulerFactory, org.apache.curator.framework.CuratorFramework curator, ServiceAnnouncer serviceAnnouncer, com.metamx.emitter.service.ServiceEmitter emitter)

Method Summary

Methods

Modifier and Type	Method and Description
String	getLeader()
com.google.common.base.Optional<ResourceManagementScheduler>	getResourceManagementScheduler()
com.google.common.base.Optional<TaskActionClient>	getTaskActionClient(Task task)
com.google.common.base.Optional<TaskQueue>	getTaskQueue()
com.google.common.base.Optional<TaskRunner>	getTaskRunner()
boolean	isLeading()
void	start() Starts waiting for leadership.
void	stop() Stops forever (not just this particular leadership session).

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskMaster

@Inject
public TaskMaster(TaskQueueConfig taskQueueConfig,
                 TaskLockbox taskLockbox,
                 TaskStorage taskStorage,
                 TaskActionClientFactory taskActionClientFactory,
                 DruidNode node,
                 ZkPathsConfig zkPaths,
                 TaskRunnerFactory runnerFactory,
                 ResourceManagementSchedulerFactory managementSchedulerFactory,
                 org.apache.curator.framework.CuratorFramework curator,
                 ServiceAnnouncer serviceAnnouncer,
                 com.metamx.emitter.service.ServiceEmitter emitter)

Method Detail

start

public void start()

Starts waiting for leadership. Should only be called once throughout the life of the program.

stop

public void stop()

Stops forever (not just this particular leadership session). Should only be called once throughout the life of the program.

isLeading

public boolean isLeading()

getLeader

public String getLeader()

getTaskRunner

public com.google.common.base.Optional<TaskRunner> getTaskRunner()

getTaskQueue

public com.google.common.base.Optional<TaskQueue> getTaskQueue()

getTaskActionClient

public com.google.common.base.Optional<TaskActionClient> getTaskActionClient(Task task)

getResourceManagementScheduler

public com.google.common.base.Optional<ResourceManagementScheduler> getResourceManagementScheduler()