Package | Description |
---|---|
org.apache.storm | |
org.apache.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.debug_result.get_e() |
NotAliveException |
Nimbus.uploadNewCredentials_result.get_e() |
NotAliveException |
Nimbus.getTopologyInfo_result.get_e() |
NotAliveException |
Nimbus.getTopologyInfoWithOpts_result.get_e() |
NotAliveException |
Nimbus.getTopologyPageInfo_result.get_e() |
NotAliveException |
Nimbus.getSupervisorPageInfo_result.get_e() |
NotAliveException |
Nimbus.getComponentPageInfo_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.debug_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.getTopologyPageInfo_result.set_e(NotAliveException e) |
void |
Nimbus.getSupervisorPageInfo_result.set_e(NotAliveException e) |
void |
Nimbus.getComponentPageInfo_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.Iface.debug(String name,
String component,
boolean enable,
double samplingPercentage)
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.
|
void |
Nimbus.Client.debug(String name,
String component,
boolean enable,
double samplingPercentage) |
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) |
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.debug_call.getResult() |
Void |
Nimbus.AsyncClient.uploadNewCredentials_call.getResult() |
TopologyInfo |
Nimbus.AsyncClient.getTopologyInfo_call.getResult() |
TopologyInfo |
Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult() |
TopologyPageInfo |
Nimbus.AsyncClient.getTopologyPageInfo_call.getResult() |
SupervisorPageInfo |
Nimbus.AsyncClient.getSupervisorPageInfo_call.getResult() |
ComponentPageInfo |
Nimbus.AsyncClient.getComponentPageInfo_call.getResult() |
String |
Nimbus.AsyncClient.getTopologyConf_call.getResult() |
StormTopology |
Nimbus.AsyncClient.getTopology_call.getResult() |
StormTopology |
Nimbus.AsyncClient.getUserTopology_call.getResult() |
SupervisorPageInfo |
Nimbus.Iface.getSupervisorPageInfo(String id,
String host,
boolean is_include_sys) |
SupervisorPageInfo |
Nimbus.Client.getSupervisorPageInfo(String id,
String host,
boolean is_include_sys) |
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) |
TopologyPageInfo |
Nimbus.Iface.getTopologyPageInfo(String id,
String window,
boolean is_include_sys) |
TopologyPageInfo |
Nimbus.Client.getTopologyPageInfo(String id,
String window,
boolean is_include_sys) |
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() |
void |
Nimbus.Client.recv_debug() |
ComponentPageInfo |
Nimbus.Client.recv_getComponentPageInfo() |
SupervisorPageInfo |
Nimbus.Client.recv_getSupervisorPageInfo() |
StormTopology |
Nimbus.Client.recv_getTopology() |
String |
Nimbus.Client.recv_getTopologyConf() |
TopologyInfo |
Nimbus.Client.recv_getTopologyInfo() |
TopologyInfo |
Nimbus.Client.recv_getTopologyInfoWithOpts() |
TopologyPageInfo |
Nimbus.Client.recv_getTopologyPageInfo() |
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 © 2022 The Apache Software Foundation. All Rights Reserved.