| Package | Description |
|---|---|
| org.apache.storm.scheduler.resource | |
| org.apache.storm.scheduler.resource.strategies.scheduling |
| Modifier and Type | Method and Description |
|---|---|
RAS_Node |
RAS_Nodes.getNodeById(String nodeId)
get node object from nodeId
|
| Modifier and Type | Method and Description |
|---|---|
static Map<String,RAS_Node> |
RAS_Nodes.getAllNodesFrom(Cluster cluster,
Topologies topologies) |
Collection<RAS_Node> |
RAS_Nodes.getNodes() |
| Modifier and Type | Method and Description |
|---|---|
static int |
RAS_Node.countFreeSlotsAlive(Collection<RAS_Node> nodes) |
static int |
RAS_Node.countSlotsUsed(Collection<RAS_Node> nodes) |
static int |
RAS_Node.countSlotsUsed(String topId,
Collection<RAS_Node> nodes) |
static int |
RAS_Node.countTotalSlotsAlive(Collection<RAS_Node> nodes) |
| Modifier and Type | Method and Description |
|---|---|
RAS_Node |
DefaultResourceAwareStrategy.idToNode(String id)
Find RAS_Node for specified node id
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.