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 and 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 and 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 and 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 and 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 and 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 and 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)

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

Constructor and Description
SchedulingSearcherState(Map<WorkerSlot,Map<String,Integer>> workerCompAssignmentCnts, Map<RasNode,Map<String,Integer>> nodeCompAssignmentCnts, int maxStatesSearched, long maxTimeMs, List<ExecutorDetails> execs, LinkedList<ExecutorDetails> unassignedAckers, TopologyDetails td, Map<ExecutorDetails,String> execToComp)

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 and Description
List<RasNode>	NodeSorterHostProximity.hostnameToNodes(String hostname) hostname to Ids.
List<RasNode>	NodeSorter.hostnameToNodes(String hostname) hostname to Ids.