Uses of Class
org.apache.storm.generated.ClusterWorkerHeartbeat
Packages that use ClusterWorkerHeartbeat
-
Uses of ClusterWorkerHeartbeat in org.apache.storm.cluster
Methods in org.apache.storm.cluster that return ClusterWorkerHeartbeatModifier and TypeMethodDescriptionIStormClusterState.getWorkerHeartbeat
(String stormId, String node, Long port) StormClusterStateImpl.getWorkerHeartbeat
(String stormId, String node, Long port) Methods in org.apache.storm.cluster with parameters of type ClusterWorkerHeartbeatModifier 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
Methods in org.apache.storm.generated that return ClusterWorkerHeartbeatMethods in org.apache.storm.generated with parameters of type ClusterWorkerHeartbeatModifier and TypeMethodDescriptionint
ClusterWorkerHeartbeat.compareTo
(ClusterWorkerHeartbeat other) boolean
ClusterWorkerHeartbeat.equals
(ClusterWorkerHeartbeat that) Constructors in org.apache.storm.generated with parameters of type ClusterWorkerHeartbeatModifierConstructorDescriptionPerforms a deep copy on other. -
Uses of ClusterWorkerHeartbeat in org.apache.storm.stats
Methods in org.apache.storm.stats that return ClusterWorkerHeartbeatModifier and TypeMethodDescriptionstatic ClusterWorkerHeartbeat
ClientStatsUtil.thriftifyZkWorkerHb
(Map<String, Object> heartbeat) Methods in org.apache.storm.stats with parameters of type ClusterWorkerHeartbeatModifier and TypeMethodDescriptionStatsUtil.convertZkWorkerHb
(ClusterWorkerHeartbeat workerHb) convert a thrift worker heartbeat into a java HashMap.