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.voidIStormClusterState.workerHeartbeat(String stormId, String node, Long port, ClusterWorkerHeartbeat info) voidStormClusterStateImpl.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 TypeMethodDescriptionintClusterWorkerHeartbeat.compareTo(ClusterWorkerHeartbeat other) booleanClusterWorkerHeartbeat.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 ClusterWorkerHeartbeatClientStatsUtil.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.