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 © 2022 The Apache Software Foundation. All rights reserved.