Uses of Class
org.apache.storm.generated.SupervisorWorkerHeartbeat

Packages that use SupervisorWorkerHeartbeat

Package	Description
org.apache.storm
org.apache.storm.daemon.nimbus
org.apache.storm.generated
org.apache.storm.stats

Uses of SupervisorWorkerHeartbeat in org.apache.storm

Methods in org.apache.storm with parameters of type SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
void	LocalCluster.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)

Uses of SupervisorWorkerHeartbeat in org.apache.storm.daemon.nimbus

Methods in org.apache.storm.daemon.nimbus with parameters of type SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
void	Nimbus.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat hb)
void	HeartbeatCache.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 SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
SupervisorWorkerHeartbeat	SupervisorWorkerHeartbeat.deepCopy()
SupervisorWorkerHeartbeat	Supervisor.sendSupervisorWorkerHeartbeat_args.get_heartbeat()
SupervisorWorkerHeartbeat	Nimbus.sendSupervisorWorkerHeartbeat_args.get_heatbeat()

Methods in org.apache.storm.generated that return types with arguments of type SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
Iterator<SupervisorWorkerHeartbeat>	SupervisorWorkerHeartbeats.get_worker_heartbeats_iterator()
List<SupervisorWorkerHeartbeat>	SupervisorWorkerHeartbeats.get_worker_heartbeats()

Methods in org.apache.storm.generated with parameters of type SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
void	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.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) Send supervisor local worker heartbeat when a supervisor is unreachable
void	Nimbus.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)
void	Supervisor.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) Send worker heartbeat to local supervisor
void	Supervisor.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)
void	Nimbus.AsyncIface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Supervisor.AsyncIface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Supervisor.sendSupervisorWorkerHeartbeat_args.set_heartbeat(SupervisorWorkerHeartbeat heartbeat)
void	Nimbus.sendSupervisorWorkerHeartbeat_args.set_heatbeat(SupervisorWorkerHeartbeat heatbeat)

Method parameters in org.apache.storm.generated with type arguments of type SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
void	SupervisorWorkerHeartbeats.set_worker_heartbeats(List<SupervisorWorkerHeartbeat> worker_heartbeats)

Constructors in org.apache.storm.generated with parameters of type SupervisorWorkerHeartbeat

Constructor and Description
sendSupervisorWorkerHeartbeat_args(SupervisorWorkerHeartbeat heatbeat)
sendSupervisorWorkerHeartbeat_args(SupervisorWorkerHeartbeat heartbeat)
sendSupervisorWorkerHeartbeat_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)
SupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat other) Performs a deep copy on other.

Constructor parameters in org.apache.storm.generated with type arguments of type SupervisorWorkerHeartbeat

Constructor and Description
SupervisorWorkerHeartbeats(String supervisor_id, List<SupervisorWorkerHeartbeat> worker_heartbeats)

Uses of SupervisorWorkerHeartbeat in org.apache.storm.stats

Methods in org.apache.storm.stats that return SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
static SupervisorWorkerHeartbeat	StatsUtil.thriftifyRpcWorkerHb(String stormId, List<Long> executorId) Used for local test.

Methods in org.apache.storm.stats with parameters of type SupervisorWorkerHeartbeat

Modifier and Type	Method and Description
static Map<List<Integer>,Map<String,Object>>	StatsUtil.convertWorkerBeats(SupervisorWorkerHeartbeat workerHeartbeat) convert SupervisorWorkerHeartbeat to nimbus local report executor heartbeats.