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 © 2023 The Apache Software Foundation. All rights reserved.