Uses of Class
org.apache.storm.scheduler.resource.RasNode

Packages that use RasNode

Package	Description
org.apache.storm.scheduler.resource
org.apache.storm.scheduler.resource.strategies.scheduling
org.apache.storm.scheduler.resource.strategies.scheduling.sorter

Uses of RasNode in org.apache.storm.scheduler.resource

Methods in org.apache.storm.scheduler.resource that return RasNode

Modifier and Type	Method	Description
RasNode	RasNodes.getNodeById(String nodeId)	get node object from nodeId.

Methods in org.apache.storm.scheduler.resource that return types with arguments of type RasNode

Modifier and Type	Method	Description
static Map<String,RasNode>	RasNodes.getAllNodesFrom(Cluster cluster)
Map<String,List<RasNode>>	RasNodes.getHostnameToNodes()	Get a map with list of RasNode for each hostname.
Collection<RasNode>	RasNodes.getNodes()

Methods in org.apache.storm.scheduler.resource with parameters of type RasNode

Modifier and Type	Method	Description
int	RasNode.compareTo(RasNode o)

Uses of RasNode in org.apache.storm.scheduler.resource.strategies.scheduling

Methods in org.apache.storm.scheduler.resource.strategies.scheduling that return RasNode

Modifier and Type	Method	Description
RasNode	BaseResourceAwareStrategy.idToNode(String id)	Find RASNode for specified node id.

Methods in org.apache.storm.scheduler.resource.strategies.scheduling that return types with arguments of type RasNode

Modifier and Type	Method	Description
List<RasNode>	BaseResourceAwareStrategy.hostnameToNodes(String hostname)	hostname to Ids.

Methods in org.apache.storm.scheduler.resource.strategies.scheduling with parameters of type RasNode

Modifier and Type	Method	Description
protected 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

Methods in org.apache.storm.scheduler.resource.strategies.scheduling.sorter that return types with arguments of type RasNode

Modifier and Type	Method	Description
List<RasNode>	NodeSorter.hostnameToNodes(String hostname)	hostname to Ids.
List<RasNode>	NodeSorterHostProximity.hostnameToNodes(String hostname)	hostname to Ids.