Uses of Class
org.apache.storm.generated.AuthorizationException
-
-
Uses of AuthorizationException in org.apache.storm
Methods in org.apache.storm that throw AuthorizationException Modifier and Type Method Description BeginDownloadResultLocalCluster. beginBlobDownload(String key)StringLocalCluster. beginCreateBlob(String key, SettableBlobMeta meta)StringLocalCluster. beginFileUpload()StringLocalCluster. beginUpdateBlob(String key)voidLocalCluster. cancelBlobUpload(String session)voidLocalCluster. debug(String name, String component, boolean enable, double samplingPercentage)voidLocalCluster. deleteBlob(String key)ByteBufferLocalCluster. downloadBlobChunk(String session)ByteBufferLocalCluster. downloadChunk(String id)StringLocalDRPC. execute(String functionName, String funcArgs)voidLocalDRPC. failRequest(String id)voidLocalDRPC. failRequestV2(String id, DRPCExecutionException e)DRPCRequestLocalDRPC. fetchRequest(String functionName)voidLocalCluster. finishBlobUpload(String session)voidLocalCluster. finishFileUpload(String location)ReadableBlobMetaLocalCluster. getBlobMeta(String key)intLocalCluster. getBlobReplication(String key)ComponentPageInfoLocalCluster. getComponentPageInfo(String topologyId, String componentId, String window, boolean isIncludeSys)NimbusSummaryLocalCluster. getLeader()StringLocalCluster. getNimbusConf()List<OwnerResourceSummary>LocalCluster. getOwnerResourceSummaries(String owner)SupervisorAssignmentsLocalCluster. getSupervisorAssignments(String node)SupervisorPageInfoLocalCluster. getSupervisorPageInfo(String id, String host, boolean isIncludeSys)TopologyHistoryInfoLocalCluster. getTopologyHistory(String user)TopologyPageInfoLocalCluster. getTopologyPageInfo(String id, String window, boolean isIncludeSys)StormTopologyLocalCluster. 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.voidLocalDRPC. result(String id, String result)voidLocalCluster. 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 AuthorizationException Modifier and Type Method Description protected 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.AtomicOutputStreamClientBlobStore. createBlob(String key, SettableBlobMeta meta)Client facing API to create a blob.AtomicOutputStreamLocalFsBlobStore. 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 InputStreamWithMetaBlobStore. getBlob(String key, Subject who)Gets the InputStream to read the blob details.abstract InputStreamWithMetaClientBlobStore. getBlob(String key)Client facing API to read a blob.InputStreamWithMetaLocalFsBlobStore. getBlob(String key, Subject who)InputStreamWithMetaLocalModeClientBlobStore. getBlob(String key)InputStreamWithMetaNimbusBlobStore. getBlob(String key)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.ReadableBlobMetaLocalFsBlobStore. getBlobMeta(String key, Subject who)ReadableBlobMetaLocalModeClientBlobStore. getBlobMeta(String key)ReadableBlobMetaNimbusBlobStore. 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[]BlobStore. readBlob(String key, Subject who)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.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.AtomicOutputStreamLocalFsBlobStore. updateBlob(String key, Subject who)AtomicOutputStreamLocalModeClientBlobStore. updateBlob(String key)AtomicOutputStreamNimbusBlobStore. 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 AuthorizationException Modifier and Type Method Description jakarta.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 AuthorizationException Modifier and Type Method Description <T extends OutstandingRequest>
TDRPC. execute(String functionName, String funcArgs, RequestFactory<T> factory)StringDRPCThrift. execute(String functionName, String funcArgs)StringDRPC. executeBlocking(String functionName, String funcArgs)voidDRPC. failRequest(String id, DRPCExecutionException e)voidDRPCThrift. failRequest(String id)voidDRPCThrift. failRequestV2(String id, DRPCExecutionException e)DRPCRequestDRPC. fetchRequest(String functionName)DRPCRequestDRPCThrift. fetchRequest(String functionName)voidDRPCThrift. result(String id, String result)voidDRPC. returnResult(String id, String result) -
Uses of AuthorizationException in org.apache.storm.daemon.nimbus
-
Uses of AuthorizationException in org.apache.storm.daemon.supervisor
Methods in org.apache.storm.daemon.supervisor that throw AuthorizationException Modifier and Type Method Description voidSupervisor. checkAuthorization(String operation)voidSupervisor. checkAuthorization(String topoName, Map<String,Object> topoConf, String operation)voidSupervisor. checkAuthorization(String topoName, Map<String,Object> topoConf, String operation, ReqContext context) -
Uses of AuthorizationException in org.apache.storm.daemon.ui.exceptionmappers
Methods in org.apache.storm.daemon.ui.exceptionmappers with parameters of type AuthorizationException Modifier and Type Method Description static jakarta.ws.rs.core.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 AuthorizationException Modifier and Type Method Description List<String>DependencyUploader. uploadFiles(List<File> dependencies, boolean cleanupIfFails) -
Uses of AuthorizationException in org.apache.storm.drpc
Methods in org.apache.storm.drpc that throw AuthorizationException Modifier and Type Method Description voidDRPCInvocationsClient. failRequest(String id)voidDRPCInvocationsClient. failRequestV2(String id, DRPCExecutionException ex)DRPCRequestDRPCInvocationsClient. fetchRequest(String func)voidDRPCInvocationsClient. result(String id, String result) -
Uses of AuthorizationException in org.apache.storm.generated
Methods in org.apache.storm.generated that return AuthorizationException Modifier and Type Method Description AuthorizationExceptionAuthorizationException. deepCopy()AuthorizationExceptionDistributedRPC.execute_result. get_aze()AuthorizationExceptionDistributedRPCInvocations.failRequest_result. get_aze()AuthorizationExceptionDistributedRPCInvocations.failRequestV2_result. get_aze()AuthorizationExceptionDistributedRPCInvocations.fetchRequest_result. get_aze()AuthorizationExceptionDistributedRPCInvocations.result_result. get_aze()AuthorizationExceptionNimbus.activate_result. get_aze()AuthorizationExceptionNimbus.beginBlobDownload_result. get_aze()AuthorizationExceptionNimbus.beginCreateBlob_result. get_aze()AuthorizationExceptionNimbus.beginFileUpload_result. get_aze()AuthorizationExceptionNimbus.beginUpdateBlob_result. get_aze()AuthorizationExceptionNimbus.cancelBlobUpload_result. get_aze()AuthorizationExceptionNimbus.deactivate_result. get_aze()AuthorizationExceptionNimbus.debug_result. get_aze()AuthorizationExceptionNimbus.deleteBlob_result. get_aze()AuthorizationExceptionNimbus.downloadBlobChunk_result. get_aze()AuthorizationExceptionNimbus.downloadChunk_result. get_aze()AuthorizationExceptionNimbus.finishBlobUpload_result. get_aze()AuthorizationExceptionNimbus.finishFileUpload_result. get_aze()AuthorizationExceptionNimbus.getBlobMeta_result. get_aze()AuthorizationExceptionNimbus.getBlobReplication_result. get_aze()AuthorizationExceptionNimbus.getClusterInfo_result. get_aze()AuthorizationExceptionNimbus.getComponentPageInfo_result. get_aze()AuthorizationExceptionNimbus.getLeader_result. get_aze()AuthorizationExceptionNimbus.getNimbusConf_result. get_aze()AuthorizationExceptionNimbus.getOwnerResourceSummaries_result. get_aze()AuthorizationExceptionNimbus.getSupervisorAssignments_result. get_aze()AuthorizationExceptionNimbus.getSupervisorPageInfo_result. get_aze()AuthorizationExceptionNimbus.getTopology_result. get_aze()AuthorizationExceptionNimbus.getTopologyConf_result. get_aze()AuthorizationExceptionNimbus.getTopologyHistory_result. get_aze()AuthorizationExceptionNimbus.getTopologyInfo_result. get_aze()AuthorizationExceptionNimbus.getTopologyInfoByName_result. get_aze()AuthorizationExceptionNimbus.getTopologyInfoByNameWithOpts_result. get_aze()AuthorizationExceptionNimbus.getTopologyInfoWithOpts_result. get_aze()AuthorizationExceptionNimbus.getTopologyPageInfo_result. get_aze()AuthorizationExceptionNimbus.getTopologySummaries_result. get_aze()AuthorizationExceptionNimbus.getTopologySummary_result. get_aze()AuthorizationExceptionNimbus.getTopologySummaryByName_result. get_aze()AuthorizationExceptionNimbus.getUserTopology_result. get_aze()AuthorizationExceptionNimbus.isRemoteBlobExists_result. get_aze()AuthorizationExceptionNimbus.isTopologyNameAllowed_result. get_aze()AuthorizationExceptionNimbus.killTopology_result. get_aze()AuthorizationExceptionNimbus.killTopologyWithOpts_result. get_aze()AuthorizationExceptionNimbus.rebalance_result. get_aze()AuthorizationExceptionNimbus.sendSupervisorWorkerHeartbeat_result. get_aze()AuthorizationExceptionNimbus.sendSupervisorWorkerHeartbeats_result. get_aze()AuthorizationExceptionNimbus.setBlobMeta_result. get_aze()AuthorizationExceptionNimbus.submitTopology_result. get_aze()AuthorizationExceptionNimbus.submitTopologyWithOpts_result. get_aze()AuthorizationExceptionNimbus.updateBlobReplication_result. get_aze()AuthorizationExceptionNimbus.uploadBlobChunk_result. get_aze()AuthorizationExceptionNimbus.uploadChunk_result. get_aze()AuthorizationExceptionNimbus.uploadNewCredentials_result. get_aze()AuthorizationExceptionSupervisor.getLocalAssignmentForStorm_result. get_aze()AuthorizationExceptionSupervisor.sendSupervisorAssignments_result. get_aze()AuthorizationExceptionSupervisor.sendSupervisorWorkerHeartbeat_result. get_aze()Methods in org.apache.storm.generated with parameters of type AuthorizationException Modifier and Type Method Description intAuthorizationException. 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 AuthorizationException Modifier and Type Method Description voidNimbus.Client. activate(String name)voidNimbus.Iface. activate(String name)BeginDownloadResultNimbus.Client. beginBlobDownload(String key)BeginDownloadResultNimbus.Iface. beginBlobDownload(String key)StringNimbus.Client. beginCreateBlob(String key, SettableBlobMeta meta)StringNimbus.Iface. beginCreateBlob(String key, SettableBlobMeta meta)StringNimbus.Client. beginFileUpload()StringNimbus.Iface. beginFileUpload()StringNimbus.Client. beginUpdateBlob(String key)StringNimbus.Iface. beginUpdateBlob(String key)voidNimbus.Client. cancelBlobUpload(String session)voidNimbus.Iface. cancelBlobUpload(String session)voidNimbus.Client. deactivate(String name)voidNimbus.Iface. deactivate(String name)voidNimbus.Client. debug(String name, String component, boolean enable, double samplingPercentage)voidNimbus.Iface. debug(String name, String component, boolean enable, double samplingPercentage)Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.voidNimbus.Client. deleteBlob(String key)voidNimbus.Iface. deleteBlob(String key)ByteBufferNimbus.Client. downloadBlobChunk(String session)ByteBufferNimbus.Iface. downloadBlobChunk(String session)ByteBufferNimbus.Client. downloadChunk(String id)ByteBufferNimbus.Iface. downloadChunk(String id)StringDistributedRPC.Client. execute(String functionName, String funcArgs)StringDistributedRPC.Iface. execute(String functionName, String funcArgs)voidDistributedRPCInvocations.Client. failRequest(String id)voidDistributedRPCInvocations.Iface. failRequest(String id)voidDistributedRPCInvocations.Client. failRequestV2(String id, DRPCExecutionException e)voidDistributedRPCInvocations.Iface. failRequestV2(String id, DRPCExecutionException e)DRPCRequestDistributedRPCInvocations.Client. fetchRequest(String functionName)DRPCRequestDistributedRPCInvocations.Iface. fetchRequest(String functionName)voidNimbus.Client. finishBlobUpload(String session)voidNimbus.Iface. finishBlobUpload(String session)voidNimbus.Client. finishFileUpload(String location)voidNimbus.Iface. finishFileUpload(String location)ReadableBlobMetaNimbus.Client. getBlobMeta(String key)ReadableBlobMetaNimbus.Iface. getBlobMeta(String key)intNimbus.Client. getBlobReplication(String key)intNimbus.Iface. getBlobReplication(String key)ClusterSummaryNimbus.Client. getClusterInfo()ClusterSummaryNimbus.Iface. getClusterInfo()ComponentPageInfoNimbus.Client. getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)ComponentPageInfoNimbus.Iface. getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)NimbusSummaryNimbus.Client. getLeader()NimbusSummaryNimbus.Iface. getLeader()AssignmentSupervisor.Client. getLocalAssignmentForStorm(String id)AssignmentSupervisor.Iface. getLocalAssignmentForStorm(String id)Get local assignment for a stormStringNimbus.Client. getNimbusConf()StringNimbus.Iface. getNimbusConf()List<OwnerResourceSummary>Nimbus.Client. getOwnerResourceSummaries(String owner)List<OwnerResourceSummary>Nimbus.Iface. getOwnerResourceSummaries(String owner)StringDistributedRPC.AsyncClient.execute_call. getResult()VoidDistributedRPCInvocations.AsyncClient.failRequest_call. getResult()VoidDistributedRPCInvocations.AsyncClient.failRequestV2_call. getResult()DRPCRequestDistributedRPCInvocations.AsyncClient.fetchRequest_call. getResult()VoidDistributedRPCInvocations.AsyncClient.result_call. getResult()VoidNimbus.AsyncClient.activate_call. getResult()BeginDownloadResultNimbus.AsyncClient.beginBlobDownload_call. getResult()StringNimbus.AsyncClient.beginCreateBlob_call. getResult()StringNimbus.AsyncClient.beginFileUpload_call. getResult()StringNimbus.AsyncClient.beginUpdateBlob_call. getResult()VoidNimbus.AsyncClient.cancelBlobUpload_call. getResult()VoidNimbus.AsyncClient.deactivate_call. getResult()VoidNimbus.AsyncClient.debug_call. getResult()VoidNimbus.AsyncClient.deleteBlob_call. getResult()ByteBufferNimbus.AsyncClient.downloadBlobChunk_call. getResult()ByteBufferNimbus.AsyncClient.downloadChunk_call. getResult()VoidNimbus.AsyncClient.finishBlobUpload_call. getResult()VoidNimbus.AsyncClient.finishFileUpload_call. getResult()ReadableBlobMetaNimbus.AsyncClient.getBlobMeta_call. getResult()IntegerNimbus.AsyncClient.getBlobReplication_call. getResult()ClusterSummaryNimbus.AsyncClient.getClusterInfo_call. getResult()ComponentPageInfoNimbus.AsyncClient.getComponentPageInfo_call. getResult()NimbusSummaryNimbus.AsyncClient.getLeader_call. getResult()StringNimbus.AsyncClient.getNimbusConf_call. getResult()List<OwnerResourceSummary>Nimbus.AsyncClient.getOwnerResourceSummaries_call. getResult()SupervisorAssignmentsNimbus.AsyncClient.getSupervisorAssignments_call. getResult()SupervisorPageInfoNimbus.AsyncClient.getSupervisorPageInfo_call. getResult()StormTopologyNimbus.AsyncClient.getTopology_call. getResult()StringNimbus.AsyncClient.getTopologyConf_call. getResult()TopologyHistoryInfoNimbus.AsyncClient.getTopologyHistory_call. getResult()TopologyInfoNimbus.AsyncClient.getTopologyInfo_call. getResult()TopologyInfoNimbus.AsyncClient.getTopologyInfoByName_call. getResult()TopologyInfoNimbus.AsyncClient.getTopologyInfoByNameWithOpts_call. getResult()TopologyInfoNimbus.AsyncClient.getTopologyInfoWithOpts_call. getResult()TopologyPageInfoNimbus.AsyncClient.getTopologyPageInfo_call. getResult()List<TopologySummary>Nimbus.AsyncClient.getTopologySummaries_call. getResult()TopologySummaryNimbus.AsyncClient.getTopologySummary_call. getResult()TopologySummaryNimbus.AsyncClient.getTopologySummaryByName_call. getResult()StormTopologyNimbus.AsyncClient.getUserTopology_call. getResult()BooleanNimbus.AsyncClient.isRemoteBlobExists_call. getResult()BooleanNimbus.AsyncClient.isTopologyNameAllowed_call. getResult()VoidNimbus.AsyncClient.killTopology_call. getResult()VoidNimbus.AsyncClient.killTopologyWithOpts_call. getResult()VoidNimbus.AsyncClient.rebalance_call. getResult()VoidNimbus.AsyncClient.sendSupervisorWorkerHeartbeat_call. getResult()VoidNimbus.AsyncClient.sendSupervisorWorkerHeartbeats_call. getResult()VoidNimbus.AsyncClient.setBlobMeta_call. getResult()VoidNimbus.AsyncClient.submitTopology_call. getResult()VoidNimbus.AsyncClient.submitTopologyWithOpts_call. getResult()IntegerNimbus.AsyncClient.updateBlobReplication_call. getResult()VoidNimbus.AsyncClient.uploadBlobChunk_call. getResult()VoidNimbus.AsyncClient.uploadChunk_call. getResult()VoidNimbus.AsyncClient.uploadNewCredentials_call. getResult()AssignmentSupervisor.AsyncClient.getLocalAssignmentForStorm_call. getResult()VoidSupervisor.AsyncClient.sendSupervisorAssignments_call. getResult()VoidSupervisor.AsyncClient.sendSupervisorWorkerHeartbeat_call. getResult()SupervisorAssignmentsNimbus.Client. getSupervisorAssignments(String node)SupervisorAssignmentsNimbus.Iface. getSupervisorAssignments(String node)Get assigned assignments for a specific supervisorSupervisorPageInfoNimbus.Client. getSupervisorPageInfo(String id, String host, boolean is_include_sys)SupervisorPageInfoNimbus.Iface. getSupervisorPageInfo(String id, String host, boolean is_include_sys)StormTopologyNimbus.Client. getTopology(String id)StormTopologyNimbus.Iface. getTopology(String id)Returns the compiled topology that contains ackers and metrics consumsers.StringNimbus.Client. getTopologyConf(String id)StringNimbus.Iface. getTopologyConf(String id)TopologyHistoryInfoNimbus.Client. getTopologyHistory(String user)TopologyHistoryInfoNimbus.Iface. getTopologyHistory(String user)TopologyInfoNimbus.Client. getTopologyInfo(String id)TopologyInfoNimbus.Iface. getTopologyInfo(String id)TopologyInfoNimbus.Client. getTopologyInfoByName(String name)TopologyInfoNimbus.Iface. getTopologyInfoByName(String name)TopologyInfoNimbus.Client. getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)TopologyInfoNimbus.Iface. getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)TopologyInfoNimbus.Client. getTopologyInfoWithOpts(String id, GetInfoOptions options)TopologyInfoNimbus.Iface. getTopologyInfoWithOpts(String id, GetInfoOptions options)TopologyPageInfoNimbus.Client. getTopologyPageInfo(String id, String window, boolean is_include_sys)TopologyPageInfoNimbus.Iface. getTopologyPageInfo(String id, String window, boolean is_include_sys)List<TopologySummary>Nimbus.Client. getTopologySummaries()List<TopologySummary>Nimbus.Iface. getTopologySummaries()TopologySummaryNimbus.Client. getTopologySummary(String id)TopologySummaryNimbus.Iface. getTopologySummary(String id)TopologySummaryNimbus.Client. getTopologySummaryByName(String name)TopologySummaryNimbus.Iface. getTopologySummaryByName(String name)StormTopologyNimbus.Client. getUserTopology(String id)StormTopologyNimbus.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()BeginDownloadResultNimbus.Client. recv_beginBlobDownload()StringNimbus.Client. recv_beginCreateBlob()StringNimbus.Client. recv_beginFileUpload()StringNimbus.Client. recv_beginUpdateBlob()voidNimbus.Client. recv_cancelBlobUpload()voidNimbus.Client. recv_deactivate()voidNimbus.Client. recv_debug()voidNimbus.Client. recv_deleteBlob()ByteBufferNimbus.Client. recv_downloadBlobChunk()ByteBufferNimbus.Client. recv_downloadChunk()StringDistributedRPC.Client. recv_execute()voidDistributedRPCInvocations.Client. recv_failRequest()voidDistributedRPCInvocations.Client. recv_failRequestV2()DRPCRequestDistributedRPCInvocations.Client. recv_fetchRequest()voidNimbus.Client. recv_finishBlobUpload()voidNimbus.Client. recv_finishFileUpload()ReadableBlobMetaNimbus.Client. recv_getBlobMeta()intNimbus.Client. recv_getBlobReplication()ClusterSummaryNimbus.Client. recv_getClusterInfo()ComponentPageInfoNimbus.Client. recv_getComponentPageInfo()NimbusSummaryNimbus.Client. recv_getLeader()AssignmentSupervisor.Client. recv_getLocalAssignmentForStorm()StringNimbus.Client. recv_getNimbusConf()List<OwnerResourceSummary>Nimbus.Client. recv_getOwnerResourceSummaries()SupervisorAssignmentsNimbus.Client. recv_getSupervisorAssignments()SupervisorPageInfoNimbus.Client. recv_getSupervisorPageInfo()StormTopologyNimbus.Client. recv_getTopology()StringNimbus.Client. recv_getTopologyConf()TopologyHistoryInfoNimbus.Client. recv_getTopologyHistory()TopologyInfoNimbus.Client. recv_getTopologyInfo()TopologyInfoNimbus.Client. recv_getTopologyInfoByName()TopologyInfoNimbus.Client. recv_getTopologyInfoByNameWithOpts()TopologyInfoNimbus.Client. recv_getTopologyInfoWithOpts()TopologyPageInfoNimbus.Client. recv_getTopologyPageInfo()List<TopologySummary>Nimbus.Client. recv_getTopologySummaries()TopologySummaryNimbus.Client. recv_getTopologySummary()TopologySummaryNimbus.Client. recv_getTopologySummaryByName()StormTopologyNimbus.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()voidDistributedRPCInvocations.Client. result(String id, String result)voidDistributedRPCInvocations.Iface. result(String id, String result)voidSupervisor.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) -
Uses of AuthorizationException in org.apache.storm.hdfs.blobstore
Methods in org.apache.storm.hdfs.blobstore that throw AuthorizationException Modifier and Type Method Description booleanHdfsBlobStore. blobExists(String key, Subject who)Checks if a blob exists.AtomicOutputStreamHdfsBlobStore. createBlob(String key, SettableBlobMeta meta, Subject who)AtomicOutputStreamHdfsClientBlobStore. createBlobToExtend(String key, SettableBlobMeta meta)voidHdfsBlobStore. deleteBlob(String key, Subject who)voidHdfsClientBlobStore. deleteBlob(String key)InputStreamWithMetaHdfsBlobStore. getBlob(String key, Subject who)InputStreamWithMetaHdfsClientBlobStore. getBlob(String key)ReadableBlobMetaHdfsBlobStore. getBlobMeta(String key, Subject who)ReadableBlobMetaHdfsClientBlobStore. 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)AtomicOutputStreamHdfsBlobStore. updateBlob(String key, Subject who)AtomicOutputStreamHdfsClientBlobStore. 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 Modifier and Type Method Description protected voidTridentKafkaClientTopologyNamedTopics. run(String[] args) -
Uses of AuthorizationException in org.apache.storm.localizer
Methods in org.apache.storm.localizer that throw AuthorizationException Modifier and Type Method Description protected org.apache.storm.localizer.LocallyCachedBlob.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.utils Modifier and Type Class Description classWrappedAuthorizationExceptionWraps the generated TException to allow getMessage() to return a valid string.Methods in org.apache.storm.utils that throw AuthorizationException Modifier and Type Method Description StringDRPCClient. execute(String func, String args)static 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.
-