Uses of Class
io.druid.indexing.overlord.RemoteTaskRunnerWorkItem

Packages that use RemoteTaskRunnerWorkItem

Package	Description
io.druid.indexing.overlord
io.druid.indexing.overlord.autoscaling

Uses of RemoteTaskRunnerWorkItem in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return RemoteTaskRunnerWorkItem

Modifier and Type	Method and Description
RemoteTaskRunnerWorkItem	RemoteTaskRunnerWorkQueue.put(String s, RemoteTaskRunnerWorkItem taskRunnerWorkItem)
RemoteTaskRunnerWorkItem	RemoteTaskRunnerWorkItem.withQueueInsertionTime(org.joda.time.DateTime time)
RemoteTaskRunnerWorkItem	RemoteTaskRunnerWorkItem.withWorker(Worker theWorker)

Methods in io.druid.indexing.overlord that return types with arguments of type RemoteTaskRunnerWorkItem

Modifier and Type	Method and Description
Collection<RemoteTaskRunnerWorkItem>	RemoteTaskRunner.getKnownTasks()
Collection<RemoteTaskRunnerWorkItem>	RemoteTaskRunner.getPendingTasks()
Collection<RemoteTaskRunnerWorkItem>	RemoteTaskRunner.getRunningTasks()

Methods in io.druid.indexing.overlord with parameters of type RemoteTaskRunnerWorkItem

Modifier and Type	Method and Description
RemoteTaskRunnerWorkItem	RemoteTaskRunnerWorkQueue.put(String s, RemoteTaskRunnerWorkItem taskRunnerWorkItem)

Uses of RemoteTaskRunnerWorkItem in io.druid.indexing.overlord.autoscaling

Method parameters in io.druid.indexing.overlord.autoscaling with type arguments of type RemoteTaskRunnerWorkItem

Modifier and Type	Method and Description
boolean	SimpleResourceManagementStrategy.doProvision(Collection<RemoteTaskRunnerWorkItem> pendingTasks, Collection<ZkWorker> zkWorkers)
boolean	ResourceManagementStrategy.doProvision(Collection<RemoteTaskRunnerWorkItem> runningTasks, Collection<ZkWorker> zkWorkers)
boolean	SimpleResourceManagementStrategy.doTerminate(Collection<RemoteTaskRunnerWorkItem> pendingTasks, Collection<ZkWorker> zkWorkers)
boolean	ResourceManagementStrategy.doTerminate(Collection<RemoteTaskRunnerWorkItem> runningTasks, Collection<ZkWorker> zkWorkers)