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

Packages that use TaskLock

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

Uses of TaskLock in io.druid.indexing.common

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

Modifier and Type	Method and Description
TaskLock	TaskLock.revokedCopy()

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	LockTryAcquireAction.perform(Task task, TaskActionToolbox toolbox)
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<TaskLock>	LockTryAcquireAction.getReturnTypeReference()
com.fasterxml.jackson.core.type.TypeReference<List<TaskLock>>	LockListAction.getReturnTypeReference()
com.fasterxml.jackson.core.type.TypeReference<TaskLock>	LockAcquireAction.getReturnTypeReference()
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
static Map<org.joda.time.Interval,TaskLock>	Tasks.tryAcquireExclusiveLocks(TaskActionClient client, SortedSet<org.joda.time.Interval> intervals)

Uses of TaskLock in io.druid.indexing.overlord

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

Modifier and Type	Method and Description
TaskLock	LockResult.getTaskLock()

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)

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)
static LockResult	LockResult.ok(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)
void	TaskStorage.replaceLock(String taskid, TaskLock oldLock, TaskLock newLock) Replace the old lock with the new lock.
void	MetadataTaskStorage.replaceLock(String taskid, TaskLock oldLock, TaskLock newLock)
void	HeapMemoryTaskStorage.replaceLock(String taskid, TaskLock oldLock, TaskLock newLock)

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

Constructor and Description
LockResult(TaskLock taskLock, boolean revoked)