Uses of Class
org.apache.storm.generated.SupervisorWorkerHeartbeat
Package
Description
-
Uses of SupervisorWorkerHeartbeat in org.apache.storm
Modifier and TypeMethodDescriptionvoid
LocalCluster.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat) -
Uses of SupervisorWorkerHeartbeat in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionvoid
void
HeartbeatCache.updateHeartbeat
(SupervisorWorkerHeartbeat workerHeartbeat, Integer taskTimeoutSecs) Update the heartbeats for a given worker. -
Uses of SupervisorWorkerHeartbeat in org.apache.storm.generated
Modifier and TypeMethodDescriptionSupervisorWorkerHeartbeat.deepCopy()
Supervisor.sendSupervisorWorkerHeartbeat_args.get_heartbeat()
Nimbus.sendSupervisorWorkerHeartbeat_args.get_heatbeat()
Modifier and TypeMethodDescriptionSupervisorWorkerHeartbeats.get_worker_heartbeats()
SupervisorWorkerHeartbeats.get_worker_heartbeats_iterator()
Modifier and TypeMethodDescriptionvoid
SupervisorWorkerHeartbeats.add_to_worker_heartbeats
(SupervisorWorkerHeartbeat elem) int
SupervisorWorkerHeartbeat.compareTo
(SupervisorWorkerHeartbeat other) boolean
SupervisorWorkerHeartbeat.equals
(SupervisorWorkerHeartbeat that) void
Nimbus.Client.send_sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat) void
Supervisor.Client.send_sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heartbeat) void
Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Nimbus.AsyncIface.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Nimbus.Client.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat) void
Nimbus.Iface.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat) Send supervisor local worker heartbeat when a supervisor is unreachablevoid
Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Supervisor.AsyncIface.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Supervisor.Client.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heartbeat) void
Supervisor.Iface.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heartbeat) Send worker heartbeat to local supervisorvoid
Supervisor.sendSupervisorWorkerHeartbeat_args.set_heartbeat
(SupervisorWorkerHeartbeat heartbeat) void
Nimbus.sendSupervisorWorkerHeartbeat_args.set_heatbeat
(SupervisorWorkerHeartbeat heatbeat) Modifier and TypeMethodDescriptionvoid
SupervisorWorkerHeartbeats.set_worker_heartbeats
(List<SupervisorWorkerHeartbeat> worker_heartbeats) ModifierConstructorDescriptionsendSupervisorWorkerHeartbeat_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.ModifierConstructorDescriptionSupervisorWorkerHeartbeats
(String supervisor_id, List<SupervisorWorkerHeartbeat> worker_heartbeats) -
Uses of SupervisorWorkerHeartbeat in org.apache.storm.stats
Modifier and TypeMethodDescriptionstatic SupervisorWorkerHeartbeat
StatsUtil.thriftifyRpcWorkerHb
(String stormId, List<Long> executorId) Used for local test.Modifier and TypeMethodDescriptionStatsUtil.convertWorkerBeats
(SupervisorWorkerHeartbeat workerHeartbeat) convertSupervisorWorkerHeartbeat
to nimbus local report executor heartbeats.