Uses of Class
org.apache.storm.generated.SupervisorAssignments
-
-
Uses of SupervisorAssignments in org.apache.storm
Methods in org.apache.storm that return SupervisorAssignments Modifier and Type Method 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 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 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 Description List<SupervisorAssignments>
SynchronizeAssignments. getAllAssignmentsFromNumaSupervisors(Nimbus.Iface nimbus, String node)
Constructors in org.apache.storm.daemon.supervisor.timer with parameters of type SupervisorAssignments Constructor 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 Description SupervisorAssignments
SupervisorAssignments. deepCopy()
SupervisorAssignments
Supervisor.sendSupervisorAssignments_args. get_assignments()
SupervisorAssignments
Nimbus.getSupervisorAssignments_result. get_success()
SupervisorAssignments
Nimbus.AsyncClient.getSupervisorAssignments_call. getResult()
SupervisorAssignments
Nimbus.Client. getSupervisorAssignments(String node)
SupervisorAssignments
Nimbus.Iface. getSupervisorAssignments(String node)
Get assigned assignments for a specific supervisorSupervisorAssignments
Nimbus.Client. recv_getSupervisorAssignments()
Methods in org.apache.storm.generated that return types with arguments of type SupervisorAssignments Modifier and Type Method 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 Description int
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 SupervisorAssignments Modifier and Type Method Description void
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 SupervisorAssignments Constructor 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 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 Description void
AssignmentDistributionService. addAssignmentsForNode(String node, String host, Integer serverPort, SupervisorAssignments assignments, StormMetricsRegistry metricsRegistry)
Add an assignments for a node/supervisor for distribution.
-