Uses of Class
org.apache.storm.scheduler.resource.SchedulingResult
Package
Description
-
Uses of SchedulingResult in org.apache.storm.scheduler.resource
Modifier and TypeMethodDescriptionstatic SchedulingResult
SchedulingResult.failure
(SchedulingStatus status, String errorMessage) static SchedulingResult
SchedulingResult.success()
static SchedulingResult
-
Uses of SchedulingResult in org.apache.storm.scheduler.resource.strategies.scheduling
Modifier and TypeMethodDescriptionprotected SchedulingResult
BaseResourceAwareStrategy.checkSchedulingFeasibility()
Check scheduling feasibility for a quick failure as the second step inBaseResourceAwareStrategy.schedule(Cluster, TopologyDetails)
.protected SchedulingResult
ConstraintSolverStrategy.checkSchedulingFeasibility()
SchedulingSearcherState.createSchedulingResult
(boolean success, String schedulerClassSimpleName) BaseResourceAwareStrategy.schedule
(Cluster cluster, TopologyDetails td) Note that this method is not thread-safe.IStrategy.schedule
(Cluster schedulingState, TopologyDetails td) This method is invoked to calculate a scheduling for topology td.protected SchedulingResult
BaseResourceAwareStrategy.scheduleExecutorsOnNodes
(List<ExecutorDetails> orderedExecutors, Iterable<String> sortedNodesIter) Try to schedule till successful or till limits (backtrack count or time) have been exceeded.protected SchedulingResult
RoundRobinResourceAwareStrategy.scheduleExecutorsOnNodes
(List<ExecutorDetails> orderedExecutors, Iterable<String> sortedNodesIterable) For each component try to schedule executors in sequence on the nodes.