Package | Description |
---|---|
org.apache.storm.scheduler.resource | |
org.apache.storm.scheduler.resource.strategies.scheduling |
Modifier and Type | Method and Description |
---|---|
RAS_Node |
RAS_Nodes.getNodeById(String nodeId)
get node object from nodeId.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,RAS_Node> |
RAS_Nodes.getAllNodesFrom(Cluster cluster) |
Collection<RAS_Node> |
RAS_Nodes.getNodes() |
Modifier and Type | Method and Description |
---|---|
RAS_Node |
BaseResourceAwareStrategy.idToNode(String id)
Find RAS_Node for specified node id.
|
Modifier and Type | Method and Description |
---|---|
List<RAS_Node> |
BaseResourceAwareStrategy.hostnameToNodes(String hostname)
hostname to Ids.
|
Modifier and Type | Method and Description |
---|---|
void |
ConstraintSolverStrategy.SearcherState.backtrack(Map<ExecutorDetails,String> execToComp,
RAS_Node node,
WorkerSlot workerSlot) |
protected String |
BaseResourceAwareStrategy.nodeToRack(RAS_Node node)
Get the rack on which a node is a part of.
|
void |
ConstraintSolverStrategy.SearcherState.tryToSchedule(Map<ExecutorDetails,String> execToComp,
RAS_Node node,
WorkerSlot workerSlot) |
Modifier and Type | Method and Description |
---|---|
protected TreeSet<BaseResourceAwareStrategy.ObjectResources> |
BaseResourceAwareStrategy.sortNodes(List<RAS_Node> availNodes,
ExecutorDetails exec,
TopologyDetails topologyDetails,
String rackId,
Map<String,AtomicInteger> scheduledCount)
Nodes are sorted by two criteria.
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.