Uses of Class
org.apache.storm.generated.SupervisorAssignments
Package
Description
-
Uses of SupervisorAssignments in org.apache.storm
-
Uses of SupervisorAssignments in org.apache.storm.daemon.nimbus
-
Uses of SupervisorAssignments in org.apache.storm.daemon.supervisor
Modifier and TypeMethodDescriptionvoid
Supervisor.sendSupervisorAssignments
(SupervisorAssignments assignments) Used for local cluster assignments distribution. -
Uses of SupervisorAssignments in org.apache.storm.daemon.supervisor.timer
Modifier and TypeMethodDescriptionSynchronizeAssignments.getAllAssignmentsFromNumaSupervisors
(Nimbus.Iface nimbus, String node) ModifierConstructorDescriptionSynchronizeAssignments
(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor. -
Uses of SupervisorAssignments in org.apache.storm.generated
Modifier and TypeMethodDescriptionSupervisorAssignments.deepCopy()
Supervisor.sendSupervisorAssignments_args.get_assignments()
Nimbus.getSupervisorAssignments_result.get_success()
Nimbus.AsyncClient.getSupervisorAssignments_call.getResult()
Nimbus.Client.getSupervisorAssignments
(String node) Nimbus.Iface.getSupervisorAssignments
(String node) Get assigned assignments for a specific supervisorNimbus.Client.recv_getSupervisorAssignments()
Modifier and TypeMethodDescriptionorg.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments>
Nimbus.AsyncProcessor.getSupervisorAssignments.getResultHandler
(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid) Modifier and TypeMethodDescriptionint
SupervisorAssignments.compareTo
(SupervisorAssignments other) boolean
SupervisorAssignments.equals
(SupervisorAssignments that) void
Supervisor.Client.send_sendSupervisorAssignments
(SupervisorAssignments assignments) void
Supervisor.AsyncClient.sendSupervisorAssignments
(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Supervisor.AsyncIface.sendSupervisorAssignments
(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) void
Supervisor.Client.sendSupervisorAssignments
(SupervisorAssignments assignments) void
Supervisor.Iface.sendSupervisorAssignments
(SupervisorAssignments assignments) Send node specific assignments to supervisorvoid
Supervisor.sendSupervisorAssignments_args.set_assignments
(SupervisorAssignments assignments) void
Nimbus.getSupervisorAssignments_result.set_success
(SupervisorAssignments success) Modifier and TypeMethodDescriptionvoid
Nimbus.AsyncClient.getSupervisorAssignments
(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) void
Nimbus.AsyncIface.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) ModifierConstructorDescriptionsendSupervisorAssignments_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) Performs a deep copy on other.ModifierConstructorDescriptiongetSupervisorAssignments_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
Modifier and TypeMethodDescriptionvoid
AssignmentDistributionService.addAssignmentsForNode
(String node, String host, Integer serverPort, SupervisorAssignments assignments, StormMetricsRegistry metricsRegistry) Add an assignments for a node/supervisor for distribution.