# 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
  Modifier
  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
  Modifier
  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)`