Class RoundRobinResourceAwareStrategy
java.lang.Object
org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy
org.apache.storm.scheduler.resource.strategies.scheduling.RoundRobinResourceAwareStrategy
- All Implemented Interfaces:
- IStrategy
- 
Nested Class SummaryNested classes/interfaces inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategyBaseResourceAwareStrategy.NodeSortType
- 
Field SummaryFields inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategycluster, compToExecs, config, execSorter, execToComp, nodes, nodeSorter, nodeSortType, orderExecutorsByProximity, searcherState, sortNodesForEachExecutor, topologyDetails, topoName
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionprotected SchedulingResultscheduleExecutorsOnNodes(List<ExecutorDetails> orderedExecutors, Iterable<String> sortedNodesIterable) For each component try to schedule executors in sequence on the nodes.Methods inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategyassignBoundAckersForNewWorkerSlot, checkSchedulingFeasibility, getMaxStateSearchFromTopoConf, hostnameToNodes, idToNode, isExecAssignmentToWorkerValid, isOrderByProximity, prepare, prepareForScheduling, schedule, setExecSorter, setNodeSorter
- 
Constructor Details- 
RoundRobinResourceAwareStrategypublic RoundRobinResourceAwareStrategy()
 
- 
- 
Method Details- 
scheduleExecutorsOnNodesprotected SchedulingResult scheduleExecutorsOnNodes(List<ExecutorDetails> orderedExecutors, Iterable<String> sortedNodesIterable) For each component try to schedule executors in sequence on the nodes.- Overrides:
- scheduleExecutorsOnNodesin class- BaseResourceAwareStrategy
- Parameters:
- orderedExecutors- Executors sorted in the preferred order cannot be null
- sortedNodesIterable- Node iterable which cannot be null, relies on behavior when- BaseResourceAwareStrategy.sortNodesForEachExecutoris false
- Returns:
- SchedulingResult with success attribute set to true or false indicting whether ALL executors were assigned. @{#}
 
 
-