Package org.apache.storm.generated
Class Supervisor.Client
java.lang.Object
org.apache.storm.thrift.TServiceClient
org.apache.storm.generated.Supervisor.Client
- All Implemented Interfaces:
- Supervisor.Iface
- Enclosing class:
- Supervisor
public static class Supervisor.Client
extends org.apache.storm.thrift.TServiceClient
implements Supervisor.Iface
- 
Nested Class SummaryNested Classes
- 
Field SummaryFields inherited from class org.apache.storm.thrift.TServiceClientiprot_, oprot_, seqid_
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionGet local assignment for a stormvoidvoidvoidvoidsend_sendSupervisorAssignments(SupervisorAssignments assignments) voidvoidsendSupervisorAssignments(SupervisorAssignments assignments) Send node specific assignments to supervisorvoidSend worker heartbeat to local supervisorMethods inherited from class org.apache.storm.thrift.TServiceClientgetInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway
- 
Constructor Details- 
Clientpublic Client(org.apache.storm.thrift.protocol.TProtocol prot) 
- 
Clientpublic Client(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TProtocol oprot) 
 
- 
- 
Method Details- 
sendSupervisorAssignmentspublic void sendSupervisorAssignments(SupervisorAssignments assignments) throws AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Supervisor.IfaceSend node specific assignments to supervisor- Specified by:
- sendSupervisorAssignmentsin interface- Supervisor.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_sendSupervisorAssignmentspublic void send_sendSupervisorAssignments(SupervisorAssignments assignments) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_sendSupervisorAssignmentspublic void recv_sendSupervisorAssignments() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getLocalAssignmentForStormpublic Assignment getLocalAssignmentForStorm(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Supervisor.IfaceGet local assignment for a storm- Specified by:
- getLocalAssignmentForStormin interface- Supervisor.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getLocalAssignmentForStorm- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getLocalAssignmentForStormpublic Assignment recv_getLocalAssignmentForStorm() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
sendSupervisorWorkerHeartbeatpublic void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Supervisor.IfaceSend worker heartbeat to local supervisor- Specified by:
- sendSupervisorWorkerHeartbeatin interface- Supervisor.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_sendSupervisorWorkerHeartbeatpublic void send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_sendSupervisorWorkerHeartbeatpublic void recv_sendSupervisorWorkerHeartbeat() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
 
-