Package | Description |
---|---|
org.apache.storm.cluster | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
ClusterWorkerHeartbeat |
StormClusterStateImpl.getWorkerHeartbeat(String stormId,
String node,
Long port) |
ClusterWorkerHeartbeat |
IStormClusterState.getWorkerHeartbeat(String stormId,
String node,
Long port) |
Modifier and Type | Method and Description |
---|---|
static Map<ExecutorInfo,ExecutorBeat> |
ClusterUtils.convertExecutorBeats(List<ExecutorInfo> executors,
ClusterWorkerHeartbeat workerHeartbeat)
Ensures that we only return heartbeats for executors assigned to this worker
|
void |
StormClusterStateImpl.workerHeartbeat(String stormId,
String node,
Long port,
ClusterWorkerHeartbeat info) |
void |
IStormClusterState.workerHeartbeat(String stormId,
String node,
Long port,
ClusterWorkerHeartbeat info) |
Modifier and Type | Method and Description |
---|---|
ClusterWorkerHeartbeat |
ClusterWorkerHeartbeat.deepCopy() |
Modifier and Type | Method and Description |
---|---|
int |
ClusterWorkerHeartbeat.compareTo(ClusterWorkerHeartbeat other) |
boolean |
ClusterWorkerHeartbeat.equals(ClusterWorkerHeartbeat that) |
Constructor and Description |
---|
ClusterWorkerHeartbeat(ClusterWorkerHeartbeat other)
Performs a deep copy on other.
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.