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 |
---|---|
SchedulingResult |
ConstraintSolverStrategy.SolverResult.asSchedulingResult() |
protected SchedulingResult |
BaseResourceAwareStrategy.mkNotEnoughResources(TopologyDetails td) |
SchedulingResult |
DefaultResourceAwareStrategy.schedule(Cluster cluster,
TopologyDetails td) |
SchedulingResult |
ConstraintSolverStrategy.schedule(Cluster cluster,
TopologyDetails td) |
SchedulingResult |
IStrategy.schedule(Cluster schedulingState,
TopologyDetails td)
This method is invoked to calculate a scheduling for topology td.
|
SchedulingResult |
GenericResourceAwareStrategy.schedule(Cluster cluster,
TopologyDetails td) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.