public static interface Supervisor.Iface
| Modifier and Type | Method and Description |
|---|---|
Assignment |
getLocalAssignmentForStorm(String id)
Get local assignment for a storm
|
void |
sendSupervisorAssignments(SupervisorAssignments assignments)
Send node specific assignments to supervisor
|
void |
sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)
Send worker heartbeat to local supervisor
|
void sendSupervisorAssignments(SupervisorAssignments assignments) throws AuthorizationException, org.apache.storm.thrift.TException
Send node specific assignments to supervisor
assignments - AuthorizationExceptionorg.apache.storm.thrift.TExceptionAssignment getLocalAssignmentForStorm(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
Get local assignment for a storm
id - NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionvoid sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) throws AuthorizationException, org.apache.storm.thrift.TException
Send worker heartbeat to local supervisor
heartbeat - AuthorizationExceptionorg.apache.storm.thrift.TExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.