Uses of Class
org.apache.storm.generated.NotAliveException

Packages that use NotAliveException

Package	Description
org.apache.storm
org.apache.storm.daemon.nimbus
org.apache.storm.daemon.ui.exceptionmappers
org.apache.storm.generated
org.apache.storm.utils

Uses of NotAliveException in org.apache.storm

Methods in org.apache.storm that throw NotAliveException

Modifier and Type	Method	Description
void	LocalCluster.debug(String name, String component, boolean enable, double samplingPercentage)
ComponentPageInfo	LocalCluster.getComponentPageInfo(String topologyId, String componentId, String window, boolean isIncludeSys)
SupervisorPageInfo	LocalCluster.getSupervisorPageInfo(String id, String host, boolean isIncludeSys)
TopologyPageInfo	LocalCluster.getTopologyPageInfo(String id, String window, boolean isIncludeSys)
StormTopology	LocalCluster.getUserTopology(String id)
static boolean	StormSubmitter.pushCredentials(String name, Map<String,Object> topoConf, Map<String,String> credentials)	Push a new set of credentials to the running topology.
static boolean	StormSubmitter.pushCredentials(String name, Map<String,Object> topoConf, Map<String,String> credentials, String expectedUser)	Push a new set of credentials to the running topology.

Uses of NotAliveException in org.apache.storm.daemon.nimbus

Methods in org.apache.storm.daemon.nimbus that throw NotAliveException

Modifier and Type	Method	Description
void	Nimbus.activate(String topoName)
void	Nimbus.deactivate(String topoName)
void	Nimbus.debug(String topoName, String componentId, boolean enable, double samplingPercentage)
Set<String>	Nimbus.filterAuthorized(String operation, Collection<String> topoIds)
ComponentPageInfo	Nimbus.getComponentPageInfo(String topoId, String componentId, String window, boolean includeSys)
SupervisorPageInfo	Nimbus.getSupervisorPageInfo(String superId, String host, boolean includeSys)
StormTopology	Nimbus.getTopology(String id)
String	Nimbus.getTopologyConf(String id)
TopologyInfo	Nimbus.getTopologyInfo(String id)
TopologyInfo	Nimbus.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)
TopologyInfo	Nimbus.getTopologyInfoWithOpts(String topoId, GetInfoOptions options)
TopologyPageInfo	Nimbus.getTopologyPageInfo(String topoId, String window, boolean includeSys)
TopologySummary	Nimbus.getTopologySummary(String id)
TopologySummary	Nimbus.getTopologySummaryByName(String name)
StormTopology	Nimbus.getUserTopology(String id)
void	Nimbus.killTopology(String name)
void	Nimbus.killTopologyWithOpts(String topoName, KillOptions options)
void	Nimbus.rebalance(String topoName, RebalanceOptions options)
void	Nimbus.uploadNewCredentials(String topoName, Credentials credentials)

Uses of NotAliveException in org.apache.storm.daemon.ui.exceptionmappers

Methods in org.apache.storm.daemon.ui.exceptionmappers with parameters of type NotAliveException

Modifier and Type	Method	Description
jakarta.ws.rs.core.Response	NotAliveExceptionMapper.toResponse(NotAliveException ex)

Uses of NotAliveException in org.apache.storm.generated

Methods in org.apache.storm.generated that return NotAliveException

Modifier and Type	Method	Description
NotAliveException	NotAliveException.deepCopy()
NotAliveException	Nimbus.activate_result.get_e()
NotAliveException	Nimbus.deactivate_result.get_e()
NotAliveException	Nimbus.debug_result.get_e()
NotAliveException	Nimbus.getComponentPageInfo_result.get_e()
NotAliveException	Nimbus.getSupervisorPageInfo_result.get_e()
NotAliveException	Nimbus.getTopology_result.get_e()
NotAliveException	Nimbus.getTopologyConf_result.get_e()
NotAliveException	Nimbus.getTopologyInfo_result.get_e()
NotAliveException	Nimbus.getTopologyInfoByName_result.get_e()
NotAliveException	Nimbus.getTopologyInfoByNameWithOpts_result.get_e()
NotAliveException	Nimbus.getTopologyInfoWithOpts_result.get_e()
NotAliveException	Nimbus.getTopologyPageInfo_result.get_e()
NotAliveException	Nimbus.getTopologySummary_result.get_e()
NotAliveException	Nimbus.getTopologySummaryByName_result.get_e()
NotAliveException	Nimbus.getUserTopology_result.get_e()
NotAliveException	Nimbus.killTopology_result.get_e()
NotAliveException	Nimbus.killTopologyWithOpts_result.get_e()
NotAliveException	Nimbus.rebalance_result.get_e()
NotAliveException	Nimbus.sendSupervisorWorkerHeartbeat_result.get_e()
NotAliveException	Nimbus.uploadNewCredentials_result.get_e()
NotAliveException	Supervisor.getLocalAssignmentForStorm_result.get_e()

