Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.cluster | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
NimbusSummary |
LocalCluster.getLeader() |
Modifier and Type | Method and Description |
---|---|
List<NimbusSummary> |
StormClusterStateImpl.nimbuses() |
List<NimbusSummary> |
IStormClusterState.nimbuses() |
Modifier and Type | Method and Description |
---|---|
void |
StormClusterStateImpl.addNimbusHost(String nimbusId,
NimbusSummary nimbusSummary) |
void |
IStormClusterState.addNimbusHost(String nimbusId,
NimbusSummary nimbusSummary) |
Modifier and Type | Method and Description |
---|---|
NimbusSummary |
Nimbus.getLeader() |
Modifier and Type | Method and Description |
---|---|
NimbusSummary |
NimbusSummary.deepCopy() |
NimbusSummary |
Nimbus.getLeader_result.get_success() |
NimbusSummary |
Nimbus.Iface.getLeader() |
NimbusSummary |
Nimbus.Client.getLeader() |
NimbusSummary |
Nimbus.AsyncClient.getLeader_call.getResult() |
NimbusSummary |
Nimbus.Client.recv_getLeader() |
Modifier and Type | Method and Description |
---|---|
Iterator<NimbusSummary> |
ClusterSummary.get_nimbuses_iterator() |
List<NimbusSummary> |
ClusterSummary.get_nimbuses() |
org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> |
Nimbus.AsyncProcessor.getLeader.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
Modifier and Type | Method and Description |
---|---|
void |
ClusterSummary.add_to_nimbuses(NimbusSummary elem) |
int |
NimbusSummary.compareTo(NimbusSummary other) |
boolean |
NimbusSummary.equals(NimbusSummary that) |
void |
Nimbus.getLeader_result.set_success(NimbusSummary success) |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.AsyncIface.getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) |
void |
Nimbus.AsyncClient.getLeader(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) |
void |
ClusterSummary.set_nimbuses(List<NimbusSummary> nimbuses) |
void |
Nimbus.AsyncProcessor.getLeader.start(I iface,
Nimbus.getLeader_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler) |
Constructor and Description |
---|
getLeader_result(NimbusSummary success,
AuthorizationException aze) |
NimbusSummary(NimbusSummary other)
Performs a deep copy on other.
|
Constructor and Description |
---|
ClusterSummary(List<SupervisorSummary> supervisors,
List<TopologySummary> topologies,
List<NimbusSummary> nimbuses) |
getLeader_call(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.