| Package | Description |
|---|---|
| org.apache.storm.scheduler | |
| org.apache.storm.scheduler.resource.normalization |
| Modifier and Type | Method and Description |
|---|---|
ResourceMetrics |
Cluster.getResourceMetrics() |
| Constructor and Description |
|---|
Cluster(INimbus nimbus,
ResourceMetrics resourceMetrics,
Map<String,SupervisorDetails> supervisors,
Map<String,? extends SchedulerAssignment> assignments,
Topologies topologies,
Map<String,Object> conf) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
NormalizedResources.remove(NormalizedResources other,
ResourceMetrics resourceMetrics)
Remove the other resources from this.
|
boolean |
NormalizedResourceOffer.remove(NormalizedResourcesWithMemory other,
ResourceMetrics resourceMetrics)
Remove the resources in other from this.
|
boolean |
NormalizedResourceOffer.remove(WorkerResources other,
ResourceMetrics resourceMetrics)
Remove the resources in other from this.
|
Copyright © 2021 The Apache Software Foundation. All rights reserved.