Package | Description |
---|---|
io.druid.indexing.overlord |
Modifier and Type | Method and Description |
---|---|
ZkWorker |
RemoteTaskRunner.findWorkerRunningTask(String taskId) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteTaskRunner.cleanBlackListedNode(ZkWorker zkWorker,
long currentTimeStamp) |
Modifier and Type | Method and Description |
---|---|
static Collection<Worker> |
RemoteTaskRunner.getWorkerFromZK(Collection<ZkWorker> workers) |
Copyright © 2011–2017. All rights reserved.