Uses of Class
org.apache.storm.scheduler.resource.SchedulingResult
Packages that use SchedulingResult
Package
Description
-
Uses of SchedulingResult in org.apache.storm.scheduler.resource
Methods in org.apache.storm.scheduler.resource that return SchedulingResultModifier and TypeMethodDescriptionstatic SchedulingResultSchedulingResult.failure(SchedulingStatus status, String errorMessage) static SchedulingResultSchedulingResult.success()static SchedulingResult -
Uses of SchedulingResult in org.apache.storm.scheduler.resource.strategies.scheduling
Methods in org.apache.storm.scheduler.resource.strategies.scheduling that return SchedulingResultModifier and TypeMethodDescriptionprotected SchedulingResultBaseResourceAwareStrategy.checkSchedulingFeasibility()Check scheduling feasibility for a quick failure as the second step inBaseResourceAwareStrategy.schedule(Cluster, TopologyDetails).protected SchedulingResultConstraintSolverStrategy.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 SchedulingResultBaseResourceAwareStrategy.scheduleExecutorsOnNodes(List<ExecutorDetails> orderedExecutors, Iterable<String> sortedNodesIter) Try to schedule till successful or till limits (backtrack count or time) have been exceeded.protected SchedulingResultRoundRobinResourceAwareStrategy.scheduleExecutorsOnNodes(List<ExecutorDetails> orderedExecutors, Iterable<String> sortedNodesIterable) For each component try to schedule executors in sequence on the nodes.