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 and 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 Detail

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