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
Nested Classes Modifier and Type Class Description static classSupervisor.Client.Factory
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description AssignmentgetLocalAssignmentForStorm(String id)Get local assignment for a stormAssignmentrecv_getLocalAssignmentForStorm()voidrecv_sendSupervisorAssignments()voidrecv_sendSupervisorWorkerHeartbeat()voidsend_getLocalAssignmentForStorm(String id)voidsend_sendSupervisorAssignments(SupervisorAssignments assignments)voidsend_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)voidsendSupervisorAssignments(SupervisorAssignments assignments)Send node specific assignments to supervisorvoidsendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)Send worker heartbeat to local supervisor
-
-
-
Method Detail
-
sendSupervisorAssignments
public 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 interfaceSupervisor.Iface- Throws:
AuthorizationExceptionorg.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:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getLocalAssignmentForStorm
public 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 interfaceSupervisor.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getLocalAssignmentForStorm
public void send_getLocalAssignmentForStorm(String id) throws org.apache.storm.thrift.TException
- Throws:
org.apache.storm.thrift.TException
-
recv_getLocalAssignmentForStorm
public Assignment recv_getLocalAssignmentForStorm() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeat
public 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 interfaceSupervisor.Iface- Throws:
AuthorizationExceptionorg.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:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
-