Uses of Class
org.apache.storm.generated.SupervisorWorkerHeartbeat
Packages that use SupervisorWorkerHeartbeat
Package
Description
-
Uses of SupervisorWorkerHeartbeat in org.apache.storm
Methods in org.apache.storm with parameters of type SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionvoidLocalCluster.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) -
Uses of SupervisorWorkerHeartbeat in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus with parameters of type SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionvoidvoidHeartbeatCache.updateHeartbeat(SupervisorWorkerHeartbeat workerHeartbeat, Integer taskTimeoutSecs) Update the heartbeats for a given worker. -
Uses of SupervisorWorkerHeartbeat in org.apache.storm.generated
Methods in org.apache.storm.generated that return SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionSupervisorWorkerHeartbeat.deepCopy()Supervisor.sendSupervisorWorkerHeartbeat_args.get_heartbeat()Nimbus.sendSupervisorWorkerHeartbeat_args.get_heatbeat()Methods in org.apache.storm.generated that return types with arguments of type SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionSupervisorWorkerHeartbeats.get_worker_heartbeats()SupervisorWorkerHeartbeats.get_worker_heartbeats_iterator()Methods in org.apache.storm.generated with parameters of type SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionvoidSupervisorWorkerHeartbeats.add_to_worker_heartbeats(SupervisorWorkerHeartbeat elem) intSupervisorWorkerHeartbeat.compareTo(SupervisorWorkerHeartbeat other) booleanSupervisorWorkerHeartbeat.equals(SupervisorWorkerHeartbeat that) voidNimbus.Client.send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) voidSupervisor.Client.send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) voidNimbus.AsyncClient.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidNimbus.AsyncIface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidNimbus.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) voidNimbus.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) Send supervisor local worker heartbeat when a supervisor is unreachablevoidSupervisor.AsyncClient.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidSupervisor.AsyncIface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidSupervisor.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) voidSupervisor.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) Send worker heartbeat to local supervisorvoidSupervisor.sendSupervisorWorkerHeartbeat_args.set_heartbeat(SupervisorWorkerHeartbeat heartbeat) voidNimbus.sendSupervisorWorkerHeartbeat_args.set_heatbeat(SupervisorWorkerHeartbeat heatbeat) Method parameters in org.apache.storm.generated with type arguments of type SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionvoidSupervisorWorkerHeartbeats.set_worker_heartbeats(List<SupervisorWorkerHeartbeat> worker_heartbeats) Constructors in org.apache.storm.generated with parameters of type SupervisorWorkerHeartbeatModifierConstructorDescriptionsendSupervisorWorkerHeartbeat_call(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport) sendSupervisorWorkerHeartbeat_call(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport) Performs a deep copy on other.Constructor parameters in org.apache.storm.generated with type arguments of type SupervisorWorkerHeartbeatModifierConstructorDescriptionSupervisorWorkerHeartbeats(String supervisor_id, List<SupervisorWorkerHeartbeat> worker_heartbeats) -
Uses of SupervisorWorkerHeartbeat in org.apache.storm.stats
Methods in org.apache.storm.stats that return SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionstatic SupervisorWorkerHeartbeatStatsUtil.thriftifyRpcWorkerHb(String stormId, List<Long> executorId) Used for local test.Methods in org.apache.storm.stats with parameters of type SupervisorWorkerHeartbeatModifier and TypeMethodDescriptionStatsUtil.convertWorkerBeats(SupervisorWorkerHeartbeat workerHeartbeat) convertSupervisorWorkerHeartbeatto nimbus local report executor heartbeats.