Uses of Class
org.apache.storm.generated.ClusterWorkerHeartbeat
-
Uses of ClusterWorkerHeartbeat in org.apache.storm.cluster
Modifier and TypeMethodDescriptionIStormClusterState.getWorkerHeartbeat
(String stormId, String node, Long port) StormClusterStateImpl.getWorkerHeartbeat
(String stormId, String node, Long port) Modifier and TypeMethodDescriptionstatic Map<ExecutorInfo,
ExecutorBeat> ClusterUtils.convertExecutorBeats
(List<ExecutorInfo> executors, ClusterWorkerHeartbeat workerHeartbeat) Ensures that we only return heartbeats for executors assigned to this worker.void
IStormClusterState.workerHeartbeat
(String stormId, String node, Long port, ClusterWorkerHeartbeat info) void
StormClusterStateImpl.workerHeartbeat
(String stormId, String node, Long port, ClusterWorkerHeartbeat info) -
Uses of ClusterWorkerHeartbeat in org.apache.storm.generated
Modifier and TypeMethodDescriptionint
ClusterWorkerHeartbeat.compareTo
(ClusterWorkerHeartbeat other) boolean
ClusterWorkerHeartbeat.equals
(ClusterWorkerHeartbeat that) ModifierConstructorDescriptionPerforms a deep copy on other. -
Uses of ClusterWorkerHeartbeat in org.apache.storm.stats
Modifier and TypeMethodDescriptionstatic ClusterWorkerHeartbeat
ClientStatsUtil.thriftifyZkWorkerHb
(Map<String, Object> heartbeat) Modifier and TypeMethodDescriptionStatsUtil.convertZkWorkerHb
(ClusterWorkerHeartbeat workerHb) convert a thrift worker heartbeat into a java HashMap.