io.druid.indexing.overlord

Interface WorkerTaskRunner

All Superinterfaces:

TaskRunner

All Known Implementing Classes:

RemoteTaskRunner

public interface WorkerTaskRunner
extends TaskRunner

Method Summary

Modifier and Type	Method and Description
WorkerTaskRunnerConfig	getConfig()
Collection<Worker>	getLazyWorkers() Return a list of workers who can be reaped by autoscaling
Collection<Task>	getPendingTaskPayloads()
Collection<ImmutableWorkerInfo>	getWorkers() List of known workers who can accept tasks
Collection<Worker>	markWorkersLazy(com.google.common.base.Predicate<ImmutableWorkerInfo> isLazyWorker, int maxWorkers) Check which workers can be marked as lazy

Methods inherited from interface io.druid.indexing.overlord.TaskRunner

getKnownTasks, getPendingTasks, getRunningTasks, getScalingStats, registerListener, restore, run, shutdown, start, stop, unregisterListener

Method Detail

getWorkers

Collection<ImmutableWorkerInfo> getWorkers()

List of known workers who can accept tasks

Returns:

A list of workers who can accept tasks for running

getLazyWorkers

Collection<Worker> getLazyWorkers()

Return a list of workers who can be reaped by autoscaling

Returns:

Workers which can be reaped by autoscaling

markWorkersLazy

Collection<Worker> markWorkersLazy(com.google.common.base.Predicate<ImmutableWorkerInfo> isLazyWorker,
                                   int maxWorkers)

Check which workers can be marked as lazy

Parameters:

isLazyWorker -

maxWorkers -

Returns:

getConfig

WorkerTaskRunnerConfig getConfig()

getPendingTaskPayloads

Collection<Task> getPendingTaskPayloads()