Package | Description |
---|---|
org.apache.storm.scheduler | |
org.apache.storm.scheduler.resource | |
org.apache.storm.scheduler.resource.normalization |
Modifier and Type | Method and Description |
---|---|
NormalizedResourceRequest |
Cluster.getAllScheduledResourcesForNode(String nodeId) |
NormalizedResourceRequest |
ISchedulingState.getAllScheduledResourcesForNode(String nodeId)
Get all scheduled resources for node.
|
NormalizedResourceRequest |
TopologyDetails.getApproximateResources(Set<ExecutorDetails> execs)
Get approximate resources for given topology executors.
|
NormalizedResourceRequest |
TopologyDetails.getApproximateTotalResources()
Get an approximate total resources needed for this topology.
|
NormalizedResourceRequest |
TopologyDetails.getTaskResourceReqList(ExecutorDetails exec)
get the resources requirements for a executor.
|
NormalizedResourceRequest |
TopologyDetails.getTotalResources(ExecutorDetails exec)
Get the total resource requirement for an executor.
|
Modifier and Type | Method and Description |
---|---|
void |
TopologyDetails.addResourcesForExec(ExecutorDetails exec,
NormalizedResourceRequest resourceList)
add resource requirements for a executor.
|
Modifier and Type | Method and Description |
---|---|
static NormalizedResourceRequest |
ResourceUtils.getBoltResources(StormTopology topology,
Map<String,Object> topologyConf,
String componentId) |
static NormalizedResourceRequest |
ResourceUtils.getSpoutResources(StormTopology topology,
Map<String,Object> topologyConf,
String componentId) |
Modifier and Type | Method and Description |
---|---|
static Map<String,NormalizedResourceRequest> |
ResourceUtils.getBoltsResources(StormTopology topology,
Map<String,Object> topologyConf) |
static Map<String,NormalizedResourceRequest> |
ResourceUtils.getSpoutsResources(StormTopology topology,
Map<String,Object> topologyConf) |
Modifier and Type | Method and Description |
---|---|
void |
NormalizedResourceRequest.add(NormalizedResourceRequest other)
Add the resources in other to this.
|
boolean |
NormalizedResourceOffer.couldFit(double minWorkerCpu,
NormalizedResourceRequest requestedResources)
Is there any possibility that a resource request could ever fit on this.
|
void |
NormalizedResourceOffer.updateForRareResourceAffinity(NormalizedResourceRequest requestedResources)
If a node or rack has a kind of resource not in a request, make that resource negative so when sorting that node or rack will be less likely to be selected.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.