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