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 TypeMethodDescriptionvoidSupervisor.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 TypeMethodDescriptionintSupervisorAssignments.compareTo(SupervisorAssignments other) booleanSupervisorAssignments.equals(SupervisorAssignments that) voidSupervisor.Client.send_sendSupervisorAssignments(SupervisorAssignments assignments) voidSupervisor.AsyncClient.sendSupervisorAssignments(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidSupervisor.AsyncIface.sendSupervisorAssignments(SupervisorAssignments assignments, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler) voidSupervisor.Client.sendSupervisorAssignments(SupervisorAssignments assignments) voidSupervisor.Iface.sendSupervisorAssignments(SupervisorAssignments assignments) Send node specific assignments to supervisorvoidSupervisor.sendSupervisorAssignments_args.set_assignments(SupervisorAssignments assignments) voidNimbus.getSupervisorAssignments_result.set_success(SupervisorAssignments success) Method parameters in org.apache.storm.generated with type arguments of type SupervisorAssignmentsModifier and TypeMethodDescriptionvoidNimbus.AsyncClient.getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) voidNimbus.AsyncIface.getSupervisorAssignments(String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler) voidNimbus.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 TypeMethodDescriptionvoidAssignmentDistributionService.addAssignmentsForNode(String node, String host, Integer serverPort, SupervisorAssignments assignments, StormMetricsRegistry metricsRegistry) Add an assignments for a node/supervisor for distribution.