Uses of Class
org.apache.storm.generated.SupervisorAssignments
Packages that use SupervisorAssignments
Package
Description
-
Uses of SupervisorAssignments in org.apache.storm
Methods in org.apache.storm that return SupervisorAssignments -
Uses of SupervisorAssignments in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus that return SupervisorAssignments -
Uses of SupervisorAssignments in org.apache.storm.daemon.supervisor
Methods in org.apache.storm.daemon.supervisor with parameters of type SupervisorAssignmentsModifier and TypeMethodDescriptionvoid
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 SupervisorAssignmentsModifier and TypeMethodDescriptionSynchronizeAssignments.getAllAssignmentsFromNumaSupervisors
(Nimbus.Iface nimbus, String node) Constructors in org.apache.storm.daemon.supervisor.timer with parameters of type SupervisorAssignmentsModifierConstructorDescriptionSynchronizeAssignments
(Supervisor supervisor, SupervisorAssignments assignments, ReadClusterState readClusterState) Constructor. -
Uses of SupervisorAssignments in org.apache.storm.generated
Methods in org.apache.storm.generated that return SupervisorAssignmentsModifier 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()
Methods in org.apache.storm.generated that return types with arguments of type SupervisorAssignmentsModifier and TypeMethodDescriptionorg.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 SupervisorAssignmentsModifier 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) Method parameters in org.apache.storm.generated with type arguments of type SupervisorAssignmentsModifier 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) Constructors in org.apache.storm.generated with parameters of type SupervisorAssignmentsModifierConstructorDescriptionsendSupervisorAssignments_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.Constructor parameters in org.apache.storm.generated with type arguments of type SupervisorAssignmentsModifierConstructorDescriptiongetSupervisorAssignments_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 SupervisorAssignmentsModifier and TypeMethodDescriptionvoid
AssignmentDistributionService.addAssignmentsForNode
(String node, String host, Integer serverPort, SupervisorAssignments assignments, StormMetricsRegistry metricsRegistry) Add an assignments for a node/supervisor for distribution.