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 Summary
-
Field Summary
Fields inherited from class org.apache.storm.thrift.TServiceClient
iprot_, oprot_, seqid_
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionGet local assignment for a stormvoid
void
void
void
send_sendSupervisorAssignments
(SupervisorAssignments assignments) void
void
sendSupervisorAssignments
(SupervisorAssignments assignments) Send node specific assignments to supervisorvoid
Send worker heartbeat to local supervisorMethods inherited from class org.apache.storm.thrift.TServiceClient
getInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway
-
Constructor Details
-
Client
public Client(org.apache.storm.thrift.protocol.TProtocol prot) -
Client
public Client(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TProtocol oprot)
-
-
Method Details
-
sendSupervisorAssignments
public void sendSupervisorAssignments(SupervisorAssignments assignments) throws AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Supervisor.Iface
Send node specific assignments to supervisor- Specified by:
sendSupervisorAssignments
in interfaceSupervisor.Iface
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
send_sendSupervisorAssignments
public void send_sendSupervisorAssignments(SupervisorAssignments assignments) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_sendSupervisorAssignments
public void recv_sendSupervisorAssignments() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
getLocalAssignmentForStorm
public Assignment getLocalAssignmentForStorm(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Supervisor.Iface
Get local assignment for a storm- Specified by:
getLocalAssignmentForStorm
in interfaceSupervisor.Iface
- Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
send_getLocalAssignmentForStorm
- Throws:
org.apache.storm.thrift.TException
-
recv_getLocalAssignmentForStorm
public Assignment recv_getLocalAssignmentForStorm() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveException
AuthorizationException
org.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeat
public void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Supervisor.Iface
Send worker heartbeat to local supervisor- Specified by:
sendSupervisorWorkerHeartbeat
in interfaceSupervisor.Iface
- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-
send_sendSupervisorWorkerHeartbeat
public void send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_sendSupervisorWorkerHeartbeat
public void recv_sendSupervisorWorkerHeartbeat() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationException
org.apache.storm.thrift.TException
-