Package | Description |
---|---|
io.druid.indexing.common | |
io.druid.indexing.common.actions | |
io.druid.indexing.common.task | |
io.druid.indexing.overlord |
Modifier and Type | Method and Description |
---|---|
TaskLock |
TaskLock.revokedCopy() |
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 |
---|---|
static Map<org.joda.time.Interval,TaskLock> |
Tasks.tryAcquireExclusiveLocks(TaskActionClient client,
SortedSet<org.joda.time.Interval> intervals) |
Modifier and Type | Method and Description |
---|---|
TaskLock |
LockResult.getTaskLock() |
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) |
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) |
Constructor and Description |
---|
LockResult(TaskLock taskLock,
boolean revoked) |
Copyright © 2011–2018. All rights reserved.