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 selfNode, IndexerZkConfig zkPaths, TaskRunnerFactory runnerFactory, org.apache.curator.framework.CuratorFramework curator, ServiceAnnouncer serviceAnnouncer, CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig, com.metamx.emitter.service.ServiceEmitter emitter, SupervisorManager supervisorManager, OverlordHelperManager overlordHelperManager)

Method Summary

Modifier and Type	Method and Description
String	getLeader()
com.google.common.base.Optional<ScalingStats>	getScalingStats()
com.google.common.base.Optional<SupervisorManager>	getSupervisorManager()
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 selfNode,
                          IndexerZkConfig zkPaths,
                          TaskRunnerFactory runnerFactory,
                          org.apache.curator.framework.CuratorFramework curator,
                          ServiceAnnouncer serviceAnnouncer,
                          CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig,
                          com.metamx.emitter.service.ServiceEmitter emitter,
                          SupervisorManager supervisorManager,
                          OverlordHelperManager overlordHelperManager)

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)

getScalingStats

public com.google.common.base.Optional<ScalingStats> getScalingStats()

getSupervisorManager

public com.google.common.base.Optional<SupervisorManager> getSupervisorManager()