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.