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 |
---|---|
ComponentPageInfo |
LocalCluster.getComponentPageInfo(String topologyId,
String componentId,
String window,
boolean isIncludeSys) |
Modifier and Type | Method and Description |
---|---|
ComponentPageInfo |
Nimbus.getComponentPageInfo(String topoId,
String componentId,
String window,
boolean includeSys) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
UIHelpers.unpackBoltPageInfo(ComponentPageInfo componentPageInfo,
String topologyId,
String window,
boolean sys,
Map config)
unpackBoltPageInfo.
|
static Map<String,Object> |
UIHelpers.unpackSpoutPageInfo(ComponentPageInfo componentPageInfo,
String topologyId,
String window,
boolean sys,
Map config)
unpackSpoutPageInfo.
|
Modifier and Type | Method and Description |
---|---|
ComponentPageInfo |
ComponentPageInfo.deepCopy() |
ComponentPageInfo |
Nimbus.getComponentPageInfo_result.get_success() |
ComponentPageInfo |
Nimbus.Iface.getComponentPageInfo(String topology_id,
String component_id,
String window,
boolean is_include_sys) |
ComponentPageInfo |
Nimbus.Client.getComponentPageInfo(String topology_id,
String component_id,
String window,
boolean is_include_sys) |
ComponentPageInfo |
Nimbus.AsyncClient.getComponentPageInfo_call.getResult() |
ComponentPageInfo |
Nimbus.Client.recv_getComponentPageInfo() |
Modifier and Type | Method and Description |
---|---|
org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> |
Nimbus.AsyncProcessor.getComponentPageInfo.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
Modifier and Type | Method and Description |
---|---|
int |
ComponentPageInfo.compareTo(ComponentPageInfo other) |
boolean |
ComponentPageInfo.equals(ComponentPageInfo that) |
void |
Nimbus.getComponentPageInfo_result.set_success(ComponentPageInfo success) |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.AsyncIface.getComponentPageInfo(String topology_id,
String component_id,
String window,
boolean is_include_sys,
org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) |
void |
Nimbus.AsyncClient.getComponentPageInfo(String topology_id,
String component_id,
String window,
boolean is_include_sys,
org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) |
void |
Nimbus.AsyncProcessor.getComponentPageInfo.start(I iface,
Nimbus.getComponentPageInfo_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> resultHandler) |
Constructor and Description |
---|
ComponentPageInfo(ComponentPageInfo other)
Performs a deep copy on other.
|
getComponentPageInfo_result(ComponentPageInfo success,
NotAliveException e,
AuthorizationException aze) |
Constructor and Description |
---|
getComponentPageInfo_call(String topology_id,
String component_id,
String window,
boolean is_include_sys,
org.apache.storm.thrift.async.AsyncMethodCallback<ComponentPageInfo> 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 ComponentPageInfo |
StatsUtil.aggCompExecsStats(Map exec2hostPort,
Map task2component,
Map<List<Integer>,Map<String,Object>> beats,
String window,
boolean includeSys,
String topologyId,
StormTopology topology,
String componentId)
aggregate component executor stats.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.