## 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.elasticsearch.bolt | ElasticSearch examples classes.
  org.apache.storm.elasticsearch.trident | ElasticSearch Trident example classes.
  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 and 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)`
    `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.
    `void` | LocalCluster.`submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)`
    `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 and 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.
    `AtomicOutputStream` | ClientBlobStore.`createBlob(String key, SettableBlobMeta meta)` Client facing API to create a blob.
    `AtomicOutputStream` | LocalFsBlobStore.`createBlob(String key, SettableBlobMeta meta, Subject who)`
    `abstract AtomicOutputStream` | BlobStore.`createBlob(String key, SettableBlobMeta meta, Subject who)` Creates the blob.
    `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` | ClientBlobStore.`deleteBlob(String key)` Client facing API to delete a blob.
    `void` | LocalModeClientBlobStore.`deleteBlob(String key)`
    `void` | NimbusBlobStore.`deleteBlob(String key)`
    `void` | LocalFsBlobStore.`deleteBlob(String key, Subject who)`
    `abstract void` | BlobStore.`deleteBlob(String key, Subject who)` Deletes the blob data and metadata.
    `abstract InputStreamWithMeta` | ClientBlobStore.`getBlob(String key)` Client facing API to read a blob.
    `InputStreamWithMeta` | LocalModeClientBlobStore.`getBlob(String key)`
    `InputStreamWithMeta` | NimbusBlobStore.`getBlob(String key)`
    `InputStreamWithMeta` | LocalFsBlobStore.`getBlob(String key, Subject who)`
    `abstract InputStreamWithMeta` | BlobStore.`getBlob(String key, Subject who)` Gets the InputStream to read the blob details.
    `abstract ReadableBlobMeta` | ClientBlobStore.`getBlobMeta(String key)` Client facing API to read the metadata information.
    `ReadableBlobMeta` | LocalModeClientBlobStore.`getBlobMeta(String key)`
    `ReadableBlobMeta` | NimbusBlobStore.`getBlobMeta(String key)`
    `ReadableBlobMeta` | LocalFsBlobStore.`getBlobMeta(String key, Subject who)`
    `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 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.
    `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)`
    `abstract void` | BlobStore.`setBlobMeta(String key, SettableBlobMeta meta, Subject who)` Sets the metadata with renewed acls for the blob.
    `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` | LocalFsBlobStore.`startSyncBlobs()`
    `void` | BlobStore.`startSyncBlobs()` Start the syncing blobs between the local running instance of the BlobStore and others.
    `abstract AtomicOutputStream` | ClientBlobStore.`updateBlob(String key)` Client facing API to update a blob.
    `AtomicOutputStream` | LocalModeClientBlobStore.`updateBlob(String key)`
    `AtomicOutputStream` | NimbusBlobStore.`updateBlob(String key)`
    `void` | BlobStore.`updateBlob(String key, byte[] data, Subject who)` Wrapper called to create the blob which contains the byte data.
    `AtomicOutputStream` | LocalFsBlobStore.`updateBlob(String key, Subject who)`
    `abstract AtomicOutputStream` | BlobStore.`updateBlob(String key, Subject who)` Updates the blob data.
    `abstract int` | ClientBlobStore.`updateBlobReplication(String key, int replication)` Client facing API to update the replication of a blob.
    `int` | LocalModeClientBlobStore.`updateBlobReplication(String key, int replication)`
    `int` | NimbusBlobStore.`updateBlobReplication(String key, int replication)`
    `int` | LocalFsBlobStore.`updateBlobReplication(String key, int replication, Subject who)`
    `abstract int` | BlobStore.`updateBlobReplication(String key, int replication, Subject who)` Modifies the replication factor of the blob.
    `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 and Description
    --- | ---
    `javax.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 and Description
    --- | ---
    `String` | DRPCThrift.`execute(String functionName, String funcArgs)`
    `<T extends OutstandingRequest> T` | DRPC.`execute(String functionName, String funcArgs, RequestFactory<T> factory)`
    `String` | DRPC.`executeBlocking(String functionName, String funcArgs)`
    `void` | DRPCThrift.`failRequest(String id)`
    `void` | DRPC.`failRequest(String id, DRPCExecutionException e)`
    `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 and 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 and 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 and Description
    --- | ---
    `static javax.ws.rs.core.Response` | ExceptionMapperUtils.`getResponse(AuthorizationException ex, javax.inject.Provider<javax.servlet.http.HttpServletRequest> request)` getResponse.
    `javax.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 and 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 and 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.elasticsearch.bolt

    Methods in org.apache.storm.elasticsearch.bolt that throw AuthorizationException
    Modifier and Type | Method and Description
    --- | ---
    `static void` | EsIndexTopology.`main(String[] args)` The example’s main method.

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

    Methods in org.apache.storm.elasticsearch.trident that throw AuthorizationException
    Modifier and Type | Method and Description
    --- | ---
    `static void` | TridentEsTopology.`main(String[] args)` The example’s main method.

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

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

    Methods in org.apache.storm.generated with parameters of type AuthorizationException
    Modifier and Type | Method and Description
    --- | ---
    `int` | AuthorizationException.`compareTo(AuthorizationException other)`
    `boolean` | AuthorizationException.`equals(AuthorizationException that)`
    `void` | DistributedRPC.execute_result.`set_aze(AuthorizationException aze)`
    `void` | DistributedRPCInvocations.result_result.`set_aze(AuthorizationException aze)`
    `void` | DistributedRPCInvocations.fetchRequest_result.`set_aze(AuthorizationException aze)`
    `void` | DistributedRPCInvocations.failRequest_result.`set_aze(AuthorizationException aze)`
    `void` | DistributedRPCInvocations.failRequestV2_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.submitTopology_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.submitTopologyWithOpts_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.killTopology_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.killTopologyWithOpts_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.activate_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.deactivate_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.rebalance_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.debug_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.uploadNewCredentials_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.beginCreateBlob_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.beginUpdateBlob_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.uploadBlobChunk_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.finishBlobUpload_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.cancelBlobUpload_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getBlobMeta_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.setBlobMeta_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.beginBlobDownload_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.downloadBlobChunk_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.deleteBlob_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getBlobReplication_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.updateBlobReplication_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.beginFileUpload_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.uploadChunk_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.finishFileUpload_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.downloadChunk_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getNimbusConf_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getClusterInfo_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopologySummaries_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopologySummaryByName_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopologySummary_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getLeader_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.isTopologyNameAllowed_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopologyInfoByName_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopologyInfo_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.getSupervisorPageInfo_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getComponentPageInfo_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopologyConf_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopology_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getUserTopology_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getTopologyHistory_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getOwnerResourceSummaries_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.getSupervisorAssignments_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.sendSupervisorWorkerHeartbeats_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.sendSupervisorWorkerHeartbeat_result.`set_aze(AuthorizationException aze)`
    `void` | Nimbus.isRemoteBlobExists_result.`set_aze(AuthorizationException aze)`
    `void` | Supervisor.sendSupervisorAssignments_result.`set_aze(AuthorizationException aze)`
    `void` | Supervisor.getLocalAssignmentForStorm_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 and Description
    --- | ---
    `void` | Nimbus.Iface.`activate(String name)`
    `void` | Nimbus.Client.`activate(String name)`
    `BeginDownloadResult` | Nimbus.Iface.`beginBlobDownload(String key)`
    `BeginDownloadResult` | Nimbus.Client.`beginBlobDownload(String key)`
    `String` | Nimbus.Iface.`beginCreateBlob(String key, SettableBlobMeta meta)`
    `String` | Nimbus.Client.`beginCreateBlob(String key, SettableBlobMeta meta)`
    `String` | Nimbus.Iface.`beginFileUpload()`
    `String` | Nimbus.Client.`beginFileUpload()`
    `String` | Nimbus.Iface.`beginUpdateBlob(String key)`
    `String` | Nimbus.Client.`beginUpdateBlob(String key)`
    `void` | Nimbus.Iface.`cancelBlobUpload(String session)`
    `void` | Nimbus.Client.`cancelBlobUpload(String session)`
    `void` | Nimbus.Iface.`deactivate(String name)`
    `void` | Nimbus.Client.`deactivate(String name)`
    `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.`debug(String name, String component, boolean enable, double samplingPercentage)`
    `void` | Nimbus.Iface.`deleteBlob(String key)`
    `void` | Nimbus.Client.`deleteBlob(String key)`
    `ByteBuffer` | Nimbus.Iface.`downloadBlobChunk(String session)`
    `ByteBuffer` | Nimbus.Client.`downloadBlobChunk(String session)`
    `ByteBuffer` | Nimbus.Iface.`downloadChunk(String id)`
    `ByteBuffer` | Nimbus.Client.`downloadChunk(String id)`
    `String` | DistributedRPC.Iface.`execute(String functionName, String funcArgs)`
    `String` | DistributedRPC.Client.`execute(String functionName, String funcArgs)`
    `void` | DistributedRPCInvocations.Iface.`failRequest(String id)`
    `void` | DistributedRPCInvocations.Client.`failRequest(String id)`
    `void` | DistributedRPCInvocations.Iface.`failRequestV2(String id, DRPCExecutionException e)`
    `void` | DistributedRPCInvocations.Client.`failRequestV2(String id, DRPCExecutionException e)`
    `DRPCRequest` | DistributedRPCInvocations.Iface.`fetchRequest(String functionName)`
    `DRPCRequest` | DistributedRPCInvocations.Client.`fetchRequest(String functionName)`
    `void` | Nimbus.Iface.`finishBlobUpload(String session)`
    `void` | Nimbus.Client.`finishBlobUpload(String session)`
    `void` | Nimbus.Iface.`finishFileUpload(String location)`
    `void` | Nimbus.Client.`finishFileUpload(String location)`
    `ReadableBlobMeta` | Nimbus.Iface.`getBlobMeta(String key)`
    `ReadableBlobMeta` | Nimbus.Client.`getBlobMeta(String key)`
    `int` | Nimbus.Iface.`getBlobReplication(String key)`
    `int` | Nimbus.Client.`getBlobReplication(String key)`
    `ClusterSummary` | Nimbus.Iface.`getClusterInfo()`
    `ClusterSummary` | Nimbus.Client.`getClusterInfo()`
    `ComponentPageInfo` | Nimbus.Iface.`getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)`
    `ComponentPageInfo` | Nimbus.Client.`getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)`
    `NimbusSummary` | Nimbus.Iface.`getLeader()`
    `NimbusSummary` | Nimbus.Client.`getLeader()`
    `Assignment` | Supervisor.Iface.`getLocalAssignmentForStorm(String id)` Get local assignment for a storm
    `Assignment` | Supervisor.Client.`getLocalAssignmentForStorm(String id)`
    `String` | Nimbus.Iface.`getNimbusConf()`
    `String` | Nimbus.Client.`getNimbusConf()`
    `List<OwnerResourceSummary>` | Nimbus.Iface.`getOwnerResourceSummaries(String owner)`
    `List<OwnerResourceSummary>` | Nimbus.Client.`getOwnerResourceSummaries(String owner)`
    `String` | DistributedRPC.AsyncClient.execute_call.`getResult()`
    `Void` | DistributedRPCInvocations.AsyncClient.result_call.`getResult()`
    `DRPCRequest` | DistributedRPCInvocations.AsyncClient.fetchRequest_call.`getResult()`
    `Void` | DistributedRPCInvocations.AsyncClient.failRequest_call.`getResult()`
    `Void` | DistributedRPCInvocations.AsyncClient.failRequestV2_call.`getResult()`
    `Void` | Nimbus.AsyncClient.submitTopology_call.`getResult()`
    `Void` | Nimbus.AsyncClient.submitTopologyWithOpts_call.`getResult()`
    `Void` | Nimbus.AsyncClient.killTopology_call.`getResult()`
    `Void` | Nimbus.AsyncClient.killTopologyWithOpts_call.`getResult()`
    `Void` | Nimbus.AsyncClient.activate_call.`getResult()`
    `Void` | Nimbus.AsyncClient.deactivate_call.`getResult()`
    `Void` | Nimbus.AsyncClient.rebalance_call.`getResult()`
    `Void` | Nimbus.AsyncClient.debug_call.`getResult()`
    `Void` | Nimbus.AsyncClient.uploadNewCredentials_call.`getResult()`
    `String` | Nimbus.AsyncClient.beginCreateBlob_call.`getResult()`
    `String` | Nimbus.AsyncClient.beginUpdateBlob_call.`getResult()`
    `Void` | Nimbus.AsyncClient.uploadBlobChunk_call.`getResult()`
    `Void` | Nimbus.AsyncClient.finishBlobUpload_call.`getResult()`
    `Void` | Nimbus.AsyncClient.cancelBlobUpload_call.`getResult()`
    `ReadableBlobMeta` | Nimbus.AsyncClient.getBlobMeta_call.`getResult()`
    `Void` | Nimbus.AsyncClient.setBlobMeta_call.`getResult()`
    `BeginDownloadResult` | Nimbus.AsyncClient.beginBlobDownload_call.`getResult()`
    `ByteBuffer` | Nimbus.AsyncClient.downloadBlobChunk_call.`getResult()`
    `Void` | Nimbus.AsyncClient.deleteBlob_call.`getResult()`
    `Integer` | Nimbus.AsyncClient.getBlobReplication_call.`getResult()`
    `Integer` | Nimbus.AsyncClient.updateBlobReplication_call.`getResult()`
    `String` | Nimbus.AsyncClient.beginFileUpload_call.`getResult()`
    `Void` | Nimbus.AsyncClient.uploadChunk_call.`getResult()`
    `Void` | Nimbus.AsyncClient.finishFileUpload_call.`getResult()`
    `ByteBuffer` | Nimbus.AsyncClient.downloadChunk_call.`getResult()`
    `String` | Nimbus.AsyncClient.getNimbusConf_call.`getResult()`
    `ClusterSummary` | Nimbus.AsyncClient.getClusterInfo_call.`getResult()`
    `List<TopologySummary>` | Nimbus.AsyncClient.getTopologySummaries_call.`getResult()`
    `TopologySummary` | Nimbus.AsyncClient.getTopologySummaryByName_call.`getResult()`
    `TopologySummary` | Nimbus.AsyncClient.getTopologySummary_call.`getResult()`
    `NimbusSummary` | Nimbus.AsyncClient.getLeader_call.`getResult()`
    `Boolean` | Nimbus.AsyncClient.isTopologyNameAllowed_call.`getResult()`
    `TopologyInfo` | Nimbus.AsyncClient.getTopologyInfoByName_call.`getResult()`
    `TopologyInfo` | Nimbus.AsyncClient.getTopologyInfo_call.`getResult()`
    `TopologyInfo` | Nimbus.AsyncClient.getTopologyInfoByNameWithOpts_call.`getResult()`
    `TopologyInfo` | Nimbus.AsyncClient.getTopologyInfoWithOpts_call.`getResult()`
    `TopologyPageInfo` | Nimbus.AsyncClient.getTopologyPageInfo_call.`getResult()`
    `SupervisorPageInfo` | Nimbus.AsyncClient.getSupervisorPageInfo_call.`getResult()`
    `ComponentPageInfo` | Nimbus.AsyncClient.getComponentPageInfo_call.`getResult()`
    `String` | Nimbus.AsyncClient.getTopologyConf_call.`getResult()`
    `StormTopology` | Nimbus.AsyncClient.getTopology_call.`getResult()`
    `StormTopology` | Nimbus.AsyncClient.getUserTopology_call.`getResult()`
    `TopologyHistoryInfo` | Nimbus.AsyncClient.getTopologyHistory_call.`getResult()`
    `List<OwnerResourceSummary>` | Nimbus.AsyncClient.getOwnerResourceSummaries_call.`getResult()`
    `SupervisorAssignments` | Nimbus.AsyncClient.getSupervisorAssignments_call.`getResult()`
    `Void` | Nimbus.AsyncClient.sendSupervisorWorkerHeartbeats_call.`getResult()`
    `Void` | Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat_call.`getResult()`
    `Boolean` | Nimbus.AsyncClient.isRemoteBlobExists_call.`getResult()`
    `Void` | Supervisor.AsyncClient.sendSupervisorAssignments_call.`getResult()`
    `Assignment` | Supervisor.AsyncClient.getLocalAssignmentForStorm_call.`getResult()`
    `Void` | Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat_call.`getResult()`
    `SupervisorAssignments` | Nimbus.Iface.`getSupervisorAssignments(String node)` Get assigned assignments for a specific supervisor
    `SupervisorAssignments` | Nimbus.Client.`getSupervisorAssignments(String node)`
    `SupervisorPageInfo` | Nimbus.Iface.`getSupervisorPageInfo(String id, String host, boolean is_include_sys)`
    `SupervisorPageInfo` | Nimbus.Client.`getSupervisorPageInfo(String id, String host, boolean is_include_sys)`
    `StormTopology` | Nimbus.Iface.`getTopology(String id)` Returns the compiled topology that contains ackers and metrics consumsers.
    `StormTopology` | Nimbus.Client.`getTopology(String id)`
    `String` | Nimbus.Iface.`getTopologyConf(String id)`
    `String` | Nimbus.Client.`getTopologyConf(String id)`
    `TopologyHistoryInfo` | Nimbus.Iface.`getTopologyHistory(String user)`
    `TopologyHistoryInfo` | Nimbus.Client.`getTopologyHistory(String user)`
    `TopologyInfo` | Nimbus.Iface.`getTopologyInfo(String id)`
    `TopologyInfo` | Nimbus.Client.`getTopologyInfo(String id)`
    `TopologyInfo` | Nimbus.Iface.`getTopologyInfoByName(String name)`
    `TopologyInfo` | Nimbus.Client.`getTopologyInfoByName(String name)`
    `TopologyInfo` | Nimbus.Iface.`getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)`
    `TopologyInfo` | Nimbus.Client.`getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)`
    `TopologyInfo` | Nimbus.Iface.`getTopologyInfoWithOpts(String id, GetInfoOptions options)`
    `TopologyInfo` | Nimbus.Client.`getTopologyInfoWithOpts(String id, GetInfoOptions options)`
    `TopologyPageInfo` | Nimbus.Iface.`getTopologyPageInfo(String id, String window, boolean is_include_sys)`
    `TopologyPageInfo` | Nimbus.Client.`getTopologyPageInfo(String id, String window, boolean is_include_sys)`
    `List<TopologySummary>` | Nimbus.Iface.`getTopologySummaries()`
    `List<TopologySummary>` | Nimbus.Client.`getTopologySummaries()`
    `TopologySummary` | Nimbus.Iface.`getTopologySummary(String id)`
    `TopologySummary` | Nimbus.Client.`getTopologySummary(String id)`
    `TopologySummary` | Nimbus.Iface.`getTopologySummaryByName(String name)`
    `TopologySummary` | Nimbus.Client.`getTopologySummaryByName(String name)`
    `StormTopology` | Nimbus.Iface.`getUserTopology(String id)` Returns the user specified topology as submitted originally.
    `StormTopology` | Nimbus.Client.`getUserTopology(String id)`
    `boolean` | Nimbus.Iface.`isRemoteBlobExists(String blobKey)` Decide if the blob is removed from cluster.
    `boolean` | Nimbus.Client.`isRemoteBlobExists(String blobKey)`
    `boolean` | Nimbus.Iface.`isTopologyNameAllowed(String name)`
    `boolean` | Nimbus.Client.`isTopologyNameAllowed(String name)`
    `void` | Nimbus.Iface.`killTopology(String name)`
    `void` | Nimbus.Client.`killTopology(String name)`
    `void` | Nimbus.Iface.`killTopologyWithOpts(String name, KillOptions options)`
    `void` | Nimbus.Client.`killTopologyWithOpts(String name, KillOptions options)`
    `void` | Nimbus.Iface.`rebalance(String name, RebalanceOptions options)`
    `void` | Nimbus.Client.`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.Iface.`result(String id, String result)`
    `void` | DistributedRPCInvocations.Client.`result(String id, String result)`
    `void` | Supervisor.Iface.`sendSupervisorAssignments(SupervisorAssignments assignments)` Send node specific assignments to supervisor
    `void` | Supervisor.Client.`sendSupervisorAssignments(SupervisorAssignments assignments)`
    `void` | Nimbus.Iface.`sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)` Send supervisor local worker heartbeat when a supervisor is unreachable
    `void` | Nimbus.Client.`sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)`
    `void` | Supervisor.Iface.`sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)` Send worker heartbeat to local supervisor
    `void` | Supervisor.Client.`sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)`
    `void` | Nimbus.Iface.`sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)` Send supervisor worker heartbeats for a specific supervisor
    `void` | Nimbus.Client.`sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)`
    `void` | Nimbus.Iface.`setBlobMeta(String key, SettableBlobMeta meta)`
    `void` | Nimbus.Client.`setBlobMeta(String key, SettableBlobMeta meta)`
    `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)`
    `int` | Nimbus.Iface.`updateBlobReplication(String key, int replication)`
    `int` | Nimbus.Client.`updateBlobReplication(String key, int replication)`
    `void` | Nimbus.Iface.`uploadBlobChunk(String session, ByteBuffer chunk)`
    `void` | Nimbus.Client.`uploadBlobChunk(String session, ByteBuffer chunk)`
    `void` | Nimbus.Iface.`uploadChunk(String location, ByteBuffer chunk)`
    `void` | Nimbus.Client.`uploadChunk(String location, ByteBuffer chunk)`
    `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 AuthorizationException
    Constructor and 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)`
    `sendSupervisorWorkerHeartbeat_result(AuthorizationException aze, NotAliveException e)`
    `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 and 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` | HdfsClientBlobStore.`deleteBlob(String key)`
    `void` | HdfsBlobStore.`deleteBlob(String key, Subject who)`
    `InputStreamWithMeta` | HdfsClientBlobStore.`getBlob(String key)`
    `InputStreamWithMeta` | HdfsBlobStore.`getBlob(String key, Subject who)`
    `ReadableBlobMeta` | HdfsClientBlobStore.`getBlobMeta(String key)`
    `ReadableBlobMeta` | HdfsBlobStore.`getBlobMeta(String key, Subject who)`
    `int` | HdfsClientBlobStore.`getBlobReplication(String key)`
    `int` | HdfsBlobStore.`getBlobReplication(String key, Subject who)`
    `boolean` | HdfsClientBlobStore.`isRemoteBlobExists(String blobKey)`
    `void` | HdfsBlobStore.`setBlobMeta(String key, SettableBlobMeta meta, Subject who)`
    `void` | HdfsClientBlobStore.`setBlobMetaToExtend(String key, SettableBlobMeta meta)`
    `AtomicOutputStream` | HdfsClientBlobStore.`updateBlob(String key)`
    `AtomicOutputStream` | HdfsBlobStore.`updateBlob(String key, Subject who)`
    `int` | HdfsClientBlobStore.`updateBlobReplication(String key, int replication)`
    `int` | HdfsBlobStore.`updateBlobReplication(String key, int replication, Subject who)`
    `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 and 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 and 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.
    `abstract long` | LocallyCachedBlob.`fetchUnzipToTemp(ClientBlobStore store)` Download the latest version to a temp location.
    `long` | LocallyCachedTopologyBlob.`fetchUnzipToTemp(ClientBlobStore store)`
    `long` | LocalizedResource.`fetchUnzipToTemp(ClientBlobStore store)`
    `abstract long` | LocallyCachedBlob.`getRemoteVersion(ClientBlobStore store)` Get the version of the blob in the blob store.
    `long` | LocallyCachedTopologyBlob.`getRemoteVersion(ClientBlobStore store)`
    `long` | LocalizedResource.`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 and 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 and 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.

Copyright © 2021 The Apache Software Foundation. All rights reserved.