public class WorkerCatalog extends Object
Constructor and Description |
---|
WorkerCatalog() |
Modifier and Type | Method and Description |
---|---|
void |
catalog(String workerId,
String graphAffinity) |
List<String> |
orderedStealingList(String graphId)
Returns a list of graphIds beginning with the supplied one, then moving on to any others that have too many
workers on them.
|
void |
purgeDeadWorkers() |
int |
size() |
void |
updateTargetWorkerCounts(com.google.common.collect.Multimap<String,String> activeJobsPerGraph) |
public void purgeDeadWorkers()
public void updateTargetWorkerCounts(com.google.common.collect.Multimap<String,String> activeJobsPerGraph)
public List<String> orderedStealingList(String graphId)
public int size()
Copyright © 2019. All rights reserved.