Package | Description |
---|---|
io.druid.indexing.common.actions | |
io.druid.indexing.overlord |
Modifier and Type | Class and Description |
---|---|
class |
LockAcquireAction |
class |
LockListAction |
class |
LockReleaseAction |
class |
LockTryAcquireAction |
class |
SegmentInsertAction |
class |
SegmentListUnusedAction |
class |
SegmentListUsedAction |
class |
SegmentMetadataUpdateAction |
class |
SegmentNukeAction |
Modifier and Type | Method and Description |
---|---|
TaskAction<T> |
TaskActionHolder.getAction() |
Modifier and Type | Method and Description |
---|---|
<RetType> RetType |
TaskActionClient.submit(TaskAction<RetType> taskAction) |
<RetType> RetType |
RemoteTaskActionClient.submit(TaskAction<RetType> taskAction) |
<RetType> RetType |
LocalTaskActionClient.submit(TaskAction<RetType> taskAction) |
Constructor and Description |
---|
TaskActionHolder(Task task,
TaskAction action) |
Modifier and Type | Method and Description |
---|---|
List<TaskAction> |
TaskStorage.getAuditLogs(String taskid)
Returns all actions taken by a task.
|
List<TaskAction> |
MetadataTaskStorage.getAuditLogs(String taskId) |
List<TaskAction> |
HeapMemoryTaskStorage.getAuditLogs(String taskid) |
Modifier and Type | Method and Description |
---|---|
<T> void |
TaskStorage.addAuditLog(Task task,
TaskAction<T> taskAction)
Add an action taken by a task to the audit log.
|
<T> void |
MetadataTaskStorage.addAuditLog(Task task,
TaskAction<T> taskAction) |
<T> void |
HeapMemoryTaskStorage.addAuditLog(Task task,
TaskAction<T> taskAction) |
Copyright © 2011–2015. All rights reserved.