Package | Description |
---|---|
io.druid.indexing.overlord |
Modifier and Type | Method and Description |
---|---|
void |
ThreadPoolTaskRunner.registerListener(TaskRunnerListener listener,
Executor executor) |
void |
TaskRunner.registerListener(TaskRunnerListener listener,
Executor executor)
Register a listener with this task runner.
|
void |
RemoteTaskRunner.registerListener(TaskRunnerListener listener,
Executor executor) |
void |
ForkingTaskRunner.registerListener(TaskRunnerListener listener,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
static void |
TaskRunnerUtils.notifyLocationChanged(Iterable<Pair<TaskRunnerListener,Executor>> listeners,
String taskId,
TaskLocation location) |
static void |
TaskRunnerUtils.notifyStatusChanged(Iterable<Pair<TaskRunnerListener,Executor>> listeners,
String taskId,
TaskStatus status) |
Copyright © 2011–2018. All rights reserved.