| 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 |
ResetDataSourceMetadataAction |
class |
SegmentAllocateAction
Allocates a pending segment for a given timestamp.
|
class |
SegmentInsertAction
Insert segments into metadata storage.
|
class |
SegmentListUnusedAction |
class |
SegmentListUsedAction |
class |
SegmentMetadataUpdateAction |
class |
SegmentNukeAction |
class |
SegmentTransactionalInsertAction
Insert segments into metadata storage.
|
| Modifier and Type | Method and Description |
|---|---|
TaskAction |
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–2017. All rights reserved.