Package | Description |
---|---|
org.apache.storm.cluster | |
org.apache.storm.generated | |
org.apache.storm.stats |
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.
|
Modifier and Type | Method and Description |
---|---|
static ClusterWorkerHeartbeat |
ClientStatsUtil.thriftifyZkWorkerHb(Map<String,Object> heartbeat) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
StatsUtil.convertZkWorkerHb(ClusterWorkerHeartbeat workerHb)
convert a thrift worker heartbeat into a java HashMap.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.