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 config, TaskActionClientFactory taskActionClientFactory, TaskRunner taskRunner, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Methods

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 config,
                        TaskActionClientFactory taskActionClientFactory,
                        TaskRunner taskRunner,
                        com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

start

public void start()

join

public void join()

stop

public void stop()