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