Methods in org.apache.storm.generated with parameters of type NotAliveException

Modifier and Type	Method	Description
int	NotAliveException.compareTo(NotAliveException other)
boolean	NotAliveException.equals(NotAliveException that)
void	Nimbus.activate_result.set_e(NotAliveException e)
void	Nimbus.deactivate_result.set_e(NotAliveException e)
void	Nimbus.debug_result.set_e(NotAliveException e)
void	Nimbus.getComponentPageInfo_result.set_e(NotAliveException e)
void	Nimbus.getSupervisorPageInfo_result.set_e(NotAliveException e)
void	Nimbus.getTopology_result.set_e(NotAliveException e)
void	Nimbus.getTopologyConf_result.set_e(NotAliveException e)
void	Nimbus.getTopologyInfo_result.set_e(NotAliveException e)
void	Nimbus.getTopologyInfoByName_result.set_e(NotAliveException e)
void	Nimbus.getTopologyInfoByNameWithOpts_result.set_e(NotAliveException e)
void	Nimbus.getTopologyInfoWithOpts_result.set_e(NotAliveException e)
void	Nimbus.getTopologyPageInfo_result.set_e(NotAliveException e)
void	Nimbus.getTopologySummary_result.set_e(NotAliveException e)
void	Nimbus.getTopologySummaryByName_result.set_e(NotAliveException e)
void	Nimbus.getUserTopology_result.set_e(NotAliveException e)
void	Nimbus.killTopology_result.set_e(NotAliveException e)
void	Nimbus.killTopologyWithOpts_result.set_e(NotAliveException e)
void	Nimbus.rebalance_result.set_e(NotAliveException e)
void	Nimbus.sendSupervisorWorkerHeartbeat_result.set_e(NotAliveException e)
void	Nimbus.uploadNewCredentials_result.set_e(NotAliveException e)
void	Supervisor.getLocalAssignmentForStorm_result.set_e(NotAliveException e)

Methods in org.apache.storm.generated that throw NotAliveException

