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 Summary
Nested classes/interfaces inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy
BaseResourceAwareStrategy.NodeSortType
-
Field Summary
Fields inherited from class org.apache.storm.scheduler.resource.strategies.scheduling.BaseResourceAwareStrategy
cluster, compToExecs, config, execSorter, execToComp, nodes, nodeSorter, nodeSortType, orderExecutorsByProximity, searcherState, sortNodesForEachExecutor, topologyDetails, topoName
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected SchedulingResult
scheduleExecutorsOnNodes
(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.BaseResourceAwareStrategy
assignBoundAckersForNewWorkerSlot, checkSchedulingFeasibility, getMaxStateSearchFromTopoConf, hostnameToNodes, idToNode, isExecAssignmentToWorkerValid, isOrderByProximity, prepare, prepareForScheduling, schedule, setExecSorter, setNodeSorter
-
Constructor Details
-
RoundRobinResourceAwareStrategy
public RoundRobinResourceAwareStrategy()
-
-
Method Details
-
scheduleExecutorsOnNodes
protected SchedulingResult scheduleExecutorsOnNodes(List<ExecutorDetails> orderedExecutors, Iterable<String> sortedNodesIterable) For each component try to schedule executors in sequence on the nodes.- Overrides:
scheduleExecutorsOnNodes
in classBaseResourceAwareStrategy
- Parameters:
orderedExecutors
- Executors sorted in the preferred order cannot be nullsortedNodesIterable
- Node iterable which cannot be null, relies on behavior whenBaseResourceAwareStrategy.sortNodesForEachExecutor
is false- Returns:
- SchedulingResult with success attribute set to true or false indicting whether ALL executors were assigned. @{#}
-