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

Packages that use InvalidTopologyException

Package	Description
org.apache.storm
org.apache.storm.generated
org.apache.storm.kafka.trident
org.apache.storm.nimbus
org.apache.storm.starter.util
org.apache.storm.utils

Uses of InvalidTopologyException in org.apache.storm

Methods in org.apache.storm that throw InvalidTopologyException

Modifier and Type	Method and Description
static void	StormSubmitter.pushCredentials(String name, Map stormConf, Map<String,String> credentials) Push a new set of credentials to the running topology.
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology) Submits a topology to run on the cluster.
void	ILocalCluster.submitTopology(String topologyName, Map conf, StormTopology topology)
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopologyAs(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submits a topology to run on the cluster as a particular user.
void	ILocalCluster.submitTopologyWithOpts(String topologyName, Map conf, StormTopology topology, SubmitOptions submitOpts)
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar.

Uses of InvalidTopologyException in org.apache.storm.generated

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

Modifier and Type	Method and Description
InvalidTopologyException	InvalidTopologyException.deepCopy()
InvalidTopologyException	Nimbus.submitTopology_result.get_ite()
InvalidTopologyException	Nimbus.submitTopologyWithOpts_result.get_ite()
InvalidTopologyException	Nimbus.rebalance_result.get_ite()
InvalidTopologyException	Nimbus.uploadNewCredentials_result.get_ite()

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

Modifier and Type	Method and Description
int	InvalidTopologyException.compareTo(InvalidTopologyException other)
boolean	InvalidTopologyException.equals(InvalidTopologyException that)
void	Nimbus.submitTopology_result.set_ite(InvalidTopologyException ite)
void	Nimbus.submitTopologyWithOpts_result.set_ite(InvalidTopologyException ite)
void	Nimbus.rebalance_result.set_ite(InvalidTopologyException ite)
void	Nimbus.uploadNewCredentials_result.set_ite(InvalidTopologyException ite)

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

Modifier and Type	Method and Description
void	Nimbus.AsyncClient.submitTopology_call.getResult()
void	Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult()
void	Nimbus.AsyncClient.rebalance_call.getResult()
void	Nimbus.AsyncClient.uploadNewCredentials_call.getResult()
void	Nimbus.Iface.rebalance(String name, RebalanceOptions options)
void	Nimbus.Client.rebalance(String name, RebalanceOptions options)
void	Nimbus.Client.recv_rebalance()
void	Nimbus.Client.recv_submitTopology()
void	Nimbus.Client.recv_submitTopologyWithOpts()
void	Nimbus.Client.recv_uploadNewCredentials()
void	Nimbus.Iface.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.Client.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.Iface.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	Nimbus.Client.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	Nimbus.Iface.uploadNewCredentials(String name, Credentials creds)
void	Nimbus.Client.uploadNewCredentials(String name, Credentials creds)

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

Constructor and Description
InvalidTopologyException(InvalidTopologyException other) Performs a deep copy on other.
rebalance_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)
submitTopology_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)
submitTopologyWithOpts_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)
uploadNewCredentials_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)

Uses of InvalidTopologyException in org.apache.storm.kafka.trident

Methods in org.apache.storm.kafka.trident that throw InvalidTopologyException

Modifier and Type	Method and Description
protected void	TridentKafkaClientWordCountNamedTopics.run(String[] args)

Uses of InvalidTopologyException in org.apache.storm.nimbus

Methods in org.apache.storm.nimbus that throw InvalidTopologyException

Modifier and Type	Method and Description
void	StrictTopologyValidator.validate(String topologyName, Map topologyConf, StormTopology topology)
void	ITopologyValidator.validate(String topologyName, Map topologyConf, StormTopology topology)
void	DefaultTopologyValidator.validate(String topologyName, Map topologyConf, StormTopology topology)

Uses of InvalidTopologyException in org.apache.storm.starter.util

Methods in org.apache.storm.starter.util that throw InvalidTopologyException

Modifier and Type	Method and Description
static void	StormRunner.runTopologyRemotely(StormTopology topology, String topologyName, Config conf)

Uses of InvalidTopologyException in org.apache.storm.utils

Methods in org.apache.storm.utils that throw InvalidTopologyException

Modifier and Type	Method and Description
static void	Utils.validateTopologyBlobStoreMap(Map<String,?> stormConf, Set<String> blobStoreKeys)