io.druid.indexing.worker.executor

Class ExecutorLifecycle

java.lang.Object

io.druid.indexing.worker.executor.ExecutorLifecycle

public class ExecutorLifecycle
extends Object

Encapsulates the lifecycle of a task executor. Loads one task, runs it, writes its status, and all the while monitors its parent process.

Constructor Summary

Constructors

Constructor and Description
ExecutorLifecycle(ExecutorLifecycleConfig taskExecutorConfig, TaskConfig taskConfig, TaskActionClientFactory taskActionClientFactory, TaskRunner taskRunner, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
void	join()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutorLifecycle

@Inject
public ExecutorLifecycle(ExecutorLifecycleConfig taskExecutorConfig,
                                 TaskConfig taskConfig,
                                 TaskActionClientFactory taskActionClientFactory,
                                 TaskRunner taskRunner,
                                 com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

start

public void start()
           throws InterruptedException

Throws:

InterruptedException

join

public void join()

stop

public void stop()
          throws Exception

Throws:

Exception