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 © 2019 The Apache Software Foundation. All Rights Reserved.