Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.daemon.ui | |
org.apache.storm.generated |
Modifier and Type | Method and Description |
---|---|
TopologySummary |
LocalCluster.getTopologySummary(String id) |
TopologySummary |
ILocalCluster.getTopologySummary(String id) |
TopologySummary |
LocalCluster.getTopologySummaryByName(String name) |
TopologySummary |
ILocalCluster.getTopologySummaryByName(String name) |
Modifier and Type | Method and Description |
---|---|
List<TopologySummary> |
LocalCluster.getTopologySummaries() |
List<TopologySummary> |
ILocalCluster.getTopologySummaries() |
Modifier and Type | Method and Description |
---|---|
TopologySummary |
Nimbus.getTopologySummary(String id) |
TopologySummary |
Nimbus.getTopologySummaryByName(String name) |
Modifier and Type | Method and Description |
---|---|
List<TopologySummary> |
Nimbus.getTopologySummaries() |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
UIHelpers.getTopologyMap(TopologySummary topologySummary)
getTopologyMap.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
UIHelpers.getAllTopologiesSummary(List<TopologySummary> topologies,
Map<String,Object> config)
getAllTopologiesSummary.
|
Modifier and Type | Method and Description |
---|---|
TopologySummary |
TopologySummary.deepCopy() |
TopologySummary |
Nimbus.getTopologySummaryByName_result.get_success() |
TopologySummary |
Nimbus.getTopologySummary_result.get_success() |
TopologySummary |
Nimbus.AsyncClient.getTopologySummaryByName_call.getResult() |
TopologySummary |
Nimbus.AsyncClient.getTopologySummary_call.getResult() |
TopologySummary |
Nimbus.Iface.getTopologySummary(String id) |
TopologySummary |
Nimbus.Client.getTopologySummary(String id) |
TopologySummary |
Nimbus.Iface.getTopologySummaryByName(String name) |
TopologySummary |
Nimbus.Client.getTopologySummaryByName(String name) |
TopologySummary |
Nimbus.Client.recv_getTopologySummary() |
TopologySummary |
Nimbus.Client.recv_getTopologySummaryByName() |
Modifier and Type | Method and Description |
---|---|
Iterator<TopologySummary> |
Nimbus.getTopologySummaries_result.get_success_iterator() |
List<TopologySummary> |
Nimbus.getTopologySummaries_result.get_success() |
Iterator<TopologySummary> |
ClusterSummary.get_topologies_iterator() |
List<TopologySummary> |
ClusterSummary.get_topologies() |
List<TopologySummary> |
Nimbus.AsyncClient.getTopologySummaries_call.getResult() |
org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> |
Nimbus.AsyncProcessor.getTopologySummaries.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> |
Nimbus.AsyncProcessor.getTopologySummaryByName.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> |
Nimbus.AsyncProcessor.getTopologySummary.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
List<TopologySummary> |
Nimbus.Iface.getTopologySummaries() |
List<TopologySummary> |
Nimbus.Client.getTopologySummaries() |
List<TopologySummary> |
Nimbus.Client.recv_getTopologySummaries() |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.getTopologySummaries_result.add_to_success(TopologySummary elem) |
void |
ClusterSummary.add_to_topologies(TopologySummary elem) |
int |
TopologySummary.compareTo(TopologySummary other) |
boolean |
TopologySummary.equals(TopologySummary that) |
void |
Nimbus.getTopologySummaryByName_result.set_success(TopologySummary success) |
void |
Nimbus.getTopologySummary_result.set_success(TopologySummary success) |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.AsyncIface.getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) |
void |
Nimbus.AsyncClient.getTopologySummaries(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) |
void |
Nimbus.AsyncIface.getTopologySummary(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
void |
Nimbus.AsyncClient.getTopologySummary(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
void |
Nimbus.AsyncIface.getTopologySummaryByName(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
void |
Nimbus.AsyncClient.getTopologySummaryByName(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
void |
Nimbus.getTopologySummaries_result.set_success(List<TopologySummary> success) |
void |
ClusterSummary.set_topologies(List<TopologySummary> topologies) |
void |
Nimbus.AsyncProcessor.getTopologySummaries.start(I iface,
Nimbus.getTopologySummaries_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler) |
void |
Nimbus.AsyncProcessor.getTopologySummary.start(I iface,
Nimbus.getTopologySummary_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
void |
Nimbus.AsyncProcessor.getTopologySummaryByName.start(I iface,
Nimbus.getTopologySummaryByName_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler) |
Constructor and Description |
---|
getTopologySummary_result(TopologySummary success,
NotAliveException e,
AuthorizationException aze) |
getTopologySummaryByName_result(TopologySummary success,
NotAliveException e,
AuthorizationException aze) |
TopologySummary(TopologySummary other)
Performs a deep copy on other.
|
Constructor and Description |
---|
ClusterSummary(List<SupervisorSummary> supervisors,
List<TopologySummary> topologies,
List<NimbusSummary> nimbuses) |
getTopologySummaries_call(org.apache.storm.thrift.async.AsyncMethodCallback<List<TopologySummary>> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
getTopologySummaries_result(List<TopologySummary> success,
AuthorizationException aze) |
getTopologySummary_call(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
getTopologySummaryByName_call(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologySummary> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.