Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
void |
LocalCluster.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) |
Modifier and Type | Method and Description |
---|---|
SupervisorWorkerHeartbeats |
SupervisorWorkerHeartbeats.deepCopy() |
SupervisorWorkerHeartbeats |
Nimbus.sendSupervisorWorkerHeartbeats_args.get_heartbeats() |
Modifier and Type | Method and Description |
---|---|
int |
SupervisorWorkerHeartbeats.compareTo(SupervisorWorkerHeartbeats other) |
boolean |
SupervisorWorkerHeartbeats.equals(SupervisorWorkerHeartbeats that) |
void |
Nimbus.Client.send_sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) |
void |
Nimbus.Iface.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)
Send supervisor worker heartbeats for a specific supervisor
|
void |
Nimbus.Client.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) |
void |
Nimbus.AsyncIface.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
Nimbus.AsyncClient.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats,
org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) |
void |
Nimbus.sendSupervisorWorkerHeartbeats_args.set_heartbeats(SupervisorWorkerHeartbeats heartbeats) |
Constructor and Description |
---|
sendSupervisorWorkerHeartbeats_args(SupervisorWorkerHeartbeats heartbeats) |
sendSupervisorWorkerHeartbeats_call(SupervisorWorkerHeartbeats heartbeats,
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) |
SupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats other)
Performs a deep copy on other.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.