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(Map<WorkerSlot,Collection<ExecutorDetails>> schedulingResultMap) |
static SchedulingResult |
SchedulingResult.successWithMsg(Map<WorkerSlot,Collection<ExecutorDetails>> schedulingResultMap,
String message) |
Modifier and Type | Method and Description |
---|---|
SchedulingResult |
IStrategy.schedule(TopologyDetails td)
This method is invoked to calcuate a scheduling for topology td
|
SchedulingResult |
DefaultResourceAwareStrategy.schedule(TopologyDetails td) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.