## Uses of Class
org.apache.storm.generated.AuthorizationException

- Packages that use AuthorizationException
  Package | Description
  --- | ---
  org.apache.storm |
  org.apache.storm.blobstore |
  org.apache.storm.daemon.common |
  org.apache.storm.daemon.drpc |
  org.apache.storm.daemon.nimbus |
  org.apache.storm.daemon.supervisor |
  org.apache.storm.daemon.ui.exceptionmappers |
  org.apache.storm.dependency |
  org.apache.storm.drpc |
  org.apache.storm.generated |
  org.apache.storm.hdfs.blobstore |
  org.apache.storm.kafka.trident |
  org.apache.storm.localizer |
  org.apache.storm.utils |

- - ### Uses of AuthorizationException in org.apache.storm

    Methods in org.apache.storm that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `BeginDownloadResult` | LocalCluster.`beginBlobDownload​(String key)` |
    `String` | LocalCluster.`beginCreateBlob​(String key, SettableBlobMeta meta)` |
    `String` | LocalCluster.`beginFileUpload()` |
    `String` | LocalCluster.`beginUpdateBlob​(String key)` |
    `void` | LocalCluster.`cancelBlobUpload​(String session)` |
    `void` | LocalCluster.`debug​(String name, String component, boolean enable, double samplingPercentage)` |
    `void` | LocalCluster.`deleteBlob​(String key)` |
    `ByteBuffer` | LocalCluster.`downloadBlobChunk​(String session)` |
    `ByteBuffer` | LocalCluster.`downloadChunk​(String id)` |
    `String` | LocalDRPC.`execute​(String functionName, String funcArgs)` |
    `void` | LocalDRPC.`failRequest​(String id)` |
    `void` | LocalDRPC.`failRequestV2​(String id, DRPCExecutionException e)` |
    `DRPCRequest` | LocalDRPC.`fetchRequest​(String functionName)` |
    `void` | LocalCluster.`finishBlobUpload​(String session)` |
    `void` | LocalCluster.`finishFileUpload​(String location)` |
    `ReadableBlobMeta` | LocalCluster.`getBlobMeta​(String key)` |
    `int` | LocalCluster.`getBlobReplication​(String key)` |
    `ComponentPageInfo` | LocalCluster.`getComponentPageInfo​(String topologyId, String componentId, String window, boolean isIncludeSys)` |
    `NimbusSummary` | LocalCluster.`getLeader()` |
    `String` | LocalCluster.`getNimbusConf()` |
    `List<OwnerResourceSummary>` | LocalCluster.`getOwnerResourceSummaries​(String owner)` |
    `SupervisorAssignments` | LocalCluster.`getSupervisorAssignments​(String node)` |
    `SupervisorPageInfo` | LocalCluster.`getSupervisorPageInfo​(String id, String host, boolean isIncludeSys)` |
    `TopologyHistoryInfo` | LocalCluster.`getTopologyHistory​(String user)` |
    `TopologyPageInfo` | LocalCluster.`getTopologyPageInfo​(String id, String window, boolean isIncludeSys)` |
    `StormTopology` | LocalCluster.`getUserTopology​(String id)` |
    `boolean` | LocalCluster.`isRemoteBlobExists​(String blobKey)` |
    `boolean` | LocalCluster.`isTopologyNameAllowed​(String name)` |
    `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` | LocalDRPC.`result​(String id, String result)` |
    `void` | LocalCluster.`sendSupervisorWorkerHeartbeat​(SupervisorWorkerHeartbeat heatbeat)` |
    `void` | LocalCluster.`sendSupervisorWorkerHeartbeats​(SupervisorWorkerHeartbeats heartbeats)` |
    `void` | LocalCluster.`setBlobMeta​(String key, SettableBlobMeta meta)` |
    `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.
    `int` | LocalCluster.`updateBlobReplication​(String key, int replication)` |
    `void` | LocalCluster.`uploadBlobChunk​(String session, ByteBuffer chunk)` |
    `void` | LocalCluster.`uploadChunk​(String location, ByteBuffer chunk)` |

  - ### Uses of AuthorizationException in org.apache.storm.blobstore

    Methods in org.apache.storm.blobstore that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `protected static void` | MigrateBlobs.`copyBlobStoreKeys​(BlobStore bsFrom, Subject whoFrom, BlobStore bsTo, Subject whoTo)` |
    `void` | BlobStore.`createBlob​(String key, byte[] data, SettableBlobMeta meta, Subject who)` | Wrapper called to create the blob which contains the byte data.
    `void` | BlobStore.`createBlob​(String key, InputStream in, SettableBlobMeta meta, Subject who)` | Wrapper called to create the blob which contains the byte data.
    `abstract AtomicOutputStream` | BlobStore.`createBlob​(String key, SettableBlobMeta meta, Subject who)` | Creates the blob.
    `AtomicOutputStream` | ClientBlobStore.`createBlob​(String key, SettableBlobMeta meta)` | Client facing API to create a blob.
    `AtomicOutputStream` | LocalFsBlobStore.`createBlob​(String key, SettableBlobMeta meta, Subject who)` |
    `protected abstract AtomicOutputStream` | ClientBlobStore.`createBlobToExtend​(String key, SettableBlobMeta meta)` | Client facing API to create a blob.
    `protected AtomicOutputStream` | LocalModeClientBlobStore.`createBlobToExtend​(String key, SettableBlobMeta meta)` |
    `protected AtomicOutputStream` | NimbusBlobStore.`createBlobToExtend​(String key, SettableBlobMeta meta)` |
    `protected static void` | MigrateBlobs.`deleteAllBlobStoreKeys​(BlobStore bs, Subject who)` |
    `abstract void` | BlobStore.`deleteBlob​(String key, Subject who)` | Deletes the blob data and metadata.
    `abstract void` | ClientBlobStore.`deleteBlob​(String key)` | Client facing API to delete a blob.
    `void` | LocalFsBlobStore.`deleteBlob​(String key, Subject who)` |
    `void` | LocalModeClientBlobStore.`deleteBlob​(String key)` |
    `void` | NimbusBlobStore.`deleteBlob​(String key)` |
    `abstract InputStreamWithMeta` | BlobStore.`getBlob​(String key, Subject who)` | Gets the InputStream to read the blob details.
    `abstract InputStreamWithMeta` | ClientBlobStore.`getBlob​(String key)` | Client facing API to read a blob.
    `InputStreamWithMeta` | LocalFsBlobStore.`getBlob​(String key, Subject who)` |
    `InputStreamWithMeta` | LocalModeClientBlobStore.`getBlob​(String key)` |
    `InputStreamWithMeta` | NimbusBlobStore.`getBlob​(String key)` |
    `abstract ReadableBlobMeta` | BlobStore.`getBlobMeta​(String key, Subject who)` | Gets the current version of metadata for a blob to be viewed by the user or downloaded by the supervisor.
    `abstract ReadableBlobMeta` | ClientBlobStore.`getBlobMeta​(String key)` | Client facing API to read the metadata information.
    `ReadableBlobMeta` | LocalFsBlobStore.`getBlobMeta​(String key, Subject who)` |
    `ReadableBlobMeta` | LocalModeClientBlobStore.`getBlobMeta​(String key)` |
    `ReadableBlobMeta` | NimbusBlobStore.`getBlobMeta​(String key)` |
    `abstract int` | ClientBlobStore.`getBlobReplication​(String key)` | Client facing API to read the replication of a blob.
    `int` | LocalModeClientBlobStore.`getBlobReplication​(String key)` |
    `int` | NimbusBlobStore.`getBlobReplication​(String key)` |
    `void` | BlobStoreAclHandler.`hasAnyPermissions​(List<AccessControl> acl, int mask, Subject who, String key)` | Validates if the user has any of the permissions mentioned in the mask.
    `void` | BlobStoreAclHandler.`hasPermissions​(List<AccessControl> acl, int mask, Subject who, String key)` | Validates if the user has at least the set of permissions mentioned in the mask.
    `abstract boolean` | ClientBlobStore.`isRemoteBlobExists​(String blobKey)` | Decide if the blob is deleted from cluster.
    `boolean` | LocalModeClientBlobStore.`isRemoteBlobExists​(String blobKey)` |
    `boolean` | NimbusBlobStore.`isRemoteBlobExists​(String blobKey)` |
    `byte[]` | BlobStore.`readBlob​(String key, Subject who)` | Wrapper around readBlobTo which returns a ByteArray output stream.
    `void` | BlobStore.`readBlobTo​(String key, OutputStream out, Subject who)` | Reads the blob from the blob store and writes it into the output stream.
    `abstract void` | BlobStore.`setBlobMeta​(String key, SettableBlobMeta meta, Subject who)` | Sets the metadata with renewed acls for the blob.
    `void` | ClientBlobStore.`setBlobMeta​(String key, SettableBlobMeta meta)` | Client facing API to set the metadata for a blob.
    `void` | LocalFsBlobStore.`setBlobMeta​(String key, SettableBlobMeta meta, Subject who)` |
    `protected abstract void` | ClientBlobStore.`setBlobMetaToExtend​(String key, SettableBlobMeta meta)` | Client facing API to set the metadata for a blob.
    `protected void` | LocalModeClientBlobStore.`setBlobMetaToExtend​(String key, SettableBlobMeta meta)` |
    `protected void` | NimbusBlobStore.`setBlobMetaToExtend​(String key, SettableBlobMeta meta)` |
    `void` | BlobStore.`startSyncBlobs()` | Start the syncing blobs between the local running instance of the BlobStore and others.
    `void` | LocalFsBlobStore.`startSyncBlobs()` |
    `void` | BlobStore.`updateBlob​(String key, byte[] data, Subject who)` | Wrapper called to create the blob which contains the byte data.
    `abstract AtomicOutputStream` | BlobStore.`updateBlob​(String key, Subject who)` | Updates the blob data.
    `abstract AtomicOutputStream` | ClientBlobStore.`updateBlob​(String key)` | Client facing API to update a blob.
    `AtomicOutputStream` | LocalFsBlobStore.`updateBlob​(String key, Subject who)` |
    `AtomicOutputStream` | LocalModeClientBlobStore.`updateBlob​(String key)` |
    `AtomicOutputStream` | NimbusBlobStore.`updateBlob​(String key)` |
    `abstract int` | BlobStore.`updateBlobReplication​(String key, int replication, Subject who)` | Modifies the replication factor of the blob.
    `abstract int` | ClientBlobStore.`updateBlobReplication​(String key, int replication)` | Client facing API to update the replication of a blob.
    `int` | LocalFsBlobStore.`updateBlobReplication​(String key, int replication, Subject who)` |
    `int` | LocalModeClientBlobStore.`updateBlobReplication​(String key, int replication)` |
    `int` | NimbusBlobStore.`updateBlobReplication​(String key, int replication)` |
    `static void` | BlobStoreAclHandler.`validateSettableACLs​(String key, List<AccessControl> acls)` |
    `void` | BlobStoreAclHandler.`validateUserCanReadMeta​(List<AccessControl> acl, Subject who, String key)` | The user should be able to see the metadata if and only if they have any of READ, WRITE, or ADMIN.

  - ### Uses of AuthorizationException in org.apache.storm.daemon.common

    Methods in org.apache.storm.daemon.common with parameters of type AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `jakarta.ws.rs.core.Response` | AuthorizationExceptionMapper.`toResponse​(AuthorizationException ex)` |

  - ### Uses of AuthorizationException in org.apache.storm.daemon.drpc

    Methods in org.apache.storm.daemon.drpc that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `<T extends OutstandingRequest> T` | DRPC.`execute​(String functionName, String funcArgs, RequestFactory<T> factory)` |
    `String` | DRPCThrift.`execute​(String functionName, String funcArgs)` |
    `String` | DRPC.`executeBlocking​(String functionName, String funcArgs)` |
    `void` | DRPC.`failRequest​(String id, DRPCExecutionException e)` |
    `void` | DRPCThrift.`failRequest​(String id)` |
    `void` | DRPCThrift.`failRequestV2​(String id, DRPCExecutionException e)` |
    `DRPCRequest` | DRPC.`fetchRequest​(String functionName)` |
    `DRPCRequest` | DRPCThrift.`fetchRequest​(String functionName)` |
    `void` | DRPCThrift.`result​(String id, String result)` |
    `void` | DRPC.`returnResult​(String id, String result)` |

  - ### Uses of AuthorizationException in org.apache.storm.daemon.nimbus

    Methods in org.apache.storm.daemon.nimbus that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | Nimbus.`activate​(String topoName)` |
    `void` | TopoCache.`addTopoConf​(String topoId, Subject who, Map<String,​Object> topoConf)` | Add a new topology config.
    `void` | TopoCache.`addTopology​(String topoId, Subject who, StormTopology topo)` | Add a new topology.
    `BeginDownloadResult` | Nimbus.`beginBlobDownload​(String key)` |
    `String` | Nimbus.`beginCreateBlob​(String key, SettableBlobMeta meta)` |
    `String` | Nimbus.`beginFileUpload()` |
    `String` | Nimbus.`beginUpdateBlob​(String key)` |
    `void` | Nimbus.`cancelBlobUpload​(String session)` |
    `void` | Nimbus.`checkAuthorization​(String topoName, Map<String,​Object> topoConf, String operation)` |
    `void` | Nimbus.`checkAuthorization​(String topoName, Map<String,​Object> topoConf, String operation, ReqContext context)` |
    `void` | Nimbus.`deactivate​(String topoName)` |
    `void` | Nimbus.`debug​(String topoName, String componentId, boolean enable, double samplingPercentage)` |
    `void` | Nimbus.`deleteBlob​(String key)` |
    `void` | TopoCache.`deleteTopoConf​(String topoId, Subject who)` | Delete a topology conf when we are done.
    `void` | TopoCache.`deleteTopology​(String topoId, Subject who)` | Delete a topology when we are done.
    `ByteBuffer` | Nimbus.`downloadBlobChunk​(String session)` |
    `ByteBuffer` | Nimbus.`downloadChunk​(String id)` |
    `Set<String>` | Nimbus.`filterAuthorized​(String operation, Collection<String> topoIds)` |
    `void` | Nimbus.`finishBlobUpload​(String session)` |
    `void` | Nimbus.`finishFileUpload​(String location)` |
    `ReadableBlobMeta` | Nimbus.`getBlobMeta​(String key)` |
    `int` | Nimbus.`getBlobReplication​(String key)` |
    `ClusterSummary` | Nimbus.`getClusterInfo()` |
    `ComponentPageInfo` | Nimbus.`getComponentPageInfo​(String topoId, String componentId, String window, boolean includeSys)` |
    `NimbusSummary` | Nimbus.`getLeader()` |
    `String` | Nimbus.`getNimbusConf()` |
    `List<OwnerResourceSummary>` | Nimbus.`getOwnerResourceSummaries​(String owner)` |
    `SupervisorAssignments` | Nimbus.`getSupervisorAssignments​(String nodeId)` |
    `SupervisorPageInfo` | Nimbus.`getSupervisorPageInfo​(String superId, String host, boolean includeSys)` |
    `StormTopology` | Nimbus.`getTopology​(String id)` |
    `String` | Nimbus.`getTopologyConf​(String id)` |
    `TopologyHistoryInfo` | Nimbus.`getTopologyHistory​(String user)` |
    `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)` |
    `List<TopologySummary>` | Nimbus.`getTopologySummaries()` |
    `TopologySummary` | Nimbus.`getTopologySummary​(String id)` |
    `TopologySummary` | Nimbus.`getTopologySummaryByName​(String name)` |
    `StormTopology` | Nimbus.`getUserTopology​(String id)` |
    `boolean` | Nimbus.`isRemoteBlobExists​(String blobKey)` |
    `boolean` | Nimbus.`isTopologyNameAllowed​(String name)` |
    `void` | Nimbus.`killTopology​(String name)` |
    `void` | Nimbus.`killTopologyWithOpts​(String topoName, KillOptions options)` |
    `Map<String,​Object>` | TopoCache.`readTopoConf​(String topoId, Subject who)` | Read a topology conf.
    `StormTopology` | TopoCache.`readTopology​(String topoId, Subject who)` | Read a topology.
    `void` | Nimbus.`rebalance​(String topoName, RebalanceOptions options)` |
    `void` | Nimbus.`sendSupervisorWorkerHeartbeat​(SupervisorWorkerHeartbeat hb)` |
    `void` | Nimbus.`sendSupervisorWorkerHeartbeats​(SupervisorWorkerHeartbeats heartbeats)` |
    `void` | Nimbus.`setBlobMeta​(String key, SettableBlobMeta meta)` |
    `void` | Nimbus.`submitTopology​(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)` |
    `void` | Nimbus.`submitTopologyWithOpts​(String topoName, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)` |
    `int` | Nimbus.`updateBlobReplication​(String key, int replication)` |
    `void` | TopoCache.`updateTopoConf​(String topoId, Subject who, Map<String,​Object> topoConf)` | Update an existing topology conf.
    `void` | TopoCache.`updateTopology​(String topoId, Subject who, StormTopology topo)` | Update an existing topology .
    `void` | Nimbus.`uploadBlobChunk​(String session, ByteBuffer chunk)` |
    `void` | Nimbus.`uploadChunk​(String location, ByteBuffer chunk)` |
    `void` | Nimbus.`uploadNewCredentials​(String topoName, Credentials credentials)` |

  - ### Uses of AuthorizationException in org.apache.storm.daemon.supervisor

    Methods in org.apache.storm.daemon.supervisor that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | Supervisor.`checkAuthorization​(String operation)` |
    `void` | Supervisor.`checkAuthorization​(String topoName, Map<String,​Object> topoConf, String operation)` |
    `void` | Supervisor.`checkAuthorization​(String topoName, Map<String,​Object> topoConf, String operation, ReqContext context)` |

  - ### Uses of AuthorizationException in org.apache.storm.daemon.ui.exceptionmappers

    Methods in org.apache.storm.daemon.ui.exceptionmappers with parameters of type AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `static jakarta.ws.rs.core.Response` | ExceptionMapperUtils.`getResponse​(AuthorizationException ex, jakarta.inject.Provider<jakarta.servlet.http.HttpServletRequest> request)` | getResponse.
    `jakarta.ws.rs.core.Response` | AuthorizationExceptionMapper.`toResponse​(AuthorizationException e)` |

  - ### Uses of AuthorizationException in org.apache.storm.dependency

    Methods in org.apache.storm.dependency that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `List<String>` | DependencyUploader.`uploadFiles​(List<File> dependencies, boolean cleanupIfFails)` |

  - ### Uses of AuthorizationException in org.apache.storm.drpc

    Methods in org.apache.storm.drpc that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | DRPCInvocationsClient.`failRequest​(String id)` |
    `void` | DRPCInvocationsClient.`failRequestV2​(String id, DRPCExecutionException ex)` |
    `DRPCRequest` | DRPCInvocationsClient.`fetchRequest​(String func)` |
    `void` | DRPCInvocationsClient.`result​(String id, String result)` |

  - ### Uses of AuthorizationException in org.apache.storm.generated

    Methods in org.apache.storm.generated that return AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `AuthorizationException` | AuthorizationException.`deepCopy()` |
    `AuthorizationException` | DistributedRPC.execute_result.`get_aze()` |
    `AuthorizationException` | DistributedRPCInvocations.failRequest_result.`get_aze()` |
    `AuthorizationException` | DistributedRPCInvocations.failRequestV2_result.`get_aze()` |
    `AuthorizationException` | DistributedRPCInvocations.fetchRequest_result.`get_aze()` |
    `AuthorizationException` | DistributedRPCInvocations.result_result.`get_aze()` |
    `AuthorizationException` | Nimbus.activate_result.`get_aze()` |
    `AuthorizationException` | Nimbus.beginBlobDownload_result.`get_aze()` |
    `AuthorizationException` | Nimbus.beginCreateBlob_result.`get_aze()` |
    `AuthorizationException` | Nimbus.beginFileUpload_result.`get_aze()` |
    `AuthorizationException` | Nimbus.beginUpdateBlob_result.`get_aze()` |
    `AuthorizationException` | Nimbus.cancelBlobUpload_result.`get_aze()` |
    `AuthorizationException` | Nimbus.deactivate_result.`get_aze()` |
    `AuthorizationException` | Nimbus.debug_result.`get_aze()` |
    `AuthorizationException` | Nimbus.deleteBlob_result.`get_aze()` |
    `AuthorizationException` | Nimbus.downloadBlobChunk_result.`get_aze()` |
    `AuthorizationException` | Nimbus.downloadChunk_result.`get_aze()` |
    `AuthorizationException` | Nimbus.finishBlobUpload_result.`get_aze()` |
    `AuthorizationException` | Nimbus.finishFileUpload_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getBlobMeta_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getBlobReplication_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getClusterInfo_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getComponentPageInfo_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getLeader_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getNimbusConf_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getOwnerResourceSummaries_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getSupervisorAssignments_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getSupervisorPageInfo_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopology_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologyConf_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologyHistory_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologyInfo_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologyInfoByName_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologyInfoByNameWithOpts_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologyInfoWithOpts_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologyPageInfo_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologySummaries_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologySummary_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getTopologySummaryByName_result.`get_aze()` |
    `AuthorizationException` | Nimbus.getUserTopology_result.`get_aze()` |
    `AuthorizationException` | Nimbus.isRemoteBlobExists_result.`get_aze()` |
    `AuthorizationException` | Nimbus.isTopologyNameAllowed_result.`get_aze()` |
    `AuthorizationException` | Nimbus.killTopology_result.`get_aze()` |
    `AuthorizationException` | Nimbus.killTopologyWithOpts_result.`get_aze()` |
    `AuthorizationException` | Nimbus.rebalance_result.`get_aze()` |
    `AuthorizationException` | Nimbus.sendSupervisorWorkerHeartbeat_result.`get_aze()` |
    `AuthorizationException` | Nimbus.sendSupervisorWorkerHeartbeats_result.`get_aze()` |
    `AuthorizationException` | Nimbus.setBlobMeta_result.`get_aze()` |
    `AuthorizationException` | Nimbus.submitTopology_result.`get_aze()` |
    `AuthorizationException` | Nimbus.submitTopologyWithOpts_result.`get_aze()` |
    `AuthorizationException` | Nimbus.updateBlobReplication_result.`get_aze()` |
    `AuthorizationException` | Nimbus.uploadBlobChunk_result.`get_aze()` |
    `AuthorizationException` | Nimbus.uploadChunk_result.`get_aze()` |
    `AuthorizationException` | Nimbus.uploadNewCredentials_result.`get_aze()` |
    `AuthorizationException` | Supervisor.getLocalAssignmentForStorm_result.`get_aze()` |
    `AuthorizationException` | Supervisor.sendSupervisorAssignments_result.`get_aze()` |
    `AuthorizationException` | Supervisor.sendSupervisorWorkerHeartbeat_result.`get_aze()` |

    Methods in org.apache.storm.generated with parameters of type AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `int` | AuthorizationException.`compareTo​(AuthorizationException other)` |
    `boolean` | AuthorizationException.`equals​(AuthorizationException that)` |
    `void` | DistributedRPC.execute_result.`set_aze​(AuthorizationException aze)` |
    `void` | DistributedRPCInvocations.failRequest_result.`set_aze​(AuthorizationException aze)` |
    `void` | DistributedRPCInvocations.failRequestV2_result.`set_aze​(AuthorizationException aze)` |
    `void` | DistributedRPCInvocations.fetchRequest_result.`set_aze​(AuthorizationException aze)` |
    `void` | DistributedRPCInvocations.result_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.activate_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.beginBlobDownload_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.beginCreateBlob_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.beginFileUpload_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.beginUpdateBlob_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.cancelBlobUpload_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.deactivate_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.debug_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.deleteBlob_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.downloadBlobChunk_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.downloadChunk_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.finishBlobUpload_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.finishFileUpload_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getBlobMeta_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getBlobReplication_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getClusterInfo_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getComponentPageInfo_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getLeader_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getNimbusConf_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getOwnerResourceSummaries_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getSupervisorAssignments_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getSupervisorPageInfo_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopology_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologyConf_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologyHistory_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologyInfo_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologyInfoByName_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologyInfoByNameWithOpts_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologyInfoWithOpts_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologyPageInfo_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologySummaries_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologySummary_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getTopologySummaryByName_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.getUserTopology_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.isRemoteBlobExists_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.isTopologyNameAllowed_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.killTopology_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.killTopologyWithOpts_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.rebalance_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.sendSupervisorWorkerHeartbeat_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.sendSupervisorWorkerHeartbeats_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.setBlobMeta_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.submitTopology_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.submitTopologyWithOpts_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.updateBlobReplication_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.uploadBlobChunk_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.uploadChunk_result.`set_aze​(AuthorizationException aze)` |
    `void` | Nimbus.uploadNewCredentials_result.`set_aze​(AuthorizationException aze)` |
    `void` | Supervisor.getLocalAssignmentForStorm_result.`set_aze​(AuthorizationException aze)` |
    `void` | Supervisor.sendSupervisorAssignments_result.`set_aze​(AuthorizationException aze)` |
    `void` | Supervisor.sendSupervisorWorkerHeartbeat_result.`set_aze​(AuthorizationException aze)` |

    Methods in org.apache.storm.generated that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `void` | Nimbus.Client.`activate​(String name)` |
    `void` | Nimbus.Iface.`activate​(String name)` |
    `BeginDownloadResult` | Nimbus.Client.`beginBlobDownload​(String key)` |
    `BeginDownloadResult` | Nimbus.Iface.`beginBlobDownload​(String key)` |
    `String` | Nimbus.Client.`beginCreateBlob​(String key, SettableBlobMeta meta)` |
    `String` | Nimbus.Iface.`beginCreateBlob​(String key, SettableBlobMeta meta)` |
    `String` | Nimbus.Client.`beginFileUpload()` |
    `String` | Nimbus.Iface.`beginFileUpload()` |
    `String` | Nimbus.Client.`beginUpdateBlob​(String key)` |
    `String` | Nimbus.Iface.`beginUpdateBlob​(String key)` |
    `void` | Nimbus.Client.`cancelBlobUpload​(String session)` |
    `void` | Nimbus.Iface.`cancelBlobUpload​(String session)` |
    `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.
    `void` | Nimbus.Client.`deleteBlob​(String key)` |
    `void` | Nimbus.Iface.`deleteBlob​(String key)` |
    `ByteBuffer` | Nimbus.Client.`downloadBlobChunk​(String session)` |
    `ByteBuffer` | Nimbus.Iface.`downloadBlobChunk​(String session)` |
    `ByteBuffer` | Nimbus.Client.`downloadChunk​(String id)` |
    `ByteBuffer` | Nimbus.Iface.`downloadChunk​(String id)` |
    `String` | DistributedRPC.Client.`execute​(String functionName, String funcArgs)` |
    `String` | DistributedRPC.Iface.`execute​(String functionName, String funcArgs)` |
    `void` | DistributedRPCInvocations.Client.`failRequest​(String id)` |
    `void` | DistributedRPCInvocations.Iface.`failRequest​(String id)` |
    `void` | DistributedRPCInvocations.Client.`failRequestV2​(String id, DRPCExecutionException e)` |
    `void` | DistributedRPCInvocations.Iface.`failRequestV2​(String id, DRPCExecutionException e)` |
    `DRPCRequest` | DistributedRPCInvocations.Client.`fetchRequest​(String functionName)` |
    `DRPCRequest` | DistributedRPCInvocations.Iface.`fetchRequest​(String functionName)` |
    `void` | Nimbus.Client.`finishBlobUpload​(String session)` |
    `void` | Nimbus.Iface.`finishBlobUpload​(String session)` |
    `void` | Nimbus.Client.`finishFileUpload​(String location)` |
    `void` | Nimbus.Iface.`finishFileUpload​(String location)` |
    `ReadableBlobMeta` | Nimbus.Client.`getBlobMeta​(String key)` |
    `ReadableBlobMeta` | Nimbus.Iface.`getBlobMeta​(String key)` |
    `int` | Nimbus.Client.`getBlobReplication​(String key)` |
    `int` | Nimbus.Iface.`getBlobReplication​(String key)` |
    `ClusterSummary` | Nimbus.Client.`getClusterInfo()` |
    `ClusterSummary` | Nimbus.Iface.`getClusterInfo()` |
    `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)` |
    `NimbusSummary` | Nimbus.Client.`getLeader()` |
    `NimbusSummary` | Nimbus.Iface.`getLeader()` |
    `Assignment` | Supervisor.Client.`getLocalAssignmentForStorm​(String id)` |
    `Assignment` | Supervisor.Iface.`getLocalAssignmentForStorm​(String id)` | Get local assignment for a storm
    `String` | Nimbus.Client.`getNimbusConf()` |
    `String` | Nimbus.Iface.`getNimbusConf()` |
    `List<OwnerResourceSummary>` | Nimbus.Client.`getOwnerResourceSummaries​(String owner)` |
    `List<OwnerResourceSummary>` | Nimbus.Iface.`getOwnerResourceSummaries​(String owner)` |
    `String` | DistributedRPC.AsyncClient.execute_call.`getResult()` |
    `Void` | DistributedRPCInvocations.AsyncClient.failRequest_call.`getResult()` |
    `Void` | DistributedRPCInvocations.AsyncClient.failRequestV2_call.`getResult()` |
    `DRPCRequest` | DistributedRPCInvocations.AsyncClient.fetchRequest_call.`getResult()` |
    `Void` | DistributedRPCInvocations.AsyncClient.result_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.activate_call.`getResult()` |
    `BeginDownloadResult` | Nimbus.AsyncClient.beginBlobDownload_call.`getResult()` |
    `String` | Nimbus.AsyncClient.beginCreateBlob_call.`getResult()` |
    `String` | Nimbus.AsyncClient.beginFileUpload_call.`getResult()` |
    `String` | Nimbus.AsyncClient.beginUpdateBlob_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.cancelBlobUpload_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.deactivate_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.debug_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.deleteBlob_call.`getResult()` |
    `ByteBuffer` | Nimbus.AsyncClient.downloadBlobChunk_call.`getResult()` |
    `ByteBuffer` | Nimbus.AsyncClient.downloadChunk_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.finishBlobUpload_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.finishFileUpload_call.`getResult()` |
    `ReadableBlobMeta` | Nimbus.AsyncClient.getBlobMeta_call.`getResult()` |
    `Integer` | Nimbus.AsyncClient.getBlobReplication_call.`getResult()` |
    `ClusterSummary` | Nimbus.AsyncClient.getClusterInfo_call.`getResult()` |
    `ComponentPageInfo` | Nimbus.AsyncClient.getComponentPageInfo_call.`getResult()` |
    `NimbusSummary` | Nimbus.AsyncClient.getLeader_call.`getResult()` |
    `String` | Nimbus.AsyncClient.getNimbusConf_call.`getResult()` |
    `List<OwnerResourceSummary>` | Nimbus.AsyncClient.getOwnerResourceSummaries_call.`getResult()` |
    `SupervisorAssignments` | Nimbus.AsyncClient.getSupervisorAssignments_call.`getResult()` |
    `SupervisorPageInfo` | Nimbus.AsyncClient.getSupervisorPageInfo_call.`getResult()` |
    `StormTopology` | Nimbus.AsyncClient.getTopology_call.`getResult()` |
    `String` | Nimbus.AsyncClient.getTopologyConf_call.`getResult()` |
    `TopologyHistoryInfo` | Nimbus.AsyncClient.getTopologyHistory_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()` |
    `List<TopologySummary>` | Nimbus.AsyncClient.getTopologySummaries_call.`getResult()` |
    `TopologySummary` | Nimbus.AsyncClient.getTopologySummary_call.`getResult()` |
    `TopologySummary` | Nimbus.AsyncClient.getTopologySummaryByName_call.`getResult()` |
    `StormTopology` | Nimbus.AsyncClient.getUserTopology_call.`getResult()` |
    `Boolean` | Nimbus.AsyncClient.isRemoteBlobExists_call.`getResult()` |
    `Boolean` | Nimbus.AsyncClient.isTopologyNameAllowed_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.sendSupervisorWorkerHeartbeats_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.setBlobMeta_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.submitTopology_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.submitTopologyWithOpts_call.`getResult()` |
    `Integer` | Nimbus.AsyncClient.updateBlobReplication_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.uploadBlobChunk_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.uploadChunk_call.`getResult()` |
    `Void` | Nimbus.AsyncClient.uploadNewCredentials_call.`getResult()` |
    `Assignment` | Supervisor.AsyncClient.getLocalAssignmentForStorm_call.`getResult()` |
    `Void` | Supervisor.AsyncClient.sendSupervisorAssignments_call.`getResult()` |
    `Void` | Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat_call.`getResult()` |
    `SupervisorAssignments` | Nimbus.Client.`getSupervisorAssignments​(String node)` |
    `SupervisorAssignments` | Nimbus.Iface.`getSupervisorAssignments​(String node)` | Get assigned assignments for a specific supervisor
    `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)` |
    `TopologyHistoryInfo` | Nimbus.Client.`getTopologyHistory​(String user)` |
    `TopologyHistoryInfo` | Nimbus.Iface.`getTopologyHistory​(String user)` |
    `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)` |
    `List<TopologySummary>` | Nimbus.Client.`getTopologySummaries()` |
    `List<TopologySummary>` | Nimbus.Iface.`getTopologySummaries()` |
    `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.
    `boolean` | Nimbus.Client.`isRemoteBlobExists​(String blobKey)` |
    `boolean` | Nimbus.Iface.`isRemoteBlobExists​(String blobKey)` | Decide if the blob is removed from cluster.
    `boolean` | Nimbus.Client.`isTopologyNameAllowed​(String name)` |
    `boolean` | Nimbus.Iface.`isTopologyNameAllowed​(String name)` |
    `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()` |
    `BeginDownloadResult` | Nimbus.Client.`recv_beginBlobDownload()` |
    `String` | Nimbus.Client.`recv_beginCreateBlob()` |
    `String` | Nimbus.Client.`recv_beginFileUpload()` |
    `String` | Nimbus.Client.`recv_beginUpdateBlob()` |
    `void` | Nimbus.Client.`recv_cancelBlobUpload()` |
    `void` | Nimbus.Client.`recv_deactivate()` |
    `void` | Nimbus.Client.`recv_debug()` |
    `void` | Nimbus.Client.`recv_deleteBlob()` |
    `ByteBuffer` | Nimbus.Client.`recv_downloadBlobChunk()` |
    `ByteBuffer` | Nimbus.Client.`recv_downloadChunk()` |
    `String` | DistributedRPC.Client.`recv_execute()` |
    `void` | DistributedRPCInvocations.Client.`recv_failRequest()` |
    `void` | DistributedRPCInvocations.Client.`recv_failRequestV2()` |
    `DRPCRequest` | DistributedRPCInvocations.Client.`recv_fetchRequest()` |
    `void` | Nimbus.Client.`recv_finishBlobUpload()` |
    `void` | Nimbus.Client.`recv_finishFileUpload()` |
    `ReadableBlobMeta` | Nimbus.Client.`recv_getBlobMeta()` |
    `int` | Nimbus.Client.`recv_getBlobReplication()` |
    `ClusterSummary` | Nimbus.Client.`recv_getClusterInfo()` |
    `ComponentPageInfo` | Nimbus.Client.`recv_getComponentPageInfo()` |
    `NimbusSummary` | Nimbus.Client.`recv_getLeader()` |
    `Assignment` | Supervisor.Client.`recv_getLocalAssignmentForStorm()` |
    `String` | Nimbus.Client.`recv_getNimbusConf()` |
    `List<OwnerResourceSummary>` | Nimbus.Client.`recv_getOwnerResourceSummaries()` |
    `SupervisorAssignments` | Nimbus.Client.`recv_getSupervisorAssignments()` |
    `SupervisorPageInfo` | Nimbus.Client.`recv_getSupervisorPageInfo()` |
    `StormTopology` | Nimbus.Client.`recv_getTopology()` |
    `String` | Nimbus.Client.`recv_getTopologyConf()` |
    `TopologyHistoryInfo` | Nimbus.Client.`recv_getTopologyHistory()` |
    `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()` |
    `List<TopologySummary>` | Nimbus.Client.`recv_getTopologySummaries()` |
    `TopologySummary` | Nimbus.Client.`recv_getTopologySummary()` |
    `TopologySummary` | Nimbus.Client.`recv_getTopologySummaryByName()` |
    `StormTopology` | Nimbus.Client.`recv_getUserTopology()` |
    `boolean` | Nimbus.Client.`recv_isRemoteBlobExists()` |
    `boolean` | Nimbus.Client.`recv_isTopologyNameAllowed()` |
    `void` | Nimbus.Client.`recv_killTopology()` |
    `void` | Nimbus.Client.`recv_killTopologyWithOpts()` |
    `void` | Nimbus.Client.`recv_rebalance()` |
    `void` | DistributedRPCInvocations.Client.`recv_result()` |
    `void` | Supervisor.Client.`recv_sendSupervisorAssignments()` |
    `void` | Nimbus.Client.`recv_sendSupervisorWorkerHeartbeat()` |
    `void` | Supervisor.Client.`recv_sendSupervisorWorkerHeartbeat()` |
    `void` | Nimbus.Client.`recv_sendSupervisorWorkerHeartbeats()` |
    `void` | Nimbus.Client.`recv_setBlobMeta()` |
    `void` | Nimbus.Client.`recv_submitTopology()` |
    `void` | Nimbus.Client.`recv_submitTopologyWithOpts()` |
    `int` | Nimbus.Client.`recv_updateBlobReplication()` |
    `void` | Nimbus.Client.`recv_uploadBlobChunk()` |
    `void` | Nimbus.Client.`recv_uploadChunk()` |
    `void` | Nimbus.Client.`recv_uploadNewCredentials()` |
    `void` | DistributedRPCInvocations.Client.`result​(String id, String result)` |
    `void` | DistributedRPCInvocations.Iface.`result​(String id, String result)` |
    `void` | Supervisor.Client.`sendSupervisorAssignments​(SupervisorAssignments assignments)` |
    `void` | Supervisor.Iface.`sendSupervisorAssignments​(SupervisorAssignments assignments)` | Send node specific assignments to supervisor
    `void` | Nimbus.Client.`sendSupervisorWorkerHeartbeat​(SupervisorWorkerHeartbeat heatbeat)` |
    `void` | Nimbus.Iface.`sendSupervisorWorkerHeartbeat​(SupervisorWorkerHeartbeat heatbeat)` | Send supervisor local worker heartbeat when a supervisor is unreachable
    `void` | Supervisor.Client.`sendSupervisorWorkerHeartbeat​(SupervisorWorkerHeartbeat heartbeat)` |
    `void` | Supervisor.Iface.`sendSupervisorWorkerHeartbeat​(SupervisorWorkerHeartbeat heartbeat)` | Send worker heartbeat to local supervisor
    `void` | Nimbus.Client.`sendSupervisorWorkerHeartbeats​(SupervisorWorkerHeartbeats heartbeats)` |
    `void` | Nimbus.Iface.`sendSupervisorWorkerHeartbeats​(SupervisorWorkerHeartbeats heartbeats)` | Send supervisor worker heartbeats for a specific supervisor
    `void` | Nimbus.Client.`setBlobMeta​(String key, SettableBlobMeta meta)` |
    `void` | Nimbus.Iface.`setBlobMeta​(String key, SettableBlobMeta meta)` |
    `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)` |
    `int` | Nimbus.Client.`updateBlobReplication​(String key, int replication)` |
    `int` | Nimbus.Iface.`updateBlobReplication​(String key, int replication)` |
    `void` | Nimbus.Client.`uploadBlobChunk​(String session, ByteBuffer chunk)` |
    `void` | Nimbus.Iface.`uploadBlobChunk​(String session, ByteBuffer chunk)` |
    `void` | Nimbus.Client.`uploadChunk​(String location, ByteBuffer chunk)` |
    `void` | Nimbus.Iface.`uploadChunk​(String location, ByteBuffer chunk)` |
    `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 AuthorizationException
    Constructor | Description
    --- | ---
    `activate_result​(NotAliveException e, AuthorizationException aze)` |
    `AuthorizationException​(AuthorizationException other)` | Performs a deep copy on other.
    `beginBlobDownload_result​(BeginDownloadResult success, AuthorizationException aze, KeyNotFoundException knf)` |
    `beginCreateBlob_result​(String success, AuthorizationException aze, KeyAlreadyExistsException kae)` |
    `beginFileUpload_result​(String success, AuthorizationException aze)` |
    `beginUpdateBlob_result​(String success, AuthorizationException aze, KeyNotFoundException knf)` |
    `cancelBlobUpload_result​(AuthorizationException aze)` |
    `deactivate_result​(NotAliveException e, AuthorizationException aze)` |
    `debug_result​(NotAliveException e, AuthorizationException aze)` |
    `deleteBlob_result​(AuthorizationException aze, KeyNotFoundException knf, IllegalStateException ise)` |
    `downloadBlobChunk_result​(ByteBuffer success, AuthorizationException aze)` |
    `downloadChunk_result​(ByteBuffer success, AuthorizationException aze)` |
    `execute_result​(String success, DRPCExecutionException e, AuthorizationException aze)` |
    `failRequest_result​(AuthorizationException aze)` |
    `failRequestV2_result​(AuthorizationException aze)` |
    `fetchRequest_result​(DRPCRequest success, AuthorizationException aze)` |
    `finishBlobUpload_result​(AuthorizationException aze)` |
    `finishFileUpload_result​(AuthorizationException aze)` |
    `getBlobMeta_result​(ReadableBlobMeta success, AuthorizationException aze, KeyNotFoundException knf)` |
    `getBlobReplication_result​(int success, AuthorizationException aze, KeyNotFoundException knf)` |
    `getClusterInfo_result​(ClusterSummary success, AuthorizationException aze)` |
    `getComponentPageInfo_result​(ComponentPageInfo success, NotAliveException e, AuthorizationException aze)` |
    `getLeader_result​(NimbusSummary success, AuthorizationException aze)` |
    `getLocalAssignmentForStorm_result​(Assignment success, NotAliveException e, AuthorizationException aze)` |
    `getNimbusConf_result​(String success, AuthorizationException aze)` |
    `getOwnerResourceSummaries_result​(List<OwnerResourceSummary> success, AuthorizationException aze)` |
    `getSupervisorAssignments_result​(SupervisorAssignments success, 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)` |
    `getTopologyHistory_result​(TopologyHistoryInfo success, 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)` |
    `getTopologySummaries_result​(List<TopologySummary> success, 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)` |
    `isRemoteBlobExists_result​(boolean success, AuthorizationException aze)` |
    `isTopologyNameAllowed_result​(boolean success, AuthorizationException aze)` |
    `killTopology_result​(NotAliveException e, AuthorizationException aze)` |
    `killTopologyWithOpts_result​(NotAliveException e, AuthorizationException aze)` |
    `rebalance_result​(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)` |
    `result_result​(AuthorizationException aze)` |
    `sendSupervisorAssignments_result​(AuthorizationException aze)` |
    `sendSupervisorWorkerHeartbeat_result​(AuthorizationException aze, NotAliveException e)` |
    `sendSupervisorWorkerHeartbeat_result​(AuthorizationException aze)` |
    `sendSupervisorWorkerHeartbeats_result​(AuthorizationException aze)` |
    `setBlobMeta_result​(AuthorizationException aze, KeyNotFoundException knf)` |
    `submitTopology_result​(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)` |
    `submitTopologyWithOpts_result​(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)` |
    `updateBlobReplication_result​(int success, AuthorizationException aze, KeyNotFoundException knf)` |
    `uploadBlobChunk_result​(AuthorizationException aze)` |
    `uploadChunk_result​(AuthorizationException aze)` |
    `uploadNewCredentials_result​(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)` |

  - ### Uses of AuthorizationException in org.apache.storm.hdfs.blobstore

    Methods in org.apache.storm.hdfs.blobstore that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `boolean` | HdfsBlobStore.`blobExists​(String key, Subject who)` | Checks if a blob exists.
    `AtomicOutputStream` | HdfsBlobStore.`createBlob​(String key, SettableBlobMeta meta, Subject who)` |
    `AtomicOutputStream` | HdfsClientBlobStore.`createBlobToExtend​(String key, SettableBlobMeta meta)` |
    `void` | HdfsBlobStore.`deleteBlob​(String key, Subject who)` |
    `void` | HdfsClientBlobStore.`deleteBlob​(String key)` |
    `InputStreamWithMeta` | HdfsBlobStore.`getBlob​(String key, Subject who)` |
    `InputStreamWithMeta` | HdfsClientBlobStore.`getBlob​(String key)` |
    `ReadableBlobMeta` | HdfsBlobStore.`getBlobMeta​(String key, Subject who)` |
    `ReadableBlobMeta` | HdfsClientBlobStore.`getBlobMeta​(String key)` |
    `int` | HdfsBlobStore.`getBlobReplication​(String key, Subject who)` |
    `int` | HdfsClientBlobStore.`getBlobReplication​(String key)` |
    `boolean` | HdfsClientBlobStore.`isRemoteBlobExists​(String blobKey)` |
    `void` | HdfsBlobStore.`setBlobMeta​(String key, SettableBlobMeta meta, Subject who)` |
    `void` | HdfsClientBlobStore.`setBlobMetaToExtend​(String key, SettableBlobMeta meta)` |
    `AtomicOutputStream` | HdfsBlobStore.`updateBlob​(String key, Subject who)` |
    `AtomicOutputStream` | HdfsClientBlobStore.`updateBlob​(String key)` |
    `int` | HdfsBlobStore.`updateBlobReplication​(String key, int replication, Subject who)` |
    `int` | HdfsClientBlobStore.`updateBlobReplication​(String key, int replication)` |
    `void` | HdfsBlobStore.`writeMetadata​(String key, SettableBlobMeta meta)` |

  - ### Uses of AuthorizationException in org.apache.storm.kafka.trident

    Methods in org.apache.storm.kafka.trident that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `protected void` | TridentKafkaClientTopologyNamedTopics.`run​(String[] args)` |

  - ### Uses of AuthorizationException in org.apache.storm.localizer

    Methods in org.apache.storm.localizer that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `protected org.apache.storm.localizer.LocallyCachedBlob.DownloadMeta` | LocallyCachedBlob.`fetch​(ClientBlobStore store, String key, IOFunction<Long,​Path> pathSupplier, IOFunction<File,​OutputStream> outStreamSupplier)` | Helper function to download blob from blob store.
    `long` | LocalizedResource.`fetchUnzipToTemp​(ClientBlobStore store)` |
    `abstract long` | LocallyCachedBlob.`fetchUnzipToTemp​(ClientBlobStore store)` | Download the latest version to a temp location.
    `long` | LocallyCachedTopologyBlob.`fetchUnzipToTemp​(ClientBlobStore store)` |
    `long` | LocalizedResource.`getRemoteVersion​(ClientBlobStore store)` |
    `abstract long` | LocallyCachedBlob.`getRemoteVersion​(ClientBlobStore store)` | Get the version of the blob in the blob store.
    `long` | LocallyCachedTopologyBlob.`getRemoteVersion​(ClientBlobStore store)` |
    `void` | LocallyCachedBlob.`update​(ClientBlobStore blobStore, long remoteBlobstoreUpdateTime)` | Checks and downloads a blob locally as necessary.

  - ### Uses of AuthorizationException in org.apache.storm.utils

    Subclasses of AuthorizationException in org.apache.storm.utils
    Modifier and Type | Class | Description
    --- | --- | ---
    `class` | `WrappedAuthorizationException` | Wraps the generated TException to allow getMessage() to return a valid string.

    Methods in org.apache.storm.utils that throw AuthorizationException
    Modifier and Type | Method | Description
    --- | --- | ---
    `String` | DRPCClient.`execute​(String func, String args)` |
    `static long` | ServerUtils.`nimbusVersionOfBlob​(String key, ClientBlobStore cb)` |
    `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.