Package | Description |
---|---|
org.apache.storm | |
org.apache.storm.daemon.nimbus | |
org.apache.storm.daemon.ui | |
org.apache.storm.generated | |
org.apache.storm.utils |
Modifier and Type | Method and Description |
---|---|
TopologyInfo |
LocalCluster.getTopologyInfo(String id) |
TopologyInfo |
ILocalCluster.getTopologyInfo(String id)
Get the state of a topology.
|
TopologyInfo |
LocalCluster.getTopologyInfoByName(String name) |
TopologyInfo |
ILocalCluster.getTopologyInfoByName(String name)
Get the state of a topology.
|
TopologyInfo |
LocalCluster.getTopologyInfoByNameWithOpts(String name,
GetInfoOptions options) |
TopologyInfo |
ILocalCluster.getTopologyInfoByNameWithOpts(String name,
GetInfoOptions options)
Get the state of a topology.
|
TopologyInfo |
LocalCluster.getTopologyInfoWithOpts(String id,
GetInfoOptions options) |
TopologyInfo |
ILocalCluster.getTopologyInfoWithOpts(String id,
GetInfoOptions options)
Get the state of a topology.
|
Modifier and Type | Method and Description |
---|---|
void |
ISubmitterHook.notify(TopologyInfo topologyInfo,
Map<String,Object> topoConf,
StormTopology topology) |
Modifier and Type | Method and Description |
---|---|
TopologyInfo |
Nimbus.getTopologyInfo(String id) |
TopologyInfo |
Nimbus.getTopologyInfoByName(String name) |
TopologyInfo |
Nimbus.getTopologyInfoByNameWithOpts(String name,
GetInfoOptions options) |
TopologyInfo |
Nimbus.getTopologyInfoWithOpts(String topoId,
GetInfoOptions options) |
Modifier and Type | Method and Description |
---|---|
static Map<String,Object> |
UIHelpers.getTopologyWorkers(TopologyInfo topologyInfo,
Map config)
getTopologyWorkers.
|
Modifier and Type | Method and Description |
---|---|
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> |
Nimbus.AsyncProcessor.getTopologyInfoByName.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> |
Nimbus.AsyncProcessor.getTopologyInfo.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> |
Nimbus.AsyncProcessor.getTopologyInfoByNameWithOpts.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> |
Nimbus.AsyncProcessor.getTopologyInfoWithOpts.getResultHandler(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
Modifier and Type | Method and Description |
---|---|
int |
TopologyInfo.compareTo(TopologyInfo other) |
boolean |
TopologyInfo.equals(TopologyInfo that) |
void |
Nimbus.getTopologyInfoByName_result.set_success(TopologyInfo success) |
void |
Nimbus.getTopologyInfo_result.set_success(TopologyInfo success) |
void |
Nimbus.getTopologyInfoByNameWithOpts_result.set_success(TopologyInfo success) |
void |
Nimbus.getTopologyInfoWithOpts_result.set_success(TopologyInfo success) |
Modifier and Type | Method and Description |
---|---|
void |
Nimbus.AsyncIface.getTopologyInfo(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncClient.getTopologyInfo(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncIface.getTopologyInfoByName(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncClient.getTopologyInfoByName(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncIface.getTopologyInfoByNameWithOpts(String name,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncClient.getTopologyInfoByNameWithOpts(String name,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncIface.getTopologyInfoWithOpts(String id,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncClient.getTopologyInfoWithOpts(String id,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncProcessor.getTopologyInfo.start(I iface,
Nimbus.getTopologyInfo_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncProcessor.getTopologyInfoByName.start(I iface,
Nimbus.getTopologyInfoByName_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncProcessor.getTopologyInfoByNameWithOpts.start(I iface,
Nimbus.getTopologyInfoByNameWithOpts_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
void |
Nimbus.AsyncProcessor.getTopologyInfoWithOpts.start(I iface,
Nimbus.getTopologyInfoWithOpts_args args,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler) |
Constructor and Description |
---|
getTopologyInfo_result(TopologyInfo success,
NotAliveException e,
AuthorizationException aze) |
getTopologyInfoByName_result(TopologyInfo success,
NotAliveException e,
AuthorizationException aze) |
getTopologyInfoByNameWithOpts_result(TopologyInfo success,
NotAliveException e,
AuthorizationException aze) |
getTopologyInfoWithOpts_result(TopologyInfo success,
NotAliveException e,
AuthorizationException aze) |
TopologyInfo(TopologyInfo other)
Performs a deep copy on other.
|
Constructor and Description |
---|
getTopologyInfo_call(String id,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
getTopologyInfoByName_call(String name,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
getTopologyInfoByNameWithOpts_call(String name,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler,
org.apache.storm.thrift.async.TAsyncClient client,
org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.storm.thrift.transport.TNonblockingTransport transport) |
getTopologyInfoWithOpts_call(String id,
GetInfoOptions options,
org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> 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 TopologyInfo |
Utils.getTopologyInfo(String name,
String asUser,
Map<String,Object> topoConf) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.