| Package | Description |
|---|---|
| org.apache.storm.scheduler.resource.strategies.scheduling | |
| org.apache.storm.scheduler.resource.strategies.scheduling.sorter |
| Modifier and Type | Method and Description |
|---|---|
List<ObjectResourcesItem> |
ObjectResourcesSummary.getObjectResources() |
| Modifier and Type | Method and Description |
|---|---|
void |
ObjectResourcesItem.add(ObjectResourcesItem other) |
void |
ObjectResourcesSummary.addObjectResourcesItem(ObjectResourcesItem item) |
| Constructor and Description |
|---|
ObjectResourcesItem(ObjectResourcesItem other) |
| Constructor and Description |
|---|
ObjectResourcesSummary(List<ObjectResourcesItem> objectResources,
NormalizedResourceOffer availableResourcesOverall,
NormalizedResourceOffer totalResourcesOverall,
String identifier) |
| Modifier and Type | Method and Description |
|---|---|
Iterable<ObjectResourcesItem> |
INodeSorter.getSortedRacks() |
Iterable<ObjectResourcesItem> |
NodeSorterHostProximity.getSortedRacks()
Racks are sorted by two criteria.
|
List<ObjectResourcesItem> |
NodeSorter.getSortedRacks()
Racks are sorted by two criteria.
|
protected List<ObjectResourcesItem> |
NodeSorter.sortObjectResources(ObjectResourcesSummary resourcesSummary,
ExecutorDetails exec,
NodeSorter.ExistingScheduleFunc existingScheduleFunc)
Scheduling uses
NodeSorter.sortAllNodes() which eventually calls this method whose behavior can be altered by setting NodeSorter.nodeSortType. |
protected Iterable<ObjectResourcesItem> |
NodeSorterHostProximity.sortObjectResources(ObjectResourcesSummary resourcesSummary,
ExecutorDetails exec,
NodeSorterHostProximity.ExistingScheduleFunc existingScheduleFunc)
Scheduling uses
NodeSorterHostProximity.sortAllNodes() which eventually calls this method whose behavior can be altered by setting NodeSorterHostProximity.nodeSortType. |
Copyright © 2021 The Apache Software Foundation. All rights reserved.