Uses of Class
org.apache.storm.generated.AuthorizationException
Packages that use AuthorizationException
Package
Description
-
Uses of AuthorizationException in org.apache.storm
Methods in org.apache.storm that throw AuthorizationExceptionModifier and TypeMethodDescriptionLocalCluster.beginBlobDownload(String key) LocalCluster.beginCreateBlob(String key, SettableBlobMeta meta) LocalCluster.beginFileUpload()LocalCluster.beginUpdateBlob(String key) voidLocalCluster.cancelBlobUpload(String session) voidvoidLocalCluster.deleteBlob(String key) LocalCluster.downloadBlobChunk(String session) LocalCluster.downloadChunk(String id) voidLocalDRPC.failRequest(String id) voidLocalDRPC.failRequestV2(String id, DRPCExecutionException e) LocalDRPC.fetchRequest(String functionName) voidLocalCluster.finishBlobUpload(String session) voidLocalCluster.finishFileUpload(String location) LocalCluster.getBlobMeta(String key) intLocalCluster.getBlobReplication(String key) LocalCluster.getComponentPageInfo(String topologyId, String componentId, String window, boolean isIncludeSys) LocalCluster.getLeader()LocalCluster.getNimbusConf()LocalCluster.getOwnerResourceSummaries(String owner) LocalCluster.getSupervisorAssignments(String node) LocalCluster.getSupervisorPageInfo(String id, String host, boolean isIncludeSys) LocalCluster.getTopologyHistory(String user) LocalCluster.getTopologyPageInfo(String id, String window, boolean isIncludeSys) LocalCluster.getUserTopology(String id) booleanLocalCluster.isRemoteBlobExists(String blobKey) booleanLocalCluster.isTopologyNameAllowed(String name) static booleanStormSubmitter.pushCredentials(String name, Map<String, Object> topoConf, Map<String, String> credentials) Push a new set of credentials to the running topology.static booleanStormSubmitter.pushCredentials(String name, Map<String, Object> topoConf, Map<String, String> credentials, String expectedUser) Push a new set of credentials to the running topology.voidvoidLocalCluster.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) voidLocalCluster.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) voidLocalCluster.setBlobMeta(String key, SettableBlobMeta meta) voidLocalCluster.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) static voidStormSubmitter.submitTopology(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster.static voidStormSubmitter.submitTopology(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.static voidStormSubmitter.submitTopology(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.static voidStormSubmitter.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.voidLocalCluster.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) static voidStormSubmitter.submitTopologyWithProgressBar(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.static voidStormSubmitter.submitTopologyWithProgressBar(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar.intLocalCluster.updateBlobReplication(String key, int replication) voidLocalCluster.uploadBlobChunk(String session, ByteBuffer chunk) voidLocalCluster.uploadChunk(String location, ByteBuffer chunk) -
Uses of AuthorizationException in org.apache.storm.blobstore
Methods in org.apache.storm.blobstore that throw AuthorizationExceptionModifier and TypeMethodDescriptionprotected static voidMigrateBlobs.copyBlobStoreKeys(BlobStore bsFrom, Subject whoFrom, BlobStore bsTo, Subject whoTo) voidBlobStore.createBlob(String key, byte[] data, SettableBlobMeta meta, Subject who) Wrapper called to create the blob which contains the byte data.voidBlobStore.createBlob(String key, InputStream in, SettableBlobMeta meta, Subject who) Wrapper called to create the blob which contains the byte data.abstract AtomicOutputStreamBlobStore.createBlob(String key, SettableBlobMeta meta, Subject who) Creates the blob.final AtomicOutputStreamClientBlobStore.createBlob(String key, SettableBlobMeta meta) Client facing API to create a blob.LocalFsBlobStore.createBlob(String key, SettableBlobMeta meta, Subject who) protected abstract AtomicOutputStreamClientBlobStore.createBlobToExtend(String key, SettableBlobMeta meta) Client facing API to create a blob.protected AtomicOutputStreamLocalModeClientBlobStore.createBlobToExtend(String key, SettableBlobMeta meta) protected AtomicOutputStreamNimbusBlobStore.createBlobToExtend(String key, SettableBlobMeta meta) protected static voidMigrateBlobs.deleteAllBlobStoreKeys(BlobStore bs, Subject who) abstract voidBlobStore.deleteBlob(String key, Subject who) Deletes the blob data and metadata.abstract voidClientBlobStore.deleteBlob(String key) Client facing API to delete a blob.voidLocalFsBlobStore.deleteBlob(String key, Subject who) voidLocalModeClientBlobStore.deleteBlob(String key) voidNimbusBlobStore.deleteBlob(String key) abstract InputStreamWithMetaGets the InputStream to read the blob details.abstract InputStreamWithMetaClient facing API to read a blob.abstract ReadableBlobMetaBlobStore.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 ReadableBlobMetaClientBlobStore.getBlobMeta(String key) Client facing API to read the metadata information.LocalFsBlobStore.getBlobMeta(String key, Subject who) LocalModeClientBlobStore.getBlobMeta(String key) NimbusBlobStore.getBlobMeta(String key) abstract intClientBlobStore.getBlobReplication(String key) Client facing API to read the replication of a blob.intLocalModeClientBlobStore.getBlobReplication(String key) intNimbusBlobStore.getBlobReplication(String key) voidBlobStoreAclHandler.hasAnyPermissions(List<AccessControl> acl, int mask, Subject who, String key) Validates if the user has any of the permissions mentioned in the mask.voidBlobStoreAclHandler.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 booleanClientBlobStore.isRemoteBlobExists(String blobKey) Decide if the blob is deleted from cluster.booleanLocalModeClientBlobStore.isRemoteBlobExists(String blobKey) booleanNimbusBlobStore.isRemoteBlobExists(String blobKey) byte[]Wrapper around readBlobTo which returns a ByteArray output stream.voidBlobStore.readBlobTo(String key, OutputStream out, Subject who) Reads the blob from the blob store and writes it into the output stream.abstract voidBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who) Sets the metadata with renewed acls for the blob.final voidClientBlobStore.setBlobMeta(String key, SettableBlobMeta meta) Client facing API to set the metadata for a blob.voidLocalFsBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who) protected abstract voidClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) Client facing API to set the metadata for a blob.protected voidLocalModeClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) protected voidNimbusBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) voidBlobStore.startSyncBlobs()Start the syncing blobs between the local running instance of the BlobStore and others.voidLocalFsBlobStore.startSyncBlobs()voidBlobStore.updateBlob(String key, byte[] data, Subject who) Wrapper called to create the blob which contains the byte data.abstract AtomicOutputStreamBlobStore.updateBlob(String key, Subject who) Updates the blob data.abstract AtomicOutputStreamClientBlobStore.updateBlob(String key) Client facing API to update a blob.LocalFsBlobStore.updateBlob(String key, Subject who) LocalModeClientBlobStore.updateBlob(String key) NimbusBlobStore.updateBlob(String key) abstract intBlobStore.updateBlobReplication(String key, int replication, Subject who) Modifies the replication factor of the blob.abstract intClientBlobStore.updateBlobReplication(String key, int replication) Client facing API to update the replication of a blob.intLocalFsBlobStore.updateBlobReplication(String key, int replication, Subject who) intLocalModeClientBlobStore.updateBlobReplication(String key, int replication) intNimbusBlobStore.updateBlobReplication(String key, int replication) static voidBlobStoreAclHandler.validateSettableACLs(String key, List<AccessControl> acls) voidBlobStoreAclHandler.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 AuthorizationExceptionModifier and TypeMethodDescriptionjakarta.ws.rs.core.ResponseAuthorizationExceptionMapper.toResponse(AuthorizationException ex) -
Uses of AuthorizationException in org.apache.storm.daemon.drpc
Methods in org.apache.storm.daemon.drpc that throw AuthorizationExceptionModifier and TypeMethodDescription<T extends OutstandingRequest>
TDRPC.execute(String functionName, String funcArgs, RequestFactory<T> factory) DRPC.executeBlocking(String functionName, String funcArgs) voidDRPC.failRequest(String id, DRPCExecutionException e) voidDRPCThrift.failRequest(String id) voidDRPCThrift.failRequestV2(String id, DRPCExecutionException e) DRPC.fetchRequest(String functionName) DRPCThrift.fetchRequest(String functionName) voidvoidDRPC.returnResult(String id, String result) -
Uses of AuthorizationException in org.apache.storm.daemon.nimbus
Methods in org.apache.storm.daemon.nimbus that throw AuthorizationExceptionModifier and TypeMethodDescriptionvoidvoidAdd a new topology config.voidTopoCache.addTopology(String topoId, Subject who, StormTopology topo) Add a new topology.Nimbus.beginBlobDownload(String key) Nimbus.beginCreateBlob(String key, SettableBlobMeta meta) Nimbus.beginFileUpload()Nimbus.beginUpdateBlob(String key) voidNimbus.cancelBlobUpload(String session) voidvoidNimbus.checkAuthorization(String topoName, Map<String, Object> topoConf, String operation, ReqContext context) voidNimbus.deactivate(String topoName) voidvoidNimbus.deleteBlob(String key) voidTopoCache.deleteTopoConf(String topoId, Subject who) Delete a topology conf when we are done.voidTopoCache.deleteTopology(String topoId, Subject who) Delete a topology when we are done.Nimbus.downloadBlobChunk(String session) Nimbus.downloadChunk(String id) Nimbus.filterAuthorized(String operation, Collection<String> topoIds) voidNimbus.finishBlobUpload(String session) voidNimbus.finishFileUpload(String location) Nimbus.getBlobMeta(String key) intNimbus.getBlobReplication(String key) Nimbus.getClusterInfo()Nimbus.getComponentPageInfo(String topoId, String componentId, String window, boolean includeSys) Nimbus.getLeader()Nimbus.getNimbusConf()Nimbus.getOwnerResourceSummaries(String owner) Nimbus.getSupervisorAssignments(String nodeId) Nimbus.getSupervisorPageInfo(String superId, String host, boolean includeSys) Nimbus.getTopology(String id) Nimbus.getTopologyConf(String id) Nimbus.getTopologyHistory(String user) Nimbus.getTopologyInfo(String id) Nimbus.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) Nimbus.getTopologyInfoWithOpts(String topoId, GetInfoOptions options) Nimbus.getTopologyPageInfo(String topoId, String window, boolean includeSys) Nimbus.getTopologySummaries()Nimbus.getTopologySummary(String id) Nimbus.getTopologySummaryByName(String name) Nimbus.getUserTopology(String id) booleanNimbus.isRemoteBlobExists(String blobKey) booleanNimbus.isTopologyNameAllowed(String name) voidNimbus.killTopology(String name) voidNimbus.killTopologyWithOpts(String topoName, KillOptions options) TopoCache.readTopoConf(String topoId, Subject who) Read a topology conf.TopoCache.readTopology(String topoId, Subject who) Read a topology.voidNimbus.rebalance(String topoName, RebalanceOptions options) voidvoidNimbus.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) voidNimbus.setBlobMeta(String key, SettableBlobMeta meta) voidNimbus.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) voidNimbus.submitTopologyWithOpts(String topoName, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) intNimbus.updateBlobReplication(String key, int replication) voidUpdate an existing topology conf.voidTopoCache.updateTopology(String topoId, Subject who, StormTopology topo) Update an existing topology .voidNimbus.uploadBlobChunk(String session, ByteBuffer chunk) voidNimbus.uploadChunk(String location, ByteBuffer chunk) voidNimbus.uploadNewCredentials(String topoName, Credentials credentials) -
Uses of AuthorizationException in org.apache.storm.daemon.supervisor
Methods in org.apache.storm.daemon.supervisor that throw AuthorizationExceptionModifier and TypeMethodDescriptionvoidSupervisor.checkAuthorization(String operation) voidvoidSupervisor.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 AuthorizationExceptionModifier and TypeMethodDescriptionstatic jakarta.ws.rs.core.ResponseExceptionMapperUtils.getResponse(AuthorizationException ex, jakarta.inject.Provider<jakarta.servlet.http.HttpServletRequest> request) getResponse.jakarta.ws.rs.core.ResponseAuthorizationExceptionMapper.toResponse(AuthorizationException e) -
Uses of AuthorizationException in org.apache.storm.dependency
Methods in org.apache.storm.dependency that throw AuthorizationExceptionModifier and TypeMethodDescriptionDependencyUploader.uploadFiles(List<File> dependencies, boolean cleanupIfFails) -
Uses of AuthorizationException in org.apache.storm.drpc
Methods in org.apache.storm.drpc that throw AuthorizationExceptionModifier and TypeMethodDescriptionvoidDRPCInvocationsClient.failRequest(String id) voidDRPCInvocationsClient.failRequestV2(String id, DRPCExecutionException ex) DRPCInvocationsClient.fetchRequest(String func) void -
Uses of AuthorizationException in org.apache.storm.generated
Methods in org.apache.storm.generated that return AuthorizationExceptionModifier and TypeMethodDescriptionAuthorizationException.deepCopy()DistributedRPC.execute_result.get_aze()DistributedRPCInvocations.failRequest_result.get_aze()DistributedRPCInvocations.failRequestV2_result.get_aze()DistributedRPCInvocations.fetchRequest_result.get_aze()DistributedRPCInvocations.result_result.get_aze()Nimbus.activate_result.get_aze()Nimbus.beginBlobDownload_result.get_aze()Nimbus.beginCreateBlob_result.get_aze()Nimbus.beginFileUpload_result.get_aze()Nimbus.beginUpdateBlob_result.get_aze()Nimbus.cancelBlobUpload_result.get_aze()Nimbus.deactivate_result.get_aze()Nimbus.debug_result.get_aze()Nimbus.deleteBlob_result.get_aze()Nimbus.downloadBlobChunk_result.get_aze()Nimbus.downloadChunk_result.get_aze()Nimbus.finishBlobUpload_result.get_aze()Nimbus.finishFileUpload_result.get_aze()Nimbus.getBlobMeta_result.get_aze()Nimbus.getBlobReplication_result.get_aze()Nimbus.getClusterInfo_result.get_aze()Nimbus.getComponentPageInfo_result.get_aze()Nimbus.getLeader_result.get_aze()Nimbus.getNimbusConf_result.get_aze()Nimbus.getOwnerResourceSummaries_result.get_aze()Nimbus.getSupervisorAssignments_result.get_aze()Nimbus.getSupervisorPageInfo_result.get_aze()Nimbus.getTopology_result.get_aze()Nimbus.getTopologyConf_result.get_aze()Nimbus.getTopologyHistory_result.get_aze()Nimbus.getTopologyInfo_result.get_aze()Nimbus.getTopologyInfoByName_result.get_aze()Nimbus.getTopologyInfoByNameWithOpts_result.get_aze()Nimbus.getTopologyInfoWithOpts_result.get_aze()Nimbus.getTopologyPageInfo_result.get_aze()Nimbus.getTopologySummaries_result.get_aze()Nimbus.getTopologySummary_result.get_aze()Nimbus.getTopologySummaryByName_result.get_aze()Nimbus.getUserTopology_result.get_aze()Nimbus.isRemoteBlobExists_result.get_aze()Nimbus.isTopologyNameAllowed_result.get_aze()Nimbus.killTopology_result.get_aze()Nimbus.killTopologyWithOpts_result.get_aze()Nimbus.rebalance_result.get_aze()Nimbus.sendSupervisorWorkerHeartbeat_result.get_aze()Nimbus.sendSupervisorWorkerHeartbeats_result.get_aze()Nimbus.setBlobMeta_result.get_aze()Nimbus.submitTopology_result.get_aze()Nimbus.submitTopologyWithOpts_result.get_aze()Nimbus.updateBlobReplication_result.get_aze()Nimbus.uploadBlobChunk_result.get_aze()Nimbus.uploadChunk_result.get_aze()Nimbus.uploadNewCredentials_result.get_aze()Supervisor.getLocalAssignmentForStorm_result.get_aze()Supervisor.sendSupervisorAssignments_result.get_aze()Supervisor.sendSupervisorWorkerHeartbeat_result.get_aze()Methods in org.apache.storm.generated with parameters of type AuthorizationExceptionModifier and TypeMethodDescriptionintAuthorizationException.compareTo(AuthorizationException other) booleanAuthorizationException.equals(AuthorizationException that) voidDistributedRPC.execute_result.set_aze(AuthorizationException aze) voidDistributedRPCInvocations.failRequest_result.set_aze(AuthorizationException aze) voidDistributedRPCInvocations.failRequestV2_result.set_aze(AuthorizationException aze) voidDistributedRPCInvocations.fetchRequest_result.set_aze(AuthorizationException aze) voidDistributedRPCInvocations.result_result.set_aze(AuthorizationException aze) voidNimbus.activate_result.set_aze(AuthorizationException aze) voidNimbus.beginBlobDownload_result.set_aze(AuthorizationException aze) voidNimbus.beginCreateBlob_result.set_aze(AuthorizationException aze) voidNimbus.beginFileUpload_result.set_aze(AuthorizationException aze) voidNimbus.beginUpdateBlob_result.set_aze(AuthorizationException aze) voidNimbus.cancelBlobUpload_result.set_aze(AuthorizationException aze) voidNimbus.deactivate_result.set_aze(AuthorizationException aze) voidNimbus.debug_result.set_aze(AuthorizationException aze) voidNimbus.deleteBlob_result.set_aze(AuthorizationException aze) voidNimbus.downloadBlobChunk_result.set_aze(AuthorizationException aze) voidNimbus.downloadChunk_result.set_aze(AuthorizationException aze) voidNimbus.finishBlobUpload_result.set_aze(AuthorizationException aze) voidNimbus.finishFileUpload_result.set_aze(AuthorizationException aze) voidNimbus.getBlobMeta_result.set_aze(AuthorizationException aze) voidNimbus.getBlobReplication_result.set_aze(AuthorizationException aze) voidNimbus.getClusterInfo_result.set_aze(AuthorizationException aze) voidNimbus.getComponentPageInfo_result.set_aze(AuthorizationException aze) voidNimbus.getLeader_result.set_aze(AuthorizationException aze) voidNimbus.getNimbusConf_result.set_aze(AuthorizationException aze) voidNimbus.getOwnerResourceSummaries_result.set_aze(AuthorizationException aze) voidNimbus.getSupervisorAssignments_result.set_aze(AuthorizationException aze) voidNimbus.getSupervisorPageInfo_result.set_aze(AuthorizationException aze) voidNimbus.getTopology_result.set_aze(AuthorizationException aze) voidNimbus.getTopologyConf_result.set_aze(AuthorizationException aze) voidNimbus.getTopologyHistory_result.set_aze(AuthorizationException aze) voidNimbus.getTopologyInfo_result.set_aze(AuthorizationException aze) voidNimbus.getTopologyInfoByName_result.set_aze(AuthorizationException aze) voidNimbus.getTopologyInfoByNameWithOpts_result.set_aze(AuthorizationException aze) voidNimbus.getTopologyInfoWithOpts_result.set_aze(AuthorizationException aze) voidNimbus.getTopologyPageInfo_result.set_aze(AuthorizationException aze) voidNimbus.getTopologySummaries_result.set_aze(AuthorizationException aze) voidNimbus.getTopologySummary_result.set_aze(AuthorizationException aze) voidNimbus.getTopologySummaryByName_result.set_aze(AuthorizationException aze) voidNimbus.getUserTopology_result.set_aze(AuthorizationException aze) voidNimbus.isRemoteBlobExists_result.set_aze(AuthorizationException aze) voidNimbus.isTopologyNameAllowed_result.set_aze(AuthorizationException aze) voidNimbus.killTopology_result.set_aze(AuthorizationException aze) voidNimbus.killTopologyWithOpts_result.set_aze(AuthorizationException aze) voidNimbus.rebalance_result.set_aze(AuthorizationException aze) voidNimbus.sendSupervisorWorkerHeartbeat_result.set_aze(AuthorizationException aze) voidNimbus.sendSupervisorWorkerHeartbeats_result.set_aze(AuthorizationException aze) voidNimbus.setBlobMeta_result.set_aze(AuthorizationException aze) voidNimbus.submitTopology_result.set_aze(AuthorizationException aze) voidNimbus.submitTopologyWithOpts_result.set_aze(AuthorizationException aze) voidNimbus.updateBlobReplication_result.set_aze(AuthorizationException aze) voidNimbus.uploadBlobChunk_result.set_aze(AuthorizationException aze) voidNimbus.uploadChunk_result.set_aze(AuthorizationException aze) voidNimbus.uploadNewCredentials_result.set_aze(AuthorizationException aze) voidSupervisor.getLocalAssignmentForStorm_result.set_aze(AuthorizationException aze) voidSupervisor.sendSupervisorAssignments_result.set_aze(AuthorizationException aze) voidSupervisor.sendSupervisorWorkerHeartbeat_result.set_aze(AuthorizationException aze) Methods in org.apache.storm.generated that throw AuthorizationExceptionModifier and TypeMethodDescriptionvoidvoidNimbus.Client.beginBlobDownload(String key) Nimbus.Iface.beginBlobDownload(String key) Nimbus.Client.beginCreateBlob(String key, SettableBlobMeta meta) Nimbus.Iface.beginCreateBlob(String key, SettableBlobMeta meta) Nimbus.Client.beginFileUpload()Nimbus.Iface.beginFileUpload()Nimbus.Client.beginUpdateBlob(String key) Nimbus.Iface.beginUpdateBlob(String key) voidNimbus.Client.cancelBlobUpload(String session) voidNimbus.Iface.cancelBlobUpload(String session) voidNimbus.Client.deactivate(String name) voidNimbus.Iface.deactivate(String name) voidvoidEnable/disable logging the tuples generated in topology via an internal EventLogger bolt.voidNimbus.Client.deleteBlob(String key) voidNimbus.Iface.deleteBlob(String key) Nimbus.Client.downloadBlobChunk(String session) Nimbus.Iface.downloadBlobChunk(String session) Nimbus.Client.downloadChunk(String id) Nimbus.Iface.downloadChunk(String id) voidDistributedRPCInvocations.Client.failRequest(String id) voidDistributedRPCInvocations.Iface.failRequest(String id) voidDistributedRPCInvocations.Client.failRequestV2(String id, DRPCExecutionException e) voidDistributedRPCInvocations.Iface.failRequestV2(String id, DRPCExecutionException e) DistributedRPCInvocations.Client.fetchRequest(String functionName) DistributedRPCInvocations.Iface.fetchRequest(String functionName) voidNimbus.Client.finishBlobUpload(String session) voidNimbus.Iface.finishBlobUpload(String session) voidNimbus.Client.finishFileUpload(String location) voidNimbus.Iface.finishFileUpload(String location) Nimbus.Client.getBlobMeta(String key) Nimbus.Iface.getBlobMeta(String key) intNimbus.Client.getBlobReplication(String key) intNimbus.Iface.getBlobReplication(String key) Nimbus.Client.getClusterInfo()Nimbus.Iface.getClusterInfo()Nimbus.Client.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) Nimbus.Iface.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) Nimbus.Client.getLeader()Nimbus.Iface.getLeader()Supervisor.Client.getLocalAssignmentForStorm(String id) Supervisor.Iface.getLocalAssignmentForStorm(String id) Get local assignment for a stormNimbus.Client.getNimbusConf()Nimbus.Iface.getNimbusConf()Nimbus.Client.getOwnerResourceSummaries(String owner) Nimbus.Iface.getOwnerResourceSummaries(String owner) DistributedRPC.AsyncClient.execute_call.getResult()DistributedRPCInvocations.AsyncClient.failRequest_call.getResult()DistributedRPCInvocations.AsyncClient.failRequestV2_call.getResult()DistributedRPCInvocations.AsyncClient.fetchRequest_call.getResult()DistributedRPCInvocations.AsyncClient.result_call.getResult()Nimbus.AsyncClient.activate_call.getResult()Nimbus.AsyncClient.beginBlobDownload_call.getResult()Nimbus.AsyncClient.beginCreateBlob_call.getResult()Nimbus.AsyncClient.beginFileUpload_call.getResult()Nimbus.AsyncClient.beginUpdateBlob_call.getResult()Nimbus.AsyncClient.cancelBlobUpload_call.getResult()Nimbus.AsyncClient.deactivate_call.getResult()Nimbus.AsyncClient.debug_call.getResult()Nimbus.AsyncClient.deleteBlob_call.getResult()Nimbus.AsyncClient.downloadBlobChunk_call.getResult()Nimbus.AsyncClient.downloadChunk_call.getResult()Nimbus.AsyncClient.finishBlobUpload_call.getResult()Nimbus.AsyncClient.finishFileUpload_call.getResult()Nimbus.AsyncClient.getBlobMeta_call.getResult()Nimbus.AsyncClient.getBlobReplication_call.getResult()Nimbus.AsyncClient.getClusterInfo_call.getResult()Nimbus.AsyncClient.getComponentPageInfo_call.getResult()Nimbus.AsyncClient.getLeader_call.getResult()Nimbus.AsyncClient.getNimbusConf_call.getResult()Nimbus.AsyncClient.getOwnerResourceSummaries_call.getResult()Nimbus.AsyncClient.getSupervisorAssignments_call.getResult()Nimbus.AsyncClient.getSupervisorPageInfo_call.getResult()Nimbus.AsyncClient.getTopology_call.getResult()Nimbus.AsyncClient.getTopologyConf_call.getResult()Nimbus.AsyncClient.getTopologyHistory_call.getResult()Nimbus.AsyncClient.getTopologyInfo_call.getResult()Nimbus.AsyncClient.getTopologyInfoByName_call.getResult()Nimbus.AsyncClient.getTopologyInfoByNameWithOpts_call.getResult()Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult()Nimbus.AsyncClient.getTopologyPageInfo_call.getResult()Nimbus.AsyncClient.getTopologySummaries_call.getResult()Nimbus.AsyncClient.getTopologySummary_call.getResult()Nimbus.AsyncClient.getTopologySummaryByName_call.getResult()Nimbus.AsyncClient.getUserTopology_call.getResult()Nimbus.AsyncClient.isRemoteBlobExists_call.getResult()Nimbus.AsyncClient.isTopologyNameAllowed_call.getResult()Nimbus.AsyncClient.killTopology_call.getResult()Nimbus.AsyncClient.killTopologyWithOpts_call.getResult()Nimbus.AsyncClient.rebalance_call.getResult()Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat_call.getResult()Nimbus.AsyncClient.sendSupervisorWorkerHeartbeats_call.getResult()Nimbus.AsyncClient.setBlobMeta_call.getResult()Nimbus.AsyncClient.submitTopology_call.getResult()Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult()Nimbus.AsyncClient.updateBlobReplication_call.getResult()Nimbus.AsyncClient.uploadBlobChunk_call.getResult()Nimbus.AsyncClient.uploadChunk_call.getResult()Nimbus.AsyncClient.uploadNewCredentials_call.getResult()Supervisor.AsyncClient.getLocalAssignmentForStorm_call.getResult()Supervisor.AsyncClient.sendSupervisorAssignments_call.getResult()Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat_call.getResult()Nimbus.Client.getSupervisorAssignments(String node) Nimbus.Iface.getSupervisorAssignments(String node) Get assigned assignments for a specific supervisorNimbus.Client.getSupervisorPageInfo(String id, String host, boolean is_include_sys) Nimbus.Iface.getSupervisorPageInfo(String id, String host, boolean is_include_sys) Nimbus.Client.getTopology(String id) Nimbus.Iface.getTopology(String id) Returns the compiled topology that contains ackers and metrics consumsers.Nimbus.Client.getTopologyConf(String id) Nimbus.Iface.getTopologyConf(String id) Nimbus.Client.getTopologyHistory(String user) Nimbus.Iface.getTopologyHistory(String user) Nimbus.Client.getTopologyInfo(String id) Nimbus.Iface.getTopologyInfo(String id) Nimbus.Client.getTopologyInfoByName(String name) Nimbus.Iface.getTopologyInfoByName(String name) Nimbus.Client.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) Nimbus.Iface.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) Nimbus.Client.getTopologyInfoWithOpts(String id, GetInfoOptions options) Nimbus.Iface.getTopologyInfoWithOpts(String id, GetInfoOptions options) Nimbus.Client.getTopologyPageInfo(String id, String window, boolean is_include_sys) Nimbus.Iface.getTopologyPageInfo(String id, String window, boolean is_include_sys) Nimbus.Client.getTopologySummaries()Nimbus.Iface.getTopologySummaries()Nimbus.Client.getTopologySummary(String id) Nimbus.Iface.getTopologySummary(String id) Nimbus.Client.getTopologySummaryByName(String name) Nimbus.Iface.getTopologySummaryByName(String name) Nimbus.Client.getUserTopology(String id) Nimbus.Iface.getUserTopology(String id) Returns the user specified topology as submitted originally.booleanNimbus.Client.isRemoteBlobExists(String blobKey) booleanNimbus.Iface.isRemoteBlobExists(String blobKey) Decide if the blob is removed from cluster.booleanNimbus.Client.isTopologyNameAllowed(String name) booleanNimbus.Iface.isTopologyNameAllowed(String name) voidNimbus.Client.killTopology(String name) voidNimbus.Iface.killTopology(String name) voidNimbus.Client.killTopologyWithOpts(String name, KillOptions options) voidNimbus.Iface.killTopologyWithOpts(String name, KillOptions options) voidNimbus.Client.rebalance(String name, RebalanceOptions options) voidNimbus.Iface.rebalance(String name, RebalanceOptions options) voidNimbus.Client.recv_activate()Nimbus.Client.recv_beginBlobDownload()Nimbus.Client.recv_beginCreateBlob()Nimbus.Client.recv_beginFileUpload()Nimbus.Client.recv_beginUpdateBlob()voidNimbus.Client.recv_cancelBlobUpload()voidNimbus.Client.recv_deactivate()voidNimbus.Client.recv_debug()voidNimbus.Client.recv_deleteBlob()Nimbus.Client.recv_downloadBlobChunk()Nimbus.Client.recv_downloadChunk()DistributedRPC.Client.recv_execute()voidDistributedRPCInvocations.Client.recv_failRequest()voidDistributedRPCInvocations.Client.recv_failRequestV2()DistributedRPCInvocations.Client.recv_fetchRequest()voidNimbus.Client.recv_finishBlobUpload()voidNimbus.Client.recv_finishFileUpload()Nimbus.Client.recv_getBlobMeta()intNimbus.Client.recv_getBlobReplication()Nimbus.Client.recv_getClusterInfo()Nimbus.Client.recv_getComponentPageInfo()Nimbus.Client.recv_getLeader()Supervisor.Client.recv_getLocalAssignmentForStorm()Nimbus.Client.recv_getNimbusConf()Nimbus.Client.recv_getOwnerResourceSummaries()Nimbus.Client.recv_getSupervisorAssignments()Nimbus.Client.recv_getSupervisorPageInfo()Nimbus.Client.recv_getTopology()Nimbus.Client.recv_getTopologyConf()Nimbus.Client.recv_getTopologyHistory()Nimbus.Client.recv_getTopologyInfo()Nimbus.Client.recv_getTopologyInfoByName()Nimbus.Client.recv_getTopologyInfoByNameWithOpts()Nimbus.Client.recv_getTopologyInfoWithOpts()Nimbus.Client.recv_getTopologyPageInfo()Nimbus.Client.recv_getTopologySummaries()Nimbus.Client.recv_getTopologySummary()Nimbus.Client.recv_getTopologySummaryByName()Nimbus.Client.recv_getUserTopology()booleanNimbus.Client.recv_isRemoteBlobExists()booleanNimbus.Client.recv_isTopologyNameAllowed()voidNimbus.Client.recv_killTopology()voidNimbus.Client.recv_killTopologyWithOpts()voidNimbus.Client.recv_rebalance()voidDistributedRPCInvocations.Client.recv_result()voidSupervisor.Client.recv_sendSupervisorAssignments()voidNimbus.Client.recv_sendSupervisorWorkerHeartbeat()voidSupervisor.Client.recv_sendSupervisorWorkerHeartbeat()voidNimbus.Client.recv_sendSupervisorWorkerHeartbeats()voidNimbus.Client.recv_setBlobMeta()voidNimbus.Client.recv_submitTopology()voidNimbus.Client.recv_submitTopologyWithOpts()intNimbus.Client.recv_updateBlobReplication()voidNimbus.Client.recv_uploadBlobChunk()voidNimbus.Client.recv_uploadChunk()voidNimbus.Client.recv_uploadNewCredentials()voidvoidvoidSupervisor.Client.sendSupervisorAssignments(SupervisorAssignments assignments) voidSupervisor.Iface.sendSupervisorAssignments(SupervisorAssignments assignments) Send node specific assignments to supervisorvoidNimbus.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) voidNimbus.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) Send supervisor local worker heartbeat when a supervisor is unreachablevoidSupervisor.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) voidSupervisor.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) Send worker heartbeat to local supervisorvoidNimbus.Client.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) voidNimbus.Iface.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) Send supervisor worker heartbeats for a specific supervisorvoidNimbus.Client.setBlobMeta(String key, SettableBlobMeta meta) voidNimbus.Iface.setBlobMeta(String key, SettableBlobMeta meta) voidNimbus.Client.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) voidNimbus.Iface.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) voidNimbus.Client.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) voidNimbus.Iface.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) intNimbus.Client.updateBlobReplication(String key, int replication) intNimbus.Iface.updateBlobReplication(String key, int replication) voidNimbus.Client.uploadBlobChunk(String session, ByteBuffer chunk) voidNimbus.Iface.uploadBlobChunk(String session, ByteBuffer chunk) voidNimbus.Client.uploadChunk(String location, ByteBuffer chunk) voidNimbus.Iface.uploadChunk(String location, ByteBuffer chunk) voidNimbus.Client.uploadNewCredentials(String name, Credentials creds) voidNimbus.Iface.uploadNewCredentials(String name, Credentials creds) Constructors in org.apache.storm.generated with parameters of type AuthorizationExceptionModifierConstructorDescriptionPerforms 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) downloadBlobChunk_result(ByteBuffer success, AuthorizationException aze) downloadChunk_result(ByteBuffer success, AuthorizationException aze) execute_result(String success, DRPCExecutionException e, AuthorizationException aze) fetchRequest_result(DRPCRequest success, 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) getSupervisorPageInfo_result(SupervisorPageInfo success, NotAliveException e, AuthorizationException aze) getTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze) getTopologyConf_result(String success, NotAliveException e, 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) submitTopology_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze) submitTopologyWithOpts_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze) updateBlobReplication_result(int success, AuthorizationException aze, KeyNotFoundException knf) 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 AuthorizationExceptionModifier and TypeMethodDescriptionbooleanHdfsBlobStore.blobExists(String key, Subject who) Checks if a blob exists.HdfsBlobStore.createBlob(String key, SettableBlobMeta meta, Subject who) HdfsClientBlobStore.createBlobToExtend(String key, SettableBlobMeta meta) voidHdfsBlobStore.deleteBlob(String key, Subject who) voidHdfsClientBlobStore.deleteBlob(String key) HdfsBlobStore.getBlobMeta(String key, Subject who) HdfsClientBlobStore.getBlobMeta(String key) intHdfsBlobStore.getBlobReplication(String key, Subject who) intHdfsClientBlobStore.getBlobReplication(String key) booleanHdfsClientBlobStore.isRemoteBlobExists(String blobKey) voidHdfsBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who) voidHdfsClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) HdfsBlobStore.updateBlob(String key, Subject who) HdfsClientBlobStore.updateBlob(String key) intHdfsBlobStore.updateBlobReplication(String key, int replication, Subject who) intHdfsClientBlobStore.updateBlobReplication(String key, int replication) voidHdfsBlobStore.writeMetadata(String key, SettableBlobMeta meta) -
Uses of AuthorizationException in org.apache.storm.kafka.trident
Methods in org.apache.storm.kafka.trident that throw AuthorizationException -
Uses of AuthorizationException in org.apache.storm.localizer
Methods in org.apache.storm.localizer that throw AuthorizationExceptionModifier and TypeMethodDescriptionprotected org.apache.storm.localizer.LocallyCachedBlob.DownloadMetaLocallyCachedBlob.fetch(ClientBlobStore store, String key, IOFunction<Long, Path> pathSupplier, IOFunction<File, OutputStream> outStreamSupplier) Helper function to download blob from blob store.longLocalizedResource.fetchUnzipToTemp(ClientBlobStore store) abstract longLocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store) Download the latest version to a temp location.longLocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store) longLocalizedResource.getRemoteVersion(ClientBlobStore store) abstract longLocallyCachedBlob.getRemoteVersion(ClientBlobStore store) Get the version of the blob in the blob store.longLocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store) voidLocallyCachedBlob.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.utilsModifier and TypeClassDescriptionclassWraps the generated TException to allow getMessage() to return a valid string.Methods in org.apache.storm.utils that throw AuthorizationExceptionModifier and TypeMethodDescriptionstatic longServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb) static voidUtils.validateTopologyBlobStoreMap(Map<String, Object> topoConf) Validate topology blobstore map.static voidUtils.validateTopologyBlobStoreMap(Map<String, Object> topoConf, BlobStore blobStore) Validate topology blobstore map.static voidUtils.validateTopologyBlobStoreMap(Map<String, Object> topoConf, NimbusBlobStore client) Validate topology blobstore map.