Uses of Class
org.apache.storm.generated.AlreadyAliveException
Package
Description
ElasticSearch examples classes.
ElasticSearch Trident example classes.
-
Uses of AlreadyAliveException in org.apache.storm
Modifier and TypeMethodDescriptionvoid
LocalCluster.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopologyAs
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submits a topology to run on the cluster as a particular user.void
LocalCluster.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) static void
StormSubmitter.submitTopologyWithProgressBar
(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.static void
StormSubmitter.submitTopologyWithProgressBar
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar. -
Uses of AlreadyAliveException in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionvoid
Nimbus.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.submitTopologyWithOpts
(String topoName, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) -
Uses of AlreadyAliveException in org.apache.storm.elasticsearch.bolt
-
Uses of AlreadyAliveException in org.apache.storm.elasticsearch.trident
-
Uses of AlreadyAliveException in org.apache.storm.generated
Modifier and TypeMethodDescriptionAlreadyAliveException.deepCopy()
Nimbus.submitTopology_result.get_e()
Nimbus.submitTopologyWithOpts_result.get_e()
Modifier and TypeMethodDescriptionint
AlreadyAliveException.compareTo
(AlreadyAliveException other) boolean
AlreadyAliveException.equals
(AlreadyAliveException that) void
Nimbus.submitTopology_result.set_e
(AlreadyAliveException e) void
Nimbus.submitTopologyWithOpts_result.set_e
(AlreadyAliveException e) Modifier and TypeMethodDescriptionNimbus.AsyncClient.submitTopology_call.getResult()
Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult()
void
Nimbus.Client.recv_submitTopology()
void
Nimbus.Client.recv_submitTopologyWithOpts()
void
Nimbus.Client.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.Iface.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.Client.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) void
Nimbus.Iface.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) ModifierConstructorDescriptionPerforms a deep copy on other.submitTopology_result
(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze) submitTopologyWithOpts_result
(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze) -
Uses of AlreadyAliveException in org.apache.storm.kafka.trident
-
Uses of AlreadyAliveException in org.apache.storm.utils
Modifier and TypeClassDescriptionclass
Wraps the generated TException to allow getMessage() to return a valid string.