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

Packages that use InvalidTopologyException

Package	Description
org.apache.storm
org.apache.storm.container.oci
org.apache.storm.daemon
org.apache.storm.daemon.nimbus
org.apache.storm.daemon.worker
org.apache.storm.generated
org.apache.storm.kafka.trident
org.apache.storm.nimbus
org.apache.storm.utils

Uses of InvalidTopologyException in org.apache.storm

Methods in org.apache.storm that throw InvalidTopologyException

Modifier and Type	Method	Description
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.
void	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 InvalidTopologyException in org.apache.storm.container.oci

Methods in org.apache.storm.container.oci that throw InvalidTopologyException

Modifier and Type	Method	Description
static void	OciUtils.adjustImageConfigForTopo(Map<String,Object> conf, Map<String,Object> topoConf, String topoId)	Adjust the image config for the topology.

Uses of InvalidTopologyException in org.apache.storm.daemon

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

Modifier and Type	Method	Description
static int	StormCommon.numStartExecutors(Object component)
static Map<Integer,String>	StormCommon.stormTaskInfo(StormTopology userTopology, Map<String,Object> topoConf)
protected Map<Integer,String>	StormCommon.stormTaskInfoImpl(StormTopology userTopology, Map<String,Object> topoConf)
static StormTopology	StormCommon.systemTopology(Map<String,Object> topoConf, StormTopology topology)	Construct a new topology structure after adding system components and streams.
protected StormTopology	StormCommon.systemTopologyImpl(Map<String,Object> topoConf, StormTopology topology)
static void	StormCommon.validateBasic(StormTopology topology)
static void	StormCommon.validateStructure(StormTopology topology)

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

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

Modifier and Type	Method	Description
void	Nimbus.rebalance(String topoName, RebalanceOptions options)
void	Nimbus.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.submitTopologyWithOpts(String topoName, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	Nimbus.uploadNewCredentials(String topoName, Credentials credentials)

Uses of InvalidTopologyException in org.apache.storm.daemon.worker

Constructors in org.apache.storm.daemon.worker that throw InvalidTopologyException

Constructor	Description
WorkerState(Map<String,Object> conf, IContext mqContext, String topologyId, String assignmentId, Supplier<SupervisorIfaceFactory> supervisorIfaceSupplier, int port, String workerId, Map<String,Object> topologyConf, IStateStorage stateStorage, IStormClusterState stormClusterState, Collection<IAutoCredentials> autoCredentials, StormMetricRegistry metricRegistry, Credentials initialCredentials)

Uses of InvalidTopologyException in org.apache.storm.generated

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

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

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

Modifier and Type	Method	Description
int	InvalidTopologyException.compareTo(InvalidTopologyException other)
boolean	InvalidTopologyException.equals(InvalidTopologyException that)
void	Nimbus.rebalance_result.set_ite(InvalidTopologyException ite)
void	Nimbus.submitTopology_result.set_ite(InvalidTopologyException ite)
void	Nimbus.submitTopologyWithOpts_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	Description
Void	Nimbus.AsyncClient.rebalance_call.getResult()
Void	Nimbus.AsyncClient.submitTopology_call.getResult()
Void	Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult()
Void	Nimbus.AsyncClient.uploadNewCredentials_call.getResult()
void	Nimbus.Client.rebalance(String name, RebalanceOptions options)
void	Nimbus.Iface.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.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)
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 InvalidTopologyException

Constructor	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	Description
protected void	TridentKafkaClientTopologyNamedTopics.run(String[] args)

Uses of InvalidTopologyException in org.apache.storm.nimbus

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

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

Uses of InvalidTopologyException in org.apache.storm.utils

Subclasses of InvalidTopologyException in org.apache.storm.utils

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

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

Modifier and Type	Method	Description
static int	ServerUtils.getComponentParallelism(Map<String,Object> topoConf, Object component)
static Map<String,Integer>	ServerUtils.getComponentParallelism(Map<String,Object> topoConf, StormTopology topology)
static double	ServerUtils.getEstimatedTotalHeapMemoryRequiredByTopo(Map<String,Object> topoConf, StormTopology topology)
static int	ServerUtils.getEstimatedWorkerCountForRasTopo(Map<String,Object> topoConf, StormTopology topology)
static void	Utils.validateCycleFree(StormTopology topology, String name)	Validate that the topology is cycle free.
static void	ServerUtils.validateTopologyAckerBundleResource(Map<String,Object> topoConf, StormTopology topology, String topoName)	RAS scheduler will try to distribute ackers evenly over workers by adding some ackers to each newly launched worker.
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf)	Validate topology blobstore map.
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf, BlobStore blobStore)	Validate topology blobstore map.
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf, NimbusBlobStore client)	Validate topology blobstore map.
static void	ServerUtils.validateTopologyWorkerMaxHeapSizeConfigs(Map<String,Object> stormConf, StormTopology topology, double defaultWorkerMaxHeapSizeMb)