Uses of Class
org.apache.storm.scheduler.resource.RasNode
Package
Description
-
Uses of RasNode in org.apache.storm.scheduler.resource
Modifier and TypeMethodDescriptionRasNodes.getNodeById
(String nodeId) get node object from nodeId.Modifier and TypeMethodDescriptionRasNodes.getAllNodesFrom
(Cluster cluster) RasNodes.getHostnameToNodes()
Get a map with list of RasNode for each hostname.RasNodes.getNodes()
-
Uses of RasNode in org.apache.storm.scheduler.resource.strategies.scheduling
Modifier and TypeMethodDescriptionFind RASNode for specified node id.Modifier and TypeMethodDescriptionBaseResourceAwareStrategy.hostnameToNodes
(String hostname) hostname to Ids.Modifier and TypeMethodDescriptionprotected int
BaseResourceAwareStrategy.assignBoundAckersForNewWorkerSlot
(ExecutorDetails exec, RasNode node, WorkerSlot workerSlot) Determine how many bound ackers to put into the given workerSlot.void
SchedulingSearcherState.assignCurrentExecutor
(Map<ExecutorDetails, String> execToComp, RasNode node, WorkerSlot workerSlot) Attempt to assign current executor (execIndex points to) to worker and node.void
SchedulingSearcherState.assignSingleBoundAcker
(RasNode node, WorkerSlot workerSlot) Remove the head of unassigned ackers and attempt to assign it to a workerSlot as a bound acker.void
SchedulingSearcherState.backtrack
(Map<ExecutorDetails, String> execToComp, RasNode[] nodesForExec, WorkerSlot[] workerSlotForExec) Backtrack to prior executor that was directly assigned.void
SchedulingSearcherState.freeWorkerSlotWithBoundAckers
(RasNode node, WorkerSlot workerSlot) Free the bound-ackers for the given node and workerSlot.int
SchedulingSearcherState.getComponentCntOnNode
(RasNode rasNode, String comp) -
Uses of RasNode in org.apache.storm.scheduler.resource.strategies.scheduling.sorter
Modifier and TypeMethodDescriptionNodeSorter.hostnameToNodes
(String hostname) hostname to Ids.NodeSorterHostProximity.hostnameToNodes
(String hostname) hostname to Ids.