| Package | Description |
|---|---|
| io.druid.indexing.common.actions | |
| io.druid.indexing.common.task | |
| io.druid.indexing.overlord |
| Modifier and Type | Method and Description |
|---|---|
TaskLock |
LockTryAcquireAction.perform(Task task,
TaskActionToolbox toolbox) |
TaskLock |
LockAcquireAction.perform(Task task,
TaskActionToolbox toolbox) |
| 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) |
| Modifier and Type | Method and Description |
|---|---|
protected Iterable<TaskLock> |
AbstractTask.getTaskLocks(TaskToolbox toolbox) |
| Modifier and Type | Method and Description |
|---|---|
TaskLock |
TaskLockbox.lock(Task task,
org.joda.time.Interval interval)
Acquires a lock on behalf of a task.
|
| 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.
|
| 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) |
Copyright © 2011–2017. All rights reserved.