Package org.apache.storm.generated

Interface Supervisor.AsyncIface

All Known Implementing Classes:

Supervisor.AsyncClient

Enclosing class:

Supervisor

public static interface Supervisor.AsyncIface

Method Summary

Modifier and Type	Method	Description
void	getLocalAssignmentForStorm(String id, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler)
void	sendSupervisorAssignments(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)

Method Details

sendSupervisorAssignments

void sendSupervisorAssignments(SupervisorAssignments assignments,
 org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                        throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

getLocalAssignmentForStorm

void getLocalAssignmentForStorm(String id,
 org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler)
                         throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException

sendSupervisorWorkerHeartbeat

void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat,
 org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
                            throws org.apache.storm.thrift.TException

Throws:

org.apache.storm.thrift.TException