Package org.apache.storm.generated
Interface Supervisor.Iface
- All Known Implementing Classes:
Supervisor.Client
- Enclosing class:
- Supervisor
public static interface Supervisor.Iface
-
Method Summary
Modifier and TypeMethodDescriptionGet local assignment for a stormvoidsendSupervisorAssignments(SupervisorAssignments assignments) Send node specific assignments to supervisorvoidSend worker heartbeat to local supervisor
-
Method Details
-
sendSupervisorAssignments
void sendSupervisorAssignments(SupervisorAssignments assignments) throws AuthorizationException, org.apache.storm.thrift.TException Send node specific assignments to supervisor- Parameters:
assignments-- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getLocalAssignmentForStorm
Assignment getLocalAssignmentForStorm(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Get local assignment for a storm- Parameters:
id-- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeat
void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws AuthorizationException, org.apache.storm.thrift.TException Send worker heartbeat to local supervisor- Parameters:
heartbeat-- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-