io.druid.indexing.worker

Class WorkerTaskMonitor

java.lang.Object

io.druid.indexing.worker.WorkerTaskMonitor

public class WorkerTaskMonitor
extends Object

The monitor watches ZK at a specified path for new tasks to appear. Upon starting the monitor, a listener will be created that waits for new tasks. Tasks are executed as soon as they are seen. The monitor implements QuerySegmentWalker so tasks can offer up queryable data. This is useful for realtime index tasks.

Constructor Summary

Constructors

Constructor and Description
WorkerTaskMonitor(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, org.apache.curator.framework.CuratorFramework cf, WorkerCuratorCoordinator workerCuratorCoordinator, TaskRunner taskRunner, WorkerConfig workerConfig)

Method Summary

Methods

Modifier and Type	Method and Description
void	start() Register a monitor for new tasks.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerTaskMonitor

@Inject
public WorkerTaskMonitor(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                        org.apache.curator.framework.CuratorFramework cf,
                        WorkerCuratorCoordinator workerCuratorCoordinator,
                        TaskRunner taskRunner,
                        WorkerConfig workerConfig)

Method Detail

start

public void start()

Register a monitor for new tasks. When new tasks appear, the worker node announces a status to indicate it has started the task. When the task is complete, the worker node updates the status. It is up to the coordinator to determine how many tasks are sent to each worker node and cleanup tasks and statuses in ZK accordingly.

stop

public void stop()