| Package | Description |
|---|---|
| backtype.storm | |
| backtype.storm.generated |
| Modifier and Type | Method and Description |
|---|---|
void |
ILocalCluster.activate(String topologyName) |
void |
ILocalCluster.deactivate(String topologyName) |
void |
ILocalCluster.killTopology(String topologyName) |
void |
ILocalCluster.killTopologyWithOpts(String name,
KillOptions options) |
static void |
StormSubmitter.pushCredentials(String name,
Map stormConf,
Map<String,String> credentials)
Push a new set of credentials to the running topology.
|
void |
ILocalCluster.rebalance(String name,
RebalanceOptions options) |
| Modifier and Type | Method and Description |
|---|---|
NotAliveException |
NotAliveException.deepCopy() |
NotAliveException |
Nimbus.killTopology_result.get_e() |
NotAliveException |
Nimbus.killTopologyWithOpts_result.get_e() |
NotAliveException |
Nimbus.activate_result.get_e() |
NotAliveException |
Nimbus.deactivate_result.get_e() |
NotAliveException |
Nimbus.rebalance_result.get_e() |
NotAliveException |
Nimbus.uploadNewCredentials_result.get_e() |
NotAliveException |
Nimbus.getTopologyInfo_result.get_e() |
NotAliveException |
Nimbus.getTopologyInfoWithOpts_result.get_e() |
NotAliveException |
Nimbus.getTopologyConf_result.get_e() |
NotAliveException |
Nimbus.getTopology_result.get_e() |
NotAliveException |
Nimbus.getUserTopology_result.get_e() |
| Modifier and Type | Method and Description |
|---|---|
int |
NotAliveException.compareTo(NotAliveException other) |
boolean |
NotAliveException.equals(NotAliveException that) |
void |
Nimbus.killTopology_result.set_e(NotAliveException e) |
void |
Nimbus.killTopologyWithOpts_result.set_e(NotAliveException e) |
void |
Nimbus.activate_result.set_e(NotAliveException e) |
void |
Nimbus.deactivate_result.set_e(NotAliveException e) |
void |
Nimbus.rebalance_result.set_e(NotAliveException e) |
void |
Nimbus.uploadNewCredentials_result.set_e(NotAliveException e) |
void |
Nimbus.getTopologyInfo_result.set_e(NotAliveException e) |
void |
Nimbus.getTopologyInfoWithOpts_result.set_e(NotAliveException e) |
void |
Nimbus.getTopologyConf_result.set_e(NotAliveException e) |
void |
Nimbus.getTopology_result.set_e(NotAliveException e) |
void |
Nimbus.getUserTopology_result.set_e(NotAliveException e) |
| Modifier and Type | Method and Description |
|---|---|
void |
Nimbus.Iface.activate(String name) |
void |
Nimbus.Client.activate(String name) |
void |
Nimbus.Iface.deactivate(String name) |
void |
Nimbus.Client.deactivate(String name) |
void |
Nimbus.AsyncClient.killTopology_call.getResult() |
void |
Nimbus.AsyncClient.killTopologyWithOpts_call.getResult() |
void |
Nimbus.AsyncClient.activate_call.getResult() |
void |
Nimbus.AsyncClient.deactivate_call.getResult() |
void |
Nimbus.AsyncClient.rebalance_call.getResult() |
void |
Nimbus.AsyncClient.uploadNewCredentials_call.getResult() |
TopologyInfo |
Nimbus.AsyncClient.getTopologyInfo_call.getResult() |
TopologyInfo |
Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult() |
String |
Nimbus.AsyncClient.getTopologyConf_call.getResult() |
StormTopology |
Nimbus.AsyncClient.getTopology_call.getResult() |
StormTopology |
Nimbus.AsyncClient.getUserTopology_call.getResult() |
StormTopology |
Nimbus.Iface.getTopology(String id)
Returns the compiled topology that contains ackers and metrics consumsers.
|
StormTopology |
Nimbus.Client.getTopology(String id) |
String |
Nimbus.Iface.getTopologyConf(String id) |
String |
Nimbus.Client.getTopologyConf(String id) |
TopologyInfo |
Nimbus.Iface.getTopologyInfo(String id) |
TopologyInfo |
Nimbus.Client.getTopologyInfo(String id) |
TopologyInfo |
Nimbus.Iface.getTopologyInfoWithOpts(String id,
GetInfoOptions options) |
TopologyInfo |
Nimbus.Client.getTopologyInfoWithOpts(String id,
GetInfoOptions options) |
StormTopology |
Nimbus.Iface.getUserTopology(String id)
Returns the user specified topology as submitted originally.
|
StormTopology |
Nimbus.Client.getUserTopology(String id) |
void |
Nimbus.Iface.killTopology(String name) |
void |
Nimbus.Client.killTopology(String name) |
void |
Nimbus.Iface.killTopologyWithOpts(String name,
KillOptions options) |
void |
Nimbus.Client.killTopologyWithOpts(String name,
KillOptions options) |
void |
Nimbus.Iface.rebalance(String name,
RebalanceOptions options) |
void |
Nimbus.Client.rebalance(String name,
RebalanceOptions options) |
void |
Nimbus.Client.recv_activate() |
void |
Nimbus.Client.recv_deactivate() |
StormTopology |
Nimbus.Client.recv_getTopology() |
String |
Nimbus.Client.recv_getTopologyConf() |
TopologyInfo |
Nimbus.Client.recv_getTopologyInfo() |
TopologyInfo |
Nimbus.Client.recv_getTopologyInfoWithOpts() |
StormTopology |
Nimbus.Client.recv_getUserTopology() |
void |
Nimbus.Client.recv_killTopology() |
void |
Nimbus.Client.recv_killTopologyWithOpts() |
void |
Nimbus.Client.recv_rebalance() |
void |
Nimbus.Client.recv_uploadNewCredentials() |
void |
Nimbus.Iface.uploadNewCredentials(String name,
Credentials creds) |
void |
Nimbus.Client.uploadNewCredentials(String name,
Credentials creds) |
Copyright © 2015. All rights reserved.