Uses of Class
io.druid.indexing.common.TaskLock

Packages that use TaskLock

Package	Description
io.druid.indexing.common.actions
io.druid.indexing.common.task
io.druid.indexing.overlord

Uses of TaskLock in io.druid.indexing.common.actions

Methods in io.druid.indexing.common.actions that return TaskLock

Modifier and Type	Method and Description
TaskLock	LockAcquireAction.perform(Task task, TaskActionToolbox toolbox)

Methods in io.druid.indexing.common.actions that return types with arguments of type TaskLock

Modifier and Type	Method and Description
com.fasterxml.jackson.core.type.TypeReference<com.google.common.base.Optional<TaskLock>>	LockTryAcquireAction.getReturnTypeReference()
com.fasterxml.jackson.core.type.TypeReference<List<TaskLock>>	LockListAction.getReturnTypeReference()
com.fasterxml.jackson.core.type.TypeReference<TaskLock>	LockAcquireAction.getReturnTypeReference()
com.google.common.base.Optional<TaskLock>	LockTryAcquireAction.perform(Task task, TaskActionToolbox toolbox)
List<TaskLock>	LockListAction.perform(Task task, TaskActionToolbox toolbox)

Uses of TaskLock in io.druid.indexing.common.task

Methods in io.druid.indexing.common.task that return types with arguments of type TaskLock

Modifier and Type	Method and Description
protected Iterable<TaskLock>	AbstractTask.getTaskLocks(TaskToolbox toolbox)

Uses of TaskLock in io.druid.indexing.overlord

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

Modifier and Type	Method and Description
TaskLock	TaskLockbox.lock(Task task, org.joda.time.Interval interval) Acquires a lock on behalf of a task.

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

Modifier and Type	Method and Description
List<TaskLock>	TaskLockbox.findLocksForTask(Task task) Return the currently-active locks for some task.
List<TaskLock>	TaskStorage.getLocks(String taskid) Returns a list of locks for a particular task.
List<TaskLock>	MetadataTaskStorage.getLocks(String taskid)
List<TaskLock>	HeapMemoryTaskStorage.getLocks(String taskid)
com.google.common.base.Optional<TaskLock>	TaskLockbox.tryLock(Task task, org.joda.time.Interval interval) Attempt to lock a task, without removing it from the queue.

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

Modifier and Type	Method and Description
void	TaskStorage.addLock(String taskid, TaskLock taskLock) Persists lock state in the storage facility.
void	MetadataTaskStorage.addLock(String taskid, TaskLock taskLock)
void	HeapMemoryTaskStorage.addLock(String taskid, TaskLock taskLock)
void	TaskStorage.removeLock(String taskid, TaskLock taskLock) Removes lock state from the storage facility.
void	MetadataTaskStorage.removeLock(String taskid, TaskLock taskLockToRemove)
void	HeapMemoryTaskStorage.removeLock(String taskid, TaskLock taskLock)