public static class Supervisor.Client extends org.apache.storm.thrift.TServiceClient implements Supervisor.Iface
| Modifier and Type | Class and Description |
|---|---|
static class |
Supervisor.Client.Factory |
| Constructor and Description |
|---|
Client(org.apache.storm.thrift.protocol.TProtocol prot) |
Client(org.apache.storm.thrift.protocol.TProtocol iprot,
org.apache.storm.thrift.protocol.TProtocol oprot) |
| Modifier and Type | Method and Description |
|---|---|
Assignment |
getLocalAssignmentForStorm(String id)
Get local assignment for a storm
|
Assignment |
recv_getLocalAssignmentForStorm() |
void |
recv_sendSupervisorAssignments() |
void |
recv_sendSupervisorWorkerHeartbeat() |
void |
send_getLocalAssignmentForStorm(String id) |
void |
send_sendSupervisorAssignments(SupervisorAssignments assignments) |
void |
send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) |
void |
sendSupervisorAssignments(SupervisorAssignments assignments)
Send node specific assignments to supervisor
|
void |
sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)
Send worker heartbeat to local supervisor
|
public Client(org.apache.storm.thrift.protocol.TProtocol prot)
public Client(org.apache.storm.thrift.protocol.TProtocol iprot,
org.apache.storm.thrift.protocol.TProtocol oprot)
public void sendSupervisorAssignments(SupervisorAssignments assignments) throws AuthorizationException, org.apache.storm.thrift.TException
Supervisor.IfaceSend node specific assignments to supervisor
sendSupervisorAssignments in interface Supervisor.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_sendSupervisorAssignments(SupervisorAssignments assignments) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_sendSupervisorAssignments()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic Assignment getLocalAssignmentForStorm(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
Supervisor.IfaceGet local assignment for a storm
getLocalAssignmentForStorm in interface Supervisor.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getLocalAssignmentForStorm(String id) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic Assignment recv_getLocalAssignmentForStorm() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws AuthorizationException, org.apache.storm.thrift.TException
Supervisor.IfaceSend worker heartbeat to local supervisor
sendSupervisorWorkerHeartbeat in interface Supervisor.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_sendSupervisorWorkerHeartbeat()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.