| Package | Description | 
|---|---|
| io.druid.indexer | |
| io.druid.indexing.common | |
| io.druid.indexing.overlord | |
| io.druid.indexing.worker | 
| Modifier and Type | Method and Description | 
|---|---|
static TaskLocation | 
TaskLocation.create(String host,
      int port,
      int tlsPort)  | 
TaskLocation | 
TaskStatusPlus.getLocation()  | 
static TaskLocation | 
TaskLocation.unknown()  | 
| Constructor and Description | 
|---|
TaskStatusPlus(String id,
              org.joda.time.DateTime createdTime,
              org.joda.time.DateTime queueInsertionTime,
              TaskState state,
              Long duration,
              TaskLocation location)  | 
| Modifier and Type | Method and Description | 
|---|---|
TaskLocation | 
TaskInfoProvider.getTaskLocation(String id)  | 
| Modifier and Type | Method and Description | 
|---|---|
abstract TaskLocation | 
TaskRunnerWorkItem.getLocation()  | 
TaskLocation | 
RemoteTaskRunnerWorkItem.getLocation()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TaskRunnerListener.locationChanged(String taskId,
               TaskLocation newLocation)
Called when the location of a task has changed. 
 | 
static void | 
TaskRunnerUtils.notifyLocationChanged(Iterable<Pair<TaskRunnerListener,Executor>> listeners,
                     String taskId,
                     TaskLocation location)  | 
void | 
RemoteTaskRunnerWorkItem.setLocation(TaskLocation location)  | 
RemoteTaskRunnerWorkItem | 
RemoteTaskRunnerWorkItem.withWorker(Worker theWorker,
          TaskLocation location)  | 
| Constructor and Description | 
|---|
RemoteTaskRunnerWorkItem(String taskId,
                        org.joda.time.DateTime createdTime,
                        org.joda.time.DateTime queueInsertionTime,
                        Worker worker,
                        TaskLocation location)  | 
RemoteTaskRunnerWorkItem(String taskId,
                        Worker worker,
                        TaskLocation location)  | 
| Modifier and Type | Method and Description | 
|---|---|
TaskLocation | 
TaskAnnouncement.getTaskLocation()  | 
| 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)  | 
Copyright © 2011–2018. All rights reserved.