| Package | Description |
|---|---|
| org.apache.storm.scheduler.resource | |
| org.apache.storm.scheduler.resource.strategies.scheduling |
| Modifier and Type | Method and Description |
|---|---|
static SchedulingResult |
SchedulingResult.failure(SchedulingStatus status,
String errorMessage) |
static SchedulingResult |
SchedulingResult.success() |
static SchedulingResult |
SchedulingResult.success(String message) |
| Modifier and Type | Method and Description |
|---|---|
protected SchedulingResult |
ConstraintSolverStrategy.checkSchedulingFeasibility() |
protected SchedulingResult |
BaseResourceAwareStrategy.checkSchedulingFeasibility()
Check scheduling feasibility for a quick failure as the second step in
BaseResourceAwareStrategy.schedule(Cluster, TopologyDetails). |
SchedulingResult |
SchedulingSearcherState.createSchedulingResult(boolean success,
String schedulerClassSimpleName) |
SchedulingResult |
IStrategy.schedule(Cluster schedulingState,
TopologyDetails td)
This method is invoked to calculate a scheduling for topology td.
|
SchedulingResult |
BaseResourceAwareStrategy.schedule(Cluster cluster,
TopologyDetails td)
Note that this method is not thread-safe.
|
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.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.