Modifier and Type | Method and Description |
---|---|
SupervisorAssignments |
LocalCluster.getSupervisorAssignments(String node) |
Modifier and Type | Method and Description |
---|---|
SupervisorAssignments |
Nimbus.getSupervisorAssignments(String node) |
Modifier and Type | Method and Description |
---|---|
void |
Supervisor.sendSupervisorAssignments(SupervisorAssignments assignments)
Used for local cluster assignments distribution.
|
Constructor and Description |
---|
SynchronizeAssignments(Supervisor supervisor,
SupervisorAssignments assignments,
ReadClusterState readClusterState)
Constructor.
|
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() |
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) |
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) |
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) |
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 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) |
Modifier and Type | Method and Description |
---|---|
void |
AssignmentDistributionService.addAssignmentsForNode(String node,
String host,
Integer serverPort,
SupervisorAssignments assignments)
Add an assignments for a node/supervisor for distribution.
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.