io.druid.indexing.overlord

Class ThreadPoolTaskRunner

java.lang.Object

io.druid.indexing.overlord.ThreadPoolTaskRunner

All Implemented Interfaces:

TaskRunner, QuerySegmentWalker

public class ThreadPoolTaskRunner
extends Object
implements TaskRunner, QuerySegmentWalker

Runs tasks in a JVM thread using an ExecutorService.

Constructor Summary

Constructors

Constructor and Description
ThreadPoolTaskRunner(TaskToolboxFactory toolboxFactory)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<TaskRunnerWorkItem>	getKnownTasks()
Collection<TaskRunnerWorkItem>	getPendingTasks()
<T> QueryRunner<T>	getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals) Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.
<T> QueryRunner<T>	getQueryRunnerForSegments(Query<T> query, Iterable<io.druid.query.SegmentDescriptor> specs) Gets the Queryable for a given list of SegmentSpecs.
Collection<TaskRunnerWorkItem>	getRunningTasks()
Collection<ZkWorker>	getWorkers()
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	run(Task task) Run a task.
void	shutdown(String taskid) Inform the task runner it can clean up any resources associated with a task.
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolTaskRunner

@Inject
public ThreadPoolTaskRunner(TaskToolboxFactory toolboxFactory)

Method Detail

stop

public void stop()

run

public com.google.common.util.concurrent.ListenableFuture<TaskStatus> run(Task task)

Description copied from interface: TaskRunner

Run a task. The returned status should be some kind of completed status.

Specified by:

run in interface TaskRunner

Parameters:

task - task to run

Returns:

task status, eventually

shutdown

public void shutdown(String taskid)

Description copied from interface: TaskRunner

Inform the task runner it can clean up any resources associated with a task. This implies shutdown of any currently-running tasks.

Specified by:

shutdown in interface TaskRunner

Parameters:

taskid - task ID to clean up resources for

getRunningTasks

public Collection<TaskRunnerWorkItem> getRunningTasks()

Specified by:

getRunningTasks in interface TaskRunner

getPendingTasks

public Collection<TaskRunnerWorkItem> getPendingTasks()

Specified by:

getPendingTasks in interface TaskRunner

getKnownTasks

public Collection<TaskRunnerWorkItem> getKnownTasks()

Specified by:

getKnownTasks in interface TaskRunner

getWorkers

public Collection<ZkWorker> getWorkers()

Specified by:

getWorkers in interface TaskRunner

getQueryRunnerForIntervals

public <T> QueryRunner<T> getQueryRunnerForIntervals(Query<T> query,
                                            Iterable<org.joda.time.Interval> intervals)

Description copied from interface: QuerySegmentWalker

Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.

Specified by:

getQueryRunnerForIntervals in interface QuerySegmentWalker

Type Parameters:

T - query result type

Parameters:

query - the query to find a Queryable for

intervals - the intervals to find a Queryable for

Returns:

a Queryable object that represents the interval

getQueryRunnerForSegments

public <T> QueryRunner<T> getQueryRunnerForSegments(Query<T> query,
                                           Iterable<io.druid.query.SegmentDescriptor> specs)

Description copied from interface: QuerySegmentWalker

Gets the Queryable for a given list of SegmentSpecs.

Specified by:

getQueryRunnerForSegments in interface QuerySegmentWalker

Type Parameters:

T - the query result type

Parameters:

query - the query to return a Queryable for

specs - the list of SegmentSpecs to find a Queryable for

Returns:

the Queryable object with the given SegmentSpecs