| Package | Description | 
|---|---|
| org.apache.storm.cluster | |
| org.apache.storm.generated | 
| Modifier and Type | Method and Description | 
|---|---|
| List<ProfileRequest> | StormClusterStateImpl. getWorkerProfileRequests(String stormId,
                        NodeInfo nodeInfo) | 
| List<ProfileRequest> | IStormClusterState. getWorkerProfileRequests(String stormId,
                        NodeInfo nodeInfo) | 
| Modifier and Type | Method and Description | 
|---|---|
| Map<ExecutorInfo,ExecutorBeat> | StormClusterStateImpl. executorBeats(String stormId,
             Map<List<Long>,NodeInfo> executorNodePort)need to take executor->node+port in explicitly so that we don’t run into a situation where a long dead worker with a skewed clock overrides all the timestamps. | 
| Map<ExecutorInfo,ExecutorBeat> | IStormClusterState. executorBeats(String stormId,
             Map<List<Long>,NodeInfo> executorNodePort) | 
| Modifier and Type | Method and Description | 
|---|---|
| NodeInfo | NodeInfo. deepCopy() | 
| NodeInfo | ProfileRequest. get_nodeInfo() | 
| Modifier and Type | Method and Description | 
|---|---|
| Map<List<Long>,NodeInfo> | Assignment. get_executor_node_port() | 
| Map<NodeInfo,WorkerResources> | Assignment. get_worker_resources() | 
| Modifier and Type | Method and Description | 
|---|---|
| int | NodeInfo. compareTo(NodeInfo other) | 
| boolean | NodeInfo. equals(NodeInfo that) | 
| void | Assignment. put_to_executor_node_port(List<Long> key,
                         NodeInfo val) | 
| void | Assignment. put_to_worker_resources(NodeInfo key,
                       WorkerResources val) | 
| void | ProfileRequest. set_nodeInfo(NodeInfo nodeInfo) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | Assignment. set_executor_node_port(Map<List<Long>,NodeInfo> executor_node_port) | 
| void | Assignment. set_worker_resources(Map<NodeInfo,WorkerResources> worker_resources) | 
| Constructor and Description | 
|---|
| NodeInfo(NodeInfo other)Performs a deep copy on other. | 
| ProfileRequest(NodeInfo nodeInfo,
              ProfileAction action) | 
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.