Uses of Class
org.apache.storm.generated.SupervisorAssignments

Packages that use SupervisorAssignments

Package	Description
org.apache.storm
org.apache.storm.daemon.nimbus
org.apache.storm.daemon.supervisor
org.apache.storm.daemon.supervisor.timer
org.apache.storm.generated
org.apache.storm.nimbus

Uses of SupervisorAssignments in org.apache.storm

Methods in org.apache.storm that return SupervisorAssignments

Modifier and Type	Method and Description
SupervisorAssignments	LocalCluster.getSupervisorAssignments(String node)

Uses of SupervisorAssignments in org.apache.storm.daemon.nimbus

Methods in org.apache.storm.daemon.nimbus that return SupervisorAssignments

Modifier and Type	Method and Description
SupervisorAssignments	Nimbus.getSupervisorAssignments(String nodeId)

Uses of SupervisorAssignments in org.apache.storm.daemon.supervisor

Methods in org.apache.storm.daemon.supervisor with parameters of type SupervisorAssignments

Modifier and Type	Method and Description
void	Supervisor.sendSupervisorAssignments(SupervisorAssignments assignments) Used for local cluster assignments distribution.

Uses of SupervisorAssignments in org.apache.storm.daemon.supervisor.timer

Methods in org.apache.storm.daemon.supervisor.timer that return types with arguments of type SupervisorAssignments

Modifier and Type	Method and Description
List<SupervisorAssignments>	SynchronizeAssignments.getAllAssignmentsFromNumaSupervisors(Nimbus.Iface nimbus, String node)

Constructors in org.apache.storm.daemon.supervisor.timer with parameters of type SupervisorAssignments

Constructor and Description
SynchronizeAssignments(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor.

Uses of SupervisorAssignments in org.apache.storm.generated

Methods in org.apache.storm.generated that return SupervisorAssignments

Modifier and Type	Method and Description
SupervisorAssignments	SupervisorAssignments.deepCopy()
SupervisorAssignments	Supervisor.sendSupervisorAssignments_args.get_assignments()
SupervisorAssignments	Nimbus.getSupervisorAssignments_result.get_success()
SupervisorAssignments	Nimbus.AsyncClient.getSupervisorAssignments_call.getResult()
SupervisorAssignments	Nimbus.Iface.getSupervisorAssignments(String node) Get assigned assignments for a specific supervisor
SupervisorAssignments	Nimbus.Client.getSupervisorAssignments(String node)
SupervisorAssignments	Nimbus.Client.recv_getSupervisorAssignments()

Methods in org.apache.storm.generated that return types with arguments of type SupervisorAssignments

Modifier and Type	Method and Description
org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments>	Nimbus.AsyncProcessor.getSupervisorAssignments.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid)

Methods in org.apache.storm.generated with parameters of type SupervisorAssignments

Modifier and Type	Method and Description
int	SupervisorAssignments.compareTo(SupervisorAssignments other)
boolean	SupervisorAssignments.equals(SupervisorAssignments that)
void	Supervisor.Client.send_sendSupervisorAssignments(SupervisorAssignments assignments)
void	Supervisor.Iface.sendSupervisorAssignments(SupervisorAssignments assignments) Send node specific assignments to supervisor
void	Supervisor.Client.sendSupervisorAssignments(SupervisorAssignments assignments)
void	Supervisor.AsyncIface.sendSupervisorAssignments(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Supervisor.AsyncClient.sendSupervisorAssignments(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
void	Supervisor.sendSupervisorAssignments_args.set_assignments(SupervisorAssignments assignments)
void	Nimbus.getSupervisorAssignments_result.set_success(SupervisorAssignments success)

Method parameters in org.apache.storm.generated with type arguments of type SupervisorAssignments

Modifier and Type	Method and Description
void	Nimbus.AsyncIface.getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler)
void	Nimbus.AsyncClient.getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler)
void	Nimbus.AsyncProcessor.getSupervisorAssignments.start(I iface, Nimbus.getSupervisorAssignments_args args, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler)

Constructors in org.apache.storm.generated with parameters of type SupervisorAssignments

Constructor and Description
getSupervisorAssignments_result(SupervisorAssignments success, AuthorizationException aze)
sendSupervisorAssignments_args(SupervisorAssignments assignments)
sendSupervisorAssignments_call(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport)
SupervisorAssignments(SupervisorAssignments other) Performs a deep copy on other.

Constructor parameters in org.apache.storm.generated with type arguments of type SupervisorAssignments

Constructor and Description
getSupervisorAssignments_call(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport)

Uses of SupervisorAssignments in org.apache.storm.nimbus

Methods in org.apache.storm.nimbus with parameters of type SupervisorAssignments

Modifier and Type	Method and Description
void	AssignmentDistributionService.addAssignmentsForNode(String node, String host, Integer serverPort, SupervisorAssignments assignments, StormMetricsRegistry metricsRegistry) Add an assignments for a node/supervisor for distribution.