Uses of Class
org.apache.storm.generated.AuthorizationException
Package
Description
ElasticSearch examples classes.
ElasticSearch Trident example classes.
-
Uses of AuthorizationException in org.apache.storm
Modifier and TypeMethodDescriptionLocalCluster.beginBlobDownload
(String key) LocalCluster.beginCreateBlob
(String key, SettableBlobMeta meta) LocalCluster.beginFileUpload()
LocalCluster.beginUpdateBlob
(String key) void
LocalCluster.cancelBlobUpload
(String session) void
void
LocalCluster.deleteBlob
(String key) LocalCluster.downloadBlobChunk
(String session) LocalCluster.downloadChunk
(String id) void
LocalDRPC.failRequest
(String id) void
LocalDRPC.failRequestV2
(String id, DRPCExecutionException e) LocalDRPC.fetchRequest
(String functionName) void
LocalCluster.finishBlobUpload
(String session) void
LocalCluster.finishFileUpload
(String location) LocalCluster.getBlobMeta
(String key) int
LocalCluster.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) 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
void
LocalCluster.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat) void
LocalCluster.sendSupervisorWorkerHeartbeats
(SupervisorWorkerHeartbeats heartbeats) void
LocalCluster.setBlobMeta
(String key, SettableBlobMeta meta) void
LocalCluster.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopology
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.static void
StormSubmitter.submitTopologyAs
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submits a topology to run on the cluster as a particular user.void
LocalCluster.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) static void
StormSubmitter.submitTopologyWithProgressBar
(String name, Map<String, Object> topoConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.static void
StormSubmitter.submitTopologyWithProgressBar
(String name, Map<String, Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar.int
LocalCluster.updateBlobReplication
(String key, int replication) void
LocalCluster.uploadBlobChunk
(String session, ByteBuffer chunk) void
LocalCluster.uploadChunk
(String location, ByteBuffer chunk) -
Uses of AuthorizationException in org.apache.storm.blobstore
Modifier and TypeMethodDescriptionprotected static void
MigrateBlobs.copyBlobStoreKeys
(BlobStore bsFrom, Subject whoFrom, BlobStore bsTo, Subject whoTo) void
BlobStore.createBlob
(String key, byte[] data, SettableBlobMeta meta, Subject who) Wrapper called to create the blob which contains the byte data.void
BlobStore.createBlob
(String key, InputStream in, SettableBlobMeta meta, Subject who) Wrapper called to create the blob which contains the byte data.abstract AtomicOutputStream
BlobStore.createBlob
(String key, SettableBlobMeta meta, Subject who) Creates the blob.final AtomicOutputStream
ClientBlobStore.createBlob
(String key, SettableBlobMeta meta) Client facing API to create a blob.LocalFsBlobStore.createBlob
(String key, SettableBlobMeta meta, Subject who) protected abstract AtomicOutputStream
ClientBlobStore.createBlobToExtend
(String key, SettableBlobMeta meta) Client facing API to create a blob.protected AtomicOutputStream
LocalModeClientBlobStore.createBlobToExtend
(String key, SettableBlobMeta meta) protected AtomicOutputStream
NimbusBlobStore.createBlobToExtend
(String key, SettableBlobMeta meta) protected static void
MigrateBlobs.deleteAllBlobStoreKeys
(BlobStore bs, Subject who) abstract void
BlobStore.deleteBlob
(String key, Subject who) Deletes the blob data and metadata.abstract void
ClientBlobStore.deleteBlob
(String key) Client facing API to delete a blob.void
LocalFsBlobStore.deleteBlob
(String key, Subject who) void
LocalModeClientBlobStore.deleteBlob
(String key) void
NimbusBlobStore.deleteBlob
(String key) abstract InputStreamWithMeta
Gets the InputStream to read the blob details.abstract InputStreamWithMeta
Client facing API to read a blob.abstract ReadableBlobMeta
BlobStore.getBlobMeta
(String key, Subject who) Gets the current version of metadata for a blob to be viewed by the user or downloaded by the supervisor.abstract ReadableBlobMeta
ClientBlobStore.getBlobMeta
(String key) Client facing API to read the metadata information.LocalFsBlobStore.getBlobMeta
(String key, Subject who) LocalModeClientBlobStore.getBlobMeta
(String key) NimbusBlobStore.getBlobMeta
(String key) abstract int
ClientBlobStore.getBlobReplication
(String key) Client facing API to read the replication of a blob.int
LocalModeClientBlobStore.getBlobReplication
(String key) int
NimbusBlobStore.getBlobReplication
(String key) void
BlobStoreAclHandler.hasAnyPermissions
(List<AccessControl> acl, int mask, Subject who, String key) Validates if the user has any of the permissions mentioned in the mask.void
BlobStoreAclHandler.hasPermissions
(List<AccessControl> acl, int mask, Subject who, String key) Validates if the user has at least the set of permissions mentioned in the mask.abstract boolean
ClientBlobStore.isRemoteBlobExists
(String blobKey) Decide if the blob is deleted from cluster.boolean
LocalModeClientBlobStore.isRemoteBlobExists
(String blobKey) boolean
NimbusBlobStore.isRemoteBlobExists
(String blobKey) byte[]
Wrapper around readBlobTo which returns a ByteArray output stream.void
BlobStore.readBlobTo
(String key, OutputStream out, Subject who) Reads the blob from the blob store and writes it into the output stream.abstract void
BlobStore.setBlobMeta
(String key, SettableBlobMeta meta, Subject who) Sets the metadata with renewed acls for the blob.final void
ClientBlobStore.setBlobMeta
(String key, SettableBlobMeta meta) Client facing API to set the metadata for a blob.void
LocalFsBlobStore.setBlobMeta
(String key, SettableBlobMeta meta, Subject who) protected abstract void
ClientBlobStore.setBlobMetaToExtend
(String key, SettableBlobMeta meta) Client facing API to set the metadata for a blob.protected void
LocalModeClientBlobStore.setBlobMetaToExtend
(String key, SettableBlobMeta meta) protected void
NimbusBlobStore.setBlobMetaToExtend
(String key, SettableBlobMeta meta) void
BlobStore.startSyncBlobs()
Start the syncing blobs between the local running instance of the BlobStore and others.void
LocalFsBlobStore.startSyncBlobs()
void
BlobStore.updateBlob
(String key, byte[] data, Subject who) Wrapper called to create the blob which contains the byte data.abstract AtomicOutputStream
BlobStore.updateBlob
(String key, Subject who) Updates the blob data.abstract AtomicOutputStream
ClientBlobStore.updateBlob
(String key) Client facing API to update a blob.LocalFsBlobStore.updateBlob
(String key, Subject who) LocalModeClientBlobStore.updateBlob
(String key) NimbusBlobStore.updateBlob
(String key) abstract int
BlobStore.updateBlobReplication
(String key, int replication, Subject who) Modifies the replication factor of the blob.abstract int
ClientBlobStore.updateBlobReplication
(String key, int replication) Client facing API to update the replication of a blob.int
LocalFsBlobStore.updateBlobReplication
(String key, int replication, Subject who) int
LocalModeClientBlobStore.updateBlobReplication
(String key, int replication) int
NimbusBlobStore.updateBlobReplication
(String key, int replication) static void
BlobStoreAclHandler.validateSettableACLs
(String key, List<AccessControl> acls) void
BlobStoreAclHandler.validateUserCanReadMeta
(List<AccessControl> acl, Subject who, String key) The user should be able to see the metadata if and only if they have any of READ, WRITE, or ADMIN. -
Uses of AuthorizationException in org.apache.storm.daemon.common
Modifier and TypeMethodDescriptionjavax.ws.rs.core.Response
AuthorizationExceptionMapper.toResponse
(AuthorizationException ex) -
Uses of AuthorizationException in org.apache.storm.daemon.drpc
Modifier and TypeMethodDescription<T extends OutstandingRequest>
TDRPC.execute
(String functionName, String funcArgs, RequestFactory<T> factory) DRPC.executeBlocking
(String functionName, String funcArgs) void
DRPC.failRequest
(String id, DRPCExecutionException e) void
DRPCThrift.failRequest
(String id) void
DRPCThrift.failRequestV2
(String id, DRPCExecutionException e) DRPC.fetchRequest
(String functionName) DRPCThrift.fetchRequest
(String functionName) void
void
DRPC.returnResult
(String id, String result) -
Uses of AuthorizationException in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionvoid
void
Add a new topology config.void
TopoCache.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) void
Nimbus.cancelBlobUpload
(String session) void
void
Nimbus.checkAuthorization
(String topoName, Map<String, Object> topoConf, String operation, ReqContext context) void
Nimbus.deactivate
(String topoName) void
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.Nimbus.downloadBlobChunk
(String session) Nimbus.downloadChunk
(String id) Nimbus.filterAuthorized
(String operation, Collection<String> topoIds) void
Nimbus.finishBlobUpload
(String session) void
Nimbus.finishFileUpload
(String location) Nimbus.getBlobMeta
(String key) int
Nimbus.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) boolean
Nimbus.isRemoteBlobExists
(String blobKey) boolean
Nimbus.isTopologyNameAllowed
(String name) void
Nimbus.killTopology
(String name) void
Nimbus.killTopologyWithOpts
(String topoName, KillOptions options) TopoCache.readTopoConf
(String topoId, Subject who) Read a topology conf.TopoCache.readTopology
(String topoId, Subject who) Read a topology.void
Nimbus.rebalance
(String topoName, RebalanceOptions options) void
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
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
Modifier and TypeMethodDescriptionvoid
Supervisor.checkAuthorization
(String operation) void
void
Supervisor.checkAuthorization
(String topoName, Map<String, Object> topoConf, String operation, ReqContext context) -
Uses of AuthorizationException in org.apache.storm.daemon.ui.exceptionmappers
Modifier and TypeMethodDescriptionstatic 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
Modifier and TypeMethodDescriptionDependencyUploader.uploadFiles
(List<File> dependencies, boolean cleanupIfFails) -
Uses of AuthorizationException in org.apache.storm.drpc
Modifier and TypeMethodDescriptionvoid
DRPCInvocationsClient.failRequest
(String id) void
DRPCInvocationsClient.failRequestV2
(String id, DRPCExecutionException ex) DRPCInvocationsClient.fetchRequest
(String func) void
-
Uses of AuthorizationException in org.apache.storm.elasticsearch.bolt
-
Uses of AuthorizationException in org.apache.storm.elasticsearch.trident
-
Uses of AuthorizationException in org.apache.storm.generated
Modifier 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()
Modifier and TypeMethodDescriptionint
AuthorizationException.compareTo
(AuthorizationException other) boolean
AuthorizationException.equals
(AuthorizationException that) void
DistributedRPC.execute_result.set_aze
(AuthorizationException aze) void
DistributedRPCInvocations.failRequest_result.set_aze
(AuthorizationException aze) void
DistributedRPCInvocations.failRequestV2_result.set_aze
(AuthorizationException aze) void
DistributedRPCInvocations.fetchRequest_result.set_aze
(AuthorizationException aze) void
DistributedRPCInvocations.result_result.set_aze
(AuthorizationException aze) void
Nimbus.activate_result.set_aze
(AuthorizationException aze) void
Nimbus.beginBlobDownload_result.set_aze
(AuthorizationException aze) void
Nimbus.beginCreateBlob_result.set_aze
(AuthorizationException aze) void
Nimbus.beginFileUpload_result.set_aze
(AuthorizationException aze) void
Nimbus.beginUpdateBlob_result.set_aze
(AuthorizationException aze) void
Nimbus.cancelBlobUpload_result.set_aze
(AuthorizationException aze) void
Nimbus.deactivate_result.set_aze
(AuthorizationException aze) void
Nimbus.debug_result.set_aze
(AuthorizationException aze) void
Nimbus.deleteBlob_result.set_aze
(AuthorizationException aze) void
Nimbus.downloadBlobChunk_result.set_aze
(AuthorizationException aze) void
Nimbus.downloadChunk_result.set_aze
(AuthorizationException aze) void
Nimbus.finishBlobUpload_result.set_aze
(AuthorizationException aze) void
Nimbus.finishFileUpload_result.set_aze
(AuthorizationException aze) void
Nimbus.getBlobMeta_result.set_aze
(AuthorizationException aze) void
Nimbus.getBlobReplication_result.set_aze
(AuthorizationException aze) void
Nimbus.getClusterInfo_result.set_aze
(AuthorizationException aze) void
Nimbus.getComponentPageInfo_result.set_aze
(AuthorizationException aze) void
Nimbus.getLeader_result.set_aze
(AuthorizationException aze) void
Nimbus.getNimbusConf_result.set_aze
(AuthorizationException aze) void
Nimbus.getOwnerResourceSummaries_result.set_aze
(AuthorizationException aze) void
Nimbus.getSupervisorAssignments_result.set_aze
(AuthorizationException aze) void
Nimbus.getSupervisorPageInfo_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopology_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologyConf_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologyHistory_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologyInfo_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologyInfoByName_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologyInfoByNameWithOpts_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologyInfoWithOpts_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologyPageInfo_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologySummaries_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologySummary_result.set_aze
(AuthorizationException aze) void
Nimbus.getTopologySummaryByName_result.set_aze
(AuthorizationException aze) void
Nimbus.getUserTopology_result.set_aze
(AuthorizationException aze) void
Nimbus.isRemoteBlobExists_result.set_aze
(AuthorizationException aze) void
Nimbus.isTopologyNameAllowed_result.set_aze
(AuthorizationException aze) void
Nimbus.killTopology_result.set_aze
(AuthorizationException aze) void
Nimbus.killTopologyWithOpts_result.set_aze
(AuthorizationException aze) void
Nimbus.rebalance_result.set_aze
(AuthorizationException aze) void
Nimbus.sendSupervisorWorkerHeartbeat_result.set_aze
(AuthorizationException aze) void
Nimbus.sendSupervisorWorkerHeartbeats_result.set_aze
(AuthorizationException aze) void
Nimbus.setBlobMeta_result.set_aze
(AuthorizationException aze) void
Nimbus.submitTopology_result.set_aze
(AuthorizationException aze) void
Nimbus.submitTopologyWithOpts_result.set_aze
(AuthorizationException aze) void
Nimbus.updateBlobReplication_result.set_aze
(AuthorizationException aze) void
Nimbus.uploadBlobChunk_result.set_aze
(AuthorizationException aze) void
Nimbus.uploadChunk_result.set_aze
(AuthorizationException aze) void
Nimbus.uploadNewCredentials_result.set_aze
(AuthorizationException aze) void
Supervisor.getLocalAssignmentForStorm_result.set_aze
(AuthorizationException aze) void
Supervisor.sendSupervisorAssignments_result.set_aze
(AuthorizationException aze) void
Supervisor.sendSupervisorWorkerHeartbeat_result.set_aze
(AuthorizationException aze) Modifier and TypeMethodDescriptionvoid
void
Nimbus.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) void
Nimbus.Client.cancelBlobUpload
(String session) void
Nimbus.Iface.cancelBlobUpload
(String session) void
Nimbus.Client.deactivate
(String name) void
Nimbus.Iface.deactivate
(String name) void
void
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.void
Nimbus.Client.deleteBlob
(String key) void
Nimbus.Iface.deleteBlob
(String key) Nimbus.Client.downloadBlobChunk
(String session) Nimbus.Iface.downloadBlobChunk
(String session) Nimbus.Client.downloadChunk
(String id) Nimbus.Iface.downloadChunk
(String id) void
DistributedRPCInvocations.Client.failRequest
(String id) void
DistributedRPCInvocations.Iface.failRequest
(String id) void
DistributedRPCInvocations.Client.failRequestV2
(String id, DRPCExecutionException e) void
DistributedRPCInvocations.Iface.failRequestV2
(String id, DRPCExecutionException e) DistributedRPCInvocations.Client.fetchRequest
(String functionName) DistributedRPCInvocations.Iface.fetchRequest
(String functionName) void
Nimbus.Client.finishBlobUpload
(String session) void
Nimbus.Iface.finishBlobUpload
(String session) void
Nimbus.Client.finishFileUpload
(String location) void
Nimbus.Iface.finishFileUpload
(String location) Nimbus.Client.getBlobMeta
(String key) Nimbus.Iface.getBlobMeta
(String key) int
Nimbus.Client.getBlobReplication
(String key) int
Nimbus.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.boolean
Nimbus.Client.isRemoteBlobExists
(String blobKey) boolean
Nimbus.Iface.isRemoteBlobExists
(String blobKey) Decide if the blob is removed from cluster.boolean
Nimbus.Client.isTopologyNameAllowed
(String name) boolean
Nimbus.Iface.isTopologyNameAllowed
(String name) void
Nimbus.Client.killTopology
(String name) void
Nimbus.Iface.killTopology
(String name) void
Nimbus.Client.killTopologyWithOpts
(String name, KillOptions options) void
Nimbus.Iface.killTopologyWithOpts
(String name, KillOptions options) void
Nimbus.Client.rebalance
(String name, RebalanceOptions options) void
Nimbus.Iface.rebalance
(String name, RebalanceOptions options) void
Nimbus.Client.recv_activate()
Nimbus.Client.recv_beginBlobDownload()
Nimbus.Client.recv_beginCreateBlob()
Nimbus.Client.recv_beginFileUpload()
Nimbus.Client.recv_beginUpdateBlob()
void
Nimbus.Client.recv_cancelBlobUpload()
void
Nimbus.Client.recv_deactivate()
void
Nimbus.Client.recv_debug()
void
Nimbus.Client.recv_deleteBlob()
Nimbus.Client.recv_downloadBlobChunk()
Nimbus.Client.recv_downloadChunk()
DistributedRPC.Client.recv_execute()
void
DistributedRPCInvocations.Client.recv_failRequest()
void
DistributedRPCInvocations.Client.recv_failRequestV2()
DistributedRPCInvocations.Client.recv_fetchRequest()
void
Nimbus.Client.recv_finishBlobUpload()
void
Nimbus.Client.recv_finishFileUpload()
Nimbus.Client.recv_getBlobMeta()
int
Nimbus.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()
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
void
void
Supervisor.Client.sendSupervisorAssignments
(SupervisorAssignments assignments) void
Supervisor.Iface.sendSupervisorAssignments
(SupervisorAssignments assignments) Send node specific assignments to supervisorvoid
Nimbus.Client.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat) void
Nimbus.Iface.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heatbeat) Send supervisor local worker heartbeat when a supervisor is unreachablevoid
Supervisor.Client.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heartbeat) void
Supervisor.Iface.sendSupervisorWorkerHeartbeat
(SupervisorWorkerHeartbeat heartbeat) Send worker heartbeat to local supervisorvoid
Nimbus.Client.sendSupervisorWorkerHeartbeats
(SupervisorWorkerHeartbeats heartbeats) void
Nimbus.Iface.sendSupervisorWorkerHeartbeats
(SupervisorWorkerHeartbeats heartbeats) Send supervisor worker heartbeats for a specific supervisorvoid
Nimbus.Client.setBlobMeta
(String key, SettableBlobMeta meta) void
Nimbus.Iface.setBlobMeta
(String key, SettableBlobMeta meta) void
Nimbus.Client.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.Iface.submitTopology
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) void
Nimbus.Client.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) void
Nimbus.Iface.submitTopologyWithOpts
(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) int
Nimbus.Client.updateBlobReplication
(String key, int replication) int
Nimbus.Iface.updateBlobReplication
(String key, int replication) void
Nimbus.Client.uploadBlobChunk
(String session, ByteBuffer chunk) void
Nimbus.Iface.uploadBlobChunk
(String session, ByteBuffer chunk) void
Nimbus.Client.uploadChunk
(String location, ByteBuffer chunk) void
Nimbus.Iface.uploadChunk
(String location, ByteBuffer chunk) void
Nimbus.Client.uploadNewCredentials
(String name, Credentials creds) void
Nimbus.Iface.uploadNewCredentials
(String name, Credentials creds) ModifierConstructorDescriptionPerforms 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
Modifier and TypeMethodDescriptionboolean
HdfsBlobStore.blobExists
(String key, Subject who) Checks if a blob exists.HdfsBlobStore.createBlob
(String key, SettableBlobMeta meta, Subject who) HdfsClientBlobStore.createBlobToExtend
(String key, SettableBlobMeta meta) void
HdfsBlobStore.deleteBlob
(String key, Subject who) void
HdfsClientBlobStore.deleteBlob
(String key) HdfsBlobStore.getBlobMeta
(String key, Subject who) HdfsClientBlobStore.getBlobMeta
(String key) int
HdfsBlobStore.getBlobReplication
(String key, Subject who) int
HdfsClientBlobStore.getBlobReplication
(String key) boolean
HdfsClientBlobStore.isRemoteBlobExists
(String blobKey) void
HdfsBlobStore.setBlobMeta
(String key, SettableBlobMeta meta, Subject who) void
HdfsClientBlobStore.setBlobMetaToExtend
(String key, SettableBlobMeta meta) HdfsBlobStore.updateBlob
(String key, Subject who) HdfsClientBlobStore.updateBlob
(String key) int
HdfsBlobStore.updateBlobReplication
(String key, int replication, Subject who) int
HdfsClientBlobStore.updateBlobReplication
(String key, int replication) void
HdfsBlobStore.writeMetadata
(String key, SettableBlobMeta meta) -
Uses of AuthorizationException in org.apache.storm.kafka.trident
-
Uses of AuthorizationException in org.apache.storm.localizer
Modifier and TypeMethodDescriptionprotected org.apache.storm.localizer.LocallyCachedBlob.DownloadMeta
LocallyCachedBlob.fetch
(ClientBlobStore store, String key, IOFunction<Long, Path> pathSupplier, IOFunction<File, OutputStream> outStreamSupplier) Helper function to download blob from blob store.long
LocalizedResource.fetchUnzipToTemp
(ClientBlobStore store) abstract long
LocallyCachedBlob.fetchUnzipToTemp
(ClientBlobStore store) Download the latest version to a temp location.long
LocallyCachedTopologyBlob.fetchUnzipToTemp
(ClientBlobStore store) long
LocalizedResource.getRemoteVersion
(ClientBlobStore store) abstract long
LocallyCachedBlob.getRemoteVersion
(ClientBlobStore store) Get the version of the blob in the blob store.long
LocallyCachedTopologyBlob.getRemoteVersion
(ClientBlobStore store) void
LocallyCachedBlob.update
(ClientBlobStore blobStore, long remoteBlobstoreUpdateTime) Checks and downloads a blob locally as necessary. -
Uses of AuthorizationException in org.apache.storm.utils
Modifier and TypeClassDescriptionclass
Wraps the generated TException to allow getMessage() to return a valid string.Modifier and TypeMethodDescriptionstatic 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.