| Package | Description | 
|---|---|
| org.apache.storm | |
| org.apache.storm.daemon.nimbus | |
| org.apache.storm.daemon.ui | |
| org.apache.storm.generated | |
| org.apache.storm.stats | 
| Modifier and Type | Method and Description | 
|---|---|
TopologyPageInfo | 
LocalCluster.getTopologyPageInfo(String id,
                   String window,
                   boolean isIncludeSys)  | 
| Modifier and Type | Method and Description | 
|---|---|
TopologyPageInfo | 
Nimbus.getTopologyPageInfo(String topoId,
                   String window,
                   boolean includeSys)  | 
| Modifier and Type | Method and Description | 
|---|---|
static Map<String,Object> | 
UIHelpers.getTopologySummary(TopologyPageInfo topologyPageInfo,
                  String window,
                  Map<String,Object> config,
                  String remoteUser)
getTopologySummary. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
TopologyPageInfo | 
TopologyPageInfo.deepCopy()  | 
TopologyPageInfo | 
Nimbus.getTopologyPageInfo_result.get_success()  | 
TopologyPageInfo | 
Nimbus.AsyncClient.getTopologyPageInfo_call.getResult()  | 
TopologyPageInfo | 
Nimbus.Iface.getTopologyPageInfo(String id,
                   String window,
                   boolean is_include_sys)  | 
TopologyPageInfo | 
Nimbus.Client.getTopologyPageInfo(String id,
                   String window,
                   boolean is_include_sys)  | 
TopologyPageInfo | 
Nimbus.Client.recv_getTopologyPageInfo()  | 
| Modifier and Type | Method and Description | 
|---|---|
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> | 
Nimbus.AsyncProcessor.getTopologyPageInfo.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
                int seqid)  | 
| Modifier and Type | Method and Description | 
|---|---|
int | 
TopologyPageInfo.compareTo(TopologyPageInfo other)  | 
boolean | 
TopologyPageInfo.equals(TopologyPageInfo that)  | 
void | 
Nimbus.getTopologyPageInfo_result.set_success(TopologyPageInfo success)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
Nimbus.AsyncIface.getTopologyPageInfo(String id,
                   String window,
                   boolean is_include_sys,
                   org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler)  | 
void | 
Nimbus.AsyncClient.getTopologyPageInfo(String id,
                   String window,
                   boolean is_include_sys,
                   org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler)  | 
void | 
Nimbus.AsyncProcessor.getTopologyPageInfo.start(I iface,
     Nimbus.getTopologyPageInfo_args args,
     org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> resultHandler)  | 
| Constructor and Description | 
|---|
getTopologyPageInfo_result(TopologyPageInfo success,
                          NotAliveException e,
                          AuthorizationException aze)  | 
TopologyPageInfo(TopologyPageInfo other)
Performs a deep copy on other. 
 | 
| Constructor and Description | 
|---|
getTopologyPageInfo_call(String id,
                        String window,
                        boolean is_include_sys,
                        org.apache.storm.thrift.async.AsyncMethodCallback<TopologyPageInfo> 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 | 
|---|---|
static TopologyPageInfo | 
StatsUtil.aggTopoExecsStats(String topologyId,
                 Map exec2nodePort,
                 Map task2component,
                 Map<List<Integer>,Map<String,Object>> beats,
                 StormTopology topology,
                 String window,
                 boolean includeSys,
                 IStormClusterState clusterState)
aggregate topo executors stats. 
 | 
Copyright © 2022 The Apache Software Foundation. All rights reserved.