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