| Package | Description | 
|---|---|
| io.druid.indexing.overlord | |
| io.druid.indexing.worker | 
| Modifier and Type | Method and Description | 
|---|---|
Map<String,TaskAnnouncement> | 
ZkWorker.getRunningTasks()  | 
| Modifier and Type | Method and Description | 
|---|---|
static TaskAnnouncement | 
TaskAnnouncement.create(String taskId,
      TaskResource resource,
      TaskStatus status,
      TaskLocation location)  | 
static TaskAnnouncement | 
TaskAnnouncement.create(Task task,
      TaskStatus status,
      TaskLocation location)  | 
| Modifier and Type | Method and Description | 
|---|---|
List<TaskAnnouncement> | 
WorkerCuratorCoordinator.getAnnouncements()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
WorkerCuratorCoordinator.updateTaskStatusAnnouncement(TaskAnnouncement announcement)  | 
Copyright © 2011–2018. All rights reserved.