Modifier and Type	Method	Description
void	Nimbus.Client.activate(String name)
void	Nimbus.Iface.activate(String name)
void	Nimbus.Client.deactivate(String name)
void	Nimbus.Iface.deactivate(String name)
void	Nimbus.Client.debug(String name, String component, boolean enable, double samplingPercentage)
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.
ComponentPageInfo	Nimbus.Client.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)
ComponentPageInfo	Nimbus.Iface.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)
Assignment	Supervisor.Client.getLocalAssignmentForStorm(String id)
Assignment	Supervisor.Iface.getLocalAssignmentForStorm(String id)	Get local assignment for a storm
Void	Nimbus.AsyncClient.activate_call.getResult()
Void	Nimbus.AsyncClient.deactivate_call.getResult()
Void	Nimbus.AsyncClient.debug_call.getResult()
ComponentPageInfo	Nimbus.AsyncClient.getComponentPageInfo_call.getResult()
SupervisorPageInfo	Nimbus.AsyncClient.getSupervisorPageInfo_call.getResult()
StormTopology	Nimbus.AsyncClient.getTopology_call.getResult()
String	Nimbus.AsyncClient.getTopologyConf_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfo_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoByName_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoByNameWithOpts_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult()
TopologyPageInfo	Nimbus.AsyncClient.getTopologyPageInfo_call.getResult()
TopologySummary	Nimbus.AsyncClient.getTopologySummary_call.getResult()
TopologySummary	Nimbus.AsyncClient.getTopologySummaryByName_call.getResult()
StormTopology	Nimbus.AsyncClient.getUserTopology_call.getResult()
Void	Nimbus.AsyncClient.killTopology_call.getResult()
Void	Nimbus.AsyncClient.killTopologyWithOpts_call.getResult()
Void	Nimbus.AsyncClient.rebalance_call.getResult()
Void	Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat_call.getResult()
Void	Nimbus.AsyncClient.uploadNewCredentials_call.getResult()
Assignment	Supervisor.AsyncClient.getLocalAssignmentForStorm_call.getResult()
SupervisorPageInfo	Nimbus.Client.getSupervisorPageInfo(String id, String host, boolean is_include_sys)
SupervisorPageInfo	Nimbus.Iface.getSupervisorPageInfo(String id, String host, boolean is_include_sys)
StormTopology	Nimbus.Client.getTopology(String id)
StormTopology	Nimbus.Iface.getTopology(String id)	Returns the compiled topology that contains ackers and metrics consumsers.
String	Nimbus.Client.getTopologyConf(String id)
String	Nimbus.Iface.getTopologyConf(String id)
TopologyInfo	Nimbus.Client.getTopologyInfo(String id)
TopologyInfo	Nimbus.Iface.getTopologyInfo(String id)
TopologyInfo	Nimbus.Client.getTopologyInfoByName(String name)
TopologyInfo	Nimbus.Iface.getTopologyInfoByName(String name)
TopologyInfo	Nimbus.Client.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)
TopologyInfo	Nimbus.Iface.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)
TopologyInfo	Nimbus.Client.getTopologyInfoWithOpts(String id, GetInfoOptions options)
TopologyInfo	Nimbus.Iface.getTopologyInfoWithOpts(String id, GetInfoOptions options)
TopologyPageInfo	Nimbus.Client.getTopologyPageInfo(String id, String window, boolean is_include_sys)
TopologyPageInfo	Nimbus.Iface.getTopologyPageInfo(String id, String window, boolean is_include_sys)
TopologySummary	Nimbus.Client.getTopologySummary(String id)
TopologySummary	Nimbus.Iface.getTopologySummary(String id)
TopologySummary	Nimbus.Client.getTopologySummaryByName(String name)
TopologySummary	Nimbus.Iface.getTopologySummaryByName(String name)
StormTopology	Nimbus.Client.getUserTopology(String id)
StormTopology	Nimbus.Iface.getUserTopology(String id)	Returns the user specified topology as submitted originally.
void	Nimbus.Client.killTopology(String name)
void	Nimbus.Iface.killTopology(String name)
void	Nimbus.Client.killTopologyWithOpts(String name, KillOptions options)
void	Nimbus.Iface.killTopologyWithOpts(String name, KillOptions options)
void	Nimbus.Client.rebalance(String name, RebalanceOptions options)
void	Nimbus.Iface.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()
Assignment	Supervisor.Client.recv_getLocalAssignmentForStorm()
SupervisorPageInfo	Nimbus.Client.recv_getSupervisorPageInfo()
StormTopology	Nimbus.Client.recv_getTopology()
String	Nimbus.Client.recv_getTopologyConf()
TopologyInfo	Nimbus.Client.recv_getTopologyInfo()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoByName()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoByNameWithOpts()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoWithOpts()
TopologyPageInfo	Nimbus.Client.recv_getTopologyPageInfo()
TopologySummary	Nimbus.Client.recv_getTopologySummary()
TopologySummary	Nimbus.Client.recv_getTopologySummaryByName()
StormTopology	Nimbus.Client.recv_getUserTopology()
void	Nimbus.Client.recv_killTopology()
void	Nimbus.Client.recv_killTopologyWithOpts()
void	Nimbus.Client.recv_rebalance()
void	Nimbus.Client.recv_sendSupervisorWorkerHeartbeat()
void	Nimbus.Client.recv_uploadNewCredentials()
void	Nimbus.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)
void	Nimbus.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)	Send supervisor local worker heartbeat when a supervisor is unreachable
void	Nimbus.Client.uploadNewCredentials(String name, Credentials creds)
void	Nimbus.Iface.uploadNewCredentials(String name, Credentials creds)

Constructors in org.apache.storm.generated with parameters of type NotAliveException

Constructor	Description
activate_result(NotAliveException e, AuthorizationException aze)
deactivate_result(NotAliveException e, AuthorizationException aze)
debug_result(NotAliveException e, AuthorizationException aze)
getComponentPageInfo_result(ComponentPageInfo success, NotAliveException e, AuthorizationException aze)
getLocalAssignmentForStorm_result(Assignment success, NotAliveException e, AuthorizationException aze)
getSupervisorPageInfo_result(SupervisorPageInfo success, NotAliveException e, AuthorizationException aze)
getTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
getTopologyConf_result(String success, NotAliveException e, AuthorizationException aze)
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)
getTopologyPageInfo_result(TopologyPageInfo success, NotAliveException e, AuthorizationException aze)
getTopologySummary_result(TopologySummary success, NotAliveException e, AuthorizationException aze)
getTopologySummaryByName_result(TopologySummary success, NotAliveException e, AuthorizationException aze)
getUserTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
killTopology_result(NotAliveException e, AuthorizationException aze)
killTopologyWithOpts_result(NotAliveException e, AuthorizationException aze)
NotAliveException(NotAliveException other)	Performs a deep copy on other.
rebalance_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)
sendSupervisorWorkerHeartbeat_result(AuthorizationException aze, NotAliveException e)
uploadNewCredentials_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)

Uses of NotAliveException in org.apache.storm.utils

Subclasses of NotAliveException in org.apache.storm.utils

Modifier and Type	Class	Description
class	WrappedNotAliveException	Wraps the generated TException to allow getMessage() to return a valid string.