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