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) |
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.getTopologyInfo_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.getTopologyInfo_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() |
TopologyInfo |
Nimbus.AsyncClient.getTopologyInfo_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) |
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) |
StormTopology |
Nimbus.Iface.getUserTopology(String id) |
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() |
StormTopology |
Nimbus.Client.recv_getUserTopology() |
void |
Nimbus.Client.recv_killTopology() |
void |
Nimbus.Client.recv_killTopologyWithOpts() |
void |
Nimbus.Client.recv_rebalance() |
Constructor and Description |
---|
activate_result(NotAliveException e) |
deactivate_result(NotAliveException e) |
getTopology_result(StormTopology success,
NotAliveException e) |
getTopologyConf_result(String success,
NotAliveException e) |
getTopologyInfo_result(TopologyInfo success,
NotAliveException e) |
getUserTopology_result(StormTopology success,
NotAliveException e) |
killTopology_result(NotAliveException e) |
killTopologyWithOpts_result(NotAliveException e) |
NotAliveException(NotAliveException other)
Performs a deep copy on other.
|
rebalance_result(NotAliveException e,
InvalidTopologyException ite) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.