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

Packages that use AuthorizationException

Package	Description
org.apache.storm
org.apache.storm.blobstore
org.apache.storm.daemon.common
org.apache.storm.daemon.drpc
org.apache.storm.daemon.nimbus
org.apache.storm.daemon.supervisor
org.apache.storm.daemon.ui.exceptionmappers
org.apache.storm.dependency
org.apache.storm.drpc
org.apache.storm.elasticsearch.bolt	ElasticSearch examples classes.
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.generated
org.apache.storm.hdfs.blobstore
org.apache.storm.kafka.trident
org.apache.storm.localizer
org.apache.storm.utils

Uses of AuthorizationException in org.apache.storm

Methods in org.apache.storm that throw AuthorizationException

Modifier and Type	Method and Description
BeginDownloadResult	LocalCluster.beginBlobDownload(String key)
String	LocalCluster.beginCreateBlob(String key, SettableBlobMeta meta)
String	LocalCluster.beginFileUpload()
String	LocalCluster.beginUpdateBlob(String key)
void	LocalCluster.cancelBlobUpload(String session)
void	LocalCluster.debug(String name, String component, boolean enable, double samplingPercentage)
void	LocalCluster.deleteBlob(String key)
ByteBuffer	LocalCluster.downloadBlobChunk(String session)
ByteBuffer	LocalCluster.downloadChunk(String id)
String	LocalDRPC.execute(String functionName, String funcArgs)
void	LocalDRPC.failRequest(String id)
void	LocalDRPC.failRequestV2(String id, DRPCExecutionException e)
DRPCRequest	LocalDRPC.fetchRequest(String functionName)
void	LocalCluster.finishBlobUpload(String session)
void	LocalCluster.finishFileUpload(String location)
ReadableBlobMeta	LocalCluster.getBlobMeta(String key)
int	LocalCluster.getBlobReplication(String key)
ComponentPageInfo	LocalCluster.getComponentPageInfo(String topologyId, String componentId, String window, boolean isIncludeSys)
NimbusSummary	LocalCluster.getLeader()
String	LocalCluster.getNimbusConf()
List<OwnerResourceSummary>	LocalCluster.getOwnerResourceSummaries(String owner)
SupervisorAssignments	LocalCluster.getSupervisorAssignments(String node)
SupervisorPageInfo	LocalCluster.getSupervisorPageInfo(String id, String host, boolean isIncludeSys)
TopologyHistoryInfo	LocalCluster.getTopologyHistory(String user)
TopologyInfo	LocalCluster.getTopologyInfoWithOpts(String id, GetInfoOptions options)
TopologyPageInfo	LocalCluster.getTopologyPageInfo(String id, String window, boolean isIncludeSys)
StormTopology	LocalCluster.getUserTopology(String id)
boolean	LocalCluster.isRemoteBlobExists(String blobKey)
boolean	LocalCluster.isTopologyNameAllowed(String name)
static boolean	StormSubmitter.pushCredentials(String name, Map<String,Object> topoConf, Map<String,String> credentials) Push a new set of credentials to the running topology.
static boolean	StormSubmitter.pushCredentials(String name, Map<String,Object> topoConf, Map<String,String> credentials, String expectedUser) Push a new set of credentials to the running topology.
void	LocalDRPC.result(String id, String result)
void	LocalCluster.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)
void	LocalCluster.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)
void	LocalCluster.setBlobMeta(String key, SettableBlobMeta meta)
static void	StormSubmitter.submitTopology(String name, Map<String,Object> topoConf, StormTopology topology) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopology(String name, Map<String,Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopology(String name, Map<String,Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.
void	LocalCluster.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
static void	StormSubmitter.submitTopologyAs(String name, Map<String,Object> topoConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submits a topology to run on the cluster as a particular user.
void	LocalCluster.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map<String,Object> topoConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map<String,Object> topoConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar.
int	LocalCluster.updateBlobReplication(String key, int replication)
void	LocalCluster.uploadBlobChunk(String session, ByteBuffer chunk)
void	LocalCluster.uploadChunk(String location, ByteBuffer chunk)

Uses of AuthorizationException in org.apache.storm.blobstore

Methods in org.apache.storm.blobstore that throw AuthorizationException

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

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

Methods in org.apache.storm.daemon.common with parameters of type AuthorizationException

Modifier and Type	Method and Description
javax.ws.rs.core.Response	AuthorizationExceptionMapper.toResponse(AuthorizationException ex)

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

Methods in org.apache.storm.daemon.drpc that throw AuthorizationException

Modifier and Type	Method and Description
String	DRPCThrift.execute(String functionName, String funcArgs)
<T extends OutstandingRequest> T	DRPC.execute(String functionName, String funcArgs, RequestFactory<T> factory)
String	DRPC.executeBlocking(String functionName, String funcArgs)
void	DRPCThrift.failRequest(String id)
void	DRPC.failRequest(String id, DRPCExecutionException e)
void	DRPCThrift.failRequestV2(String id, DRPCExecutionException e)
DRPCRequest	DRPC.fetchRequest(String functionName)
DRPCRequest	DRPCThrift.fetchRequest(String functionName)
void	DRPCThrift.result(String id, String result)
void	DRPC.returnResult(String id, String result)

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

Methods in org.apache.storm.daemon.nimbus that throw AuthorizationException

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

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

Methods in org.apache.storm.daemon.supervisor that throw AuthorizationException

Modifier and Type	Method and Description
void	Supervisor.checkAuthorization(String operation)
void	Supervisor.checkAuthorization(String topoName, Map<String,Object> topoConf, String operation)
void	Supervisor.checkAuthorization(String topoName, Map<String,Object> topoConf, String operation, ReqContext context)

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

Methods in org.apache.storm.daemon.ui.exceptionmappers with parameters of type AuthorizationException

Modifier and Type	Method and Description
static javax.ws.rs.core.Response	ExceptionMapperUtils.getResponse(AuthorizationException ex, javax.inject.Provider<javax.servlet.http.HttpServletRequest> request) getResponse.
javax.ws.rs.core.Response	AuthorizationExceptionMapper.toResponse(AuthorizationException e)

Uses of AuthorizationException in org.apache.storm.dependency

Methods in org.apache.storm.dependency that throw AuthorizationException

Modifier and Type	Method and Description
List<String>	DependencyUploader.uploadFiles(List<File> dependencies, boolean cleanupIfFails)

Uses of AuthorizationException in org.apache.storm.drpc

Methods in org.apache.storm.drpc that throw AuthorizationException

Modifier and Type	Method and Description
void	DRPCInvocationsClient.failRequest(String id)
void	DRPCInvocationsClient.failRequestV2(String id, DRPCExecutionException ex)
DRPCRequest	DRPCInvocationsClient.fetchRequest(String func)
void	DRPCInvocationsClient.result(String id, String result)

Uses of AuthorizationException in org.apache.storm.elasticsearch.bolt

Methods in org.apache.storm.elasticsearch.bolt that throw AuthorizationException

Modifier and Type	Method and Description
static void	EsIndexTopology.main(String[] args) The example’s main method.

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

Methods in org.apache.storm.elasticsearch.trident that throw AuthorizationException

Modifier and Type	Method and Description
static void	TridentEsTopology.main(String[] args) The example’s main method.

Uses of AuthorizationException in org.apache.storm.generated

Methods in org.apache.storm.generated that return AuthorizationException

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

Methods in org.apache.storm.generated with parameters of type AuthorizationException

Modifier and Type	Method and Description
int	AuthorizationException.compareTo(AuthorizationException other)
boolean	AuthorizationException.equals(AuthorizationException that)
void	DistributedRPC.execute_result.set_aze(AuthorizationException aze)
void	DistributedRPCInvocations.result_result.set_aze(AuthorizationException aze)
void	DistributedRPCInvocations.fetchRequest_result.set_aze(AuthorizationException aze)
void	DistributedRPCInvocations.failRequest_result.set_aze(AuthorizationException aze)
void	DistributedRPCInvocations.failRequestV2_result.set_aze(AuthorizationException aze)
void	Nimbus.submitTopology_result.set_aze(AuthorizationException aze)
void	Nimbus.submitTopologyWithOpts_result.set_aze(AuthorizationException aze)
void	Nimbus.killTopology_result.set_aze(AuthorizationException aze)
void	Nimbus.killTopologyWithOpts_result.set_aze(AuthorizationException aze)
void	Nimbus.activate_result.set_aze(AuthorizationException aze)
void	Nimbus.deactivate_result.set_aze(AuthorizationException aze)
void	Nimbus.rebalance_result.set_aze(AuthorizationException aze)
void	Nimbus.debug_result.set_aze(AuthorizationException aze)
void	Nimbus.uploadNewCredentials_result.set_aze(AuthorizationException aze)
void	Nimbus.beginCreateBlob_result.set_aze(AuthorizationException aze)
void	Nimbus.beginUpdateBlob_result.set_aze(AuthorizationException aze)
void	Nimbus.uploadBlobChunk_result.set_aze(AuthorizationException aze)
void	Nimbus.finishBlobUpload_result.set_aze(AuthorizationException aze)
void	Nimbus.cancelBlobUpload_result.set_aze(AuthorizationException aze)
void	Nimbus.getBlobMeta_result.set_aze(AuthorizationException aze)
void	Nimbus.setBlobMeta_result.set_aze(AuthorizationException aze)
void	Nimbus.beginBlobDownload_result.set_aze(AuthorizationException aze)
void	Nimbus.downloadBlobChunk_result.set_aze(AuthorizationException aze)
void	Nimbus.deleteBlob_result.set_aze(AuthorizationException aze)
void	Nimbus.getBlobReplication_result.set_aze(AuthorizationException aze)
void	Nimbus.updateBlobReplication_result.set_aze(AuthorizationException aze)
void	Nimbus.beginFileUpload_result.set_aze(AuthorizationException aze)
void	Nimbus.uploadChunk_result.set_aze(AuthorizationException aze)
void	Nimbus.finishFileUpload_result.set_aze(AuthorizationException aze)
void	Nimbus.downloadChunk_result.set_aze(AuthorizationException aze)
void	Nimbus.getNimbusConf_result.set_aze(AuthorizationException aze)
void	Nimbus.getClusterInfo_result.set_aze(AuthorizationException aze)
void	Nimbus.getLeader_result.set_aze(AuthorizationException aze)
void	Nimbus.isTopologyNameAllowed_result.set_aze(AuthorizationException aze)
void	Nimbus.getTopologyInfo_result.set_aze(AuthorizationException aze)
void	Nimbus.getTopologyInfoWithOpts_result.set_aze(AuthorizationException aze)
void	Nimbus.getTopologyPageInfo_result.set_aze(AuthorizationException aze)
void	Nimbus.getSupervisorPageInfo_result.set_aze(AuthorizationException aze)
void	Nimbus.getComponentPageInfo_result.set_aze(AuthorizationException aze)
void	Nimbus.getTopologyConf_result.set_aze(AuthorizationException aze)
void	Nimbus.getTopology_result.set_aze(AuthorizationException aze)
void	Nimbus.getUserTopology_result.set_aze(AuthorizationException aze)
void	Nimbus.getTopologyHistory_result.set_aze(AuthorizationException aze)
void	Nimbus.getOwnerResourceSummaries_result.set_aze(AuthorizationException aze)
void	Nimbus.getSupervisorAssignments_result.set_aze(AuthorizationException aze)
void	Nimbus.sendSupervisorWorkerHeartbeats_result.set_aze(AuthorizationException aze)
void	Nimbus.sendSupervisorWorkerHeartbeat_result.set_aze(AuthorizationException aze)
void	Nimbus.isRemoteBlobExists_result.set_aze(AuthorizationException aze)
void	Supervisor.sendSupervisorAssignments_result.set_aze(AuthorizationException aze)
void	Supervisor.getLocalAssignmentForStorm_result.set_aze(AuthorizationException aze)
void	Supervisor.sendSupervisorWorkerHeartbeat_result.set_aze(AuthorizationException aze)

Methods in org.apache.storm.generated that throw AuthorizationException

Modifier and Type	Method and Description
void	Nimbus.Iface.activate(String name)
void	Nimbus.Client.activate(String name)
BeginDownloadResult	Nimbus.Iface.beginBlobDownload(String key)
BeginDownloadResult	Nimbus.Client.beginBlobDownload(String key)
String	Nimbus.Iface.beginCreateBlob(String key, SettableBlobMeta meta)
String	Nimbus.Client.beginCreateBlob(String key, SettableBlobMeta meta)
String	Nimbus.Iface.beginFileUpload()
String	Nimbus.Client.beginFileUpload()
String	Nimbus.Iface.beginUpdateBlob(String key)
String	Nimbus.Client.beginUpdateBlob(String key)
void	Nimbus.Iface.cancelBlobUpload(String session)
void	Nimbus.Client.cancelBlobUpload(String session)
void	Nimbus.Iface.deactivate(String name)
void	Nimbus.Client.deactivate(String name)
void	Nimbus.Iface.debug(String name, String component, boolean enable, double samplingPercentage) Enable/disable logging the tuples generated in topology via an internal EventLogger bolt.
void	Nimbus.Client.debug(String name, String component, boolean enable, double samplingPercentage)
void	Nimbus.Iface.deleteBlob(String key)
void	Nimbus.Client.deleteBlob(String key)
ByteBuffer	Nimbus.Iface.downloadBlobChunk(String session)
ByteBuffer	Nimbus.Client.downloadBlobChunk(String session)
ByteBuffer	Nimbus.Iface.downloadChunk(String id)
ByteBuffer	Nimbus.Client.downloadChunk(String id)
String	DistributedRPC.Iface.execute(String functionName, String funcArgs)
String	DistributedRPC.Client.execute(String functionName, String funcArgs)
void	DistributedRPCInvocations.Iface.failRequest(String id)
void	DistributedRPCInvocations.Client.failRequest(String id)
void	DistributedRPCInvocations.Iface.failRequestV2(String id, DRPCExecutionException e)
void	DistributedRPCInvocations.Client.failRequestV2(String id, DRPCExecutionException e)
DRPCRequest	DistributedRPCInvocations.Iface.fetchRequest(String functionName)
DRPCRequest	DistributedRPCInvocations.Client.fetchRequest(String functionName)
void	Nimbus.Iface.finishBlobUpload(String session)
void	Nimbus.Client.finishBlobUpload(String session)
void	Nimbus.Iface.finishFileUpload(String location)
void	Nimbus.Client.finishFileUpload(String location)
ReadableBlobMeta	Nimbus.Iface.getBlobMeta(String key)
ReadableBlobMeta	Nimbus.Client.getBlobMeta(String key)
int	Nimbus.Iface.getBlobReplication(String key)
int	Nimbus.Client.getBlobReplication(String key)
ClusterSummary	Nimbus.Iface.getClusterInfo()
ClusterSummary	Nimbus.Client.getClusterInfo()
ComponentPageInfo	Nimbus.Iface.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)
ComponentPageInfo	Nimbus.Client.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)
NimbusSummary	Nimbus.Iface.getLeader()
NimbusSummary	Nimbus.Client.getLeader()
Assignment	Supervisor.Iface.getLocalAssignmentForStorm(String id) Get local assignment for a storm
Assignment	Supervisor.Client.getLocalAssignmentForStorm(String id)
String	Nimbus.Iface.getNimbusConf()
String	Nimbus.Client.getNimbusConf()
List<OwnerResourceSummary>	Nimbus.Iface.getOwnerResourceSummaries(String owner)
List<OwnerResourceSummary>	Nimbus.Client.getOwnerResourceSummaries(String owner)
String	DistributedRPC.AsyncClient.execute_call.getResult()
Void	DistributedRPCInvocations.AsyncClient.result_call.getResult()
DRPCRequest	DistributedRPCInvocations.AsyncClient.fetchRequest_call.getResult()
Void	DistributedRPCInvocations.AsyncClient.failRequest_call.getResult()
Void	DistributedRPCInvocations.AsyncClient.failRequestV2_call.getResult()
Void	Nimbus.AsyncClient.submitTopology_call.getResult()
Void	Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult()
Void	Nimbus.AsyncClient.killTopology_call.getResult()
Void	Nimbus.AsyncClient.killTopologyWithOpts_call.getResult()
Void	Nimbus.AsyncClient.activate_call.getResult()
Void	Nimbus.AsyncClient.deactivate_call.getResult()
Void	Nimbus.AsyncClient.rebalance_call.getResult()
Void	Nimbus.AsyncClient.debug_call.getResult()
Void	Nimbus.AsyncClient.uploadNewCredentials_call.getResult()
String	Nimbus.AsyncClient.beginCreateBlob_call.getResult()
String	Nimbus.AsyncClient.beginUpdateBlob_call.getResult()
Void	Nimbus.AsyncClient.uploadBlobChunk_call.getResult()
Void	Nimbus.AsyncClient.finishBlobUpload_call.getResult()
Void	Nimbus.AsyncClient.cancelBlobUpload_call.getResult()
ReadableBlobMeta	Nimbus.AsyncClient.getBlobMeta_call.getResult()
Void	Nimbus.AsyncClient.setBlobMeta_call.getResult()
BeginDownloadResult	Nimbus.AsyncClient.beginBlobDownload_call.getResult()
ByteBuffer	Nimbus.AsyncClient.downloadBlobChunk_call.getResult()
Void	Nimbus.AsyncClient.deleteBlob_call.getResult()
Integer	Nimbus.AsyncClient.getBlobReplication_call.getResult()
Integer	Nimbus.AsyncClient.updateBlobReplication_call.getResult()
String	Nimbus.AsyncClient.beginFileUpload_call.getResult()
Void	Nimbus.AsyncClient.uploadChunk_call.getResult()
Void	Nimbus.AsyncClient.finishFileUpload_call.getResult()
ByteBuffer	Nimbus.AsyncClient.downloadChunk_call.getResult()
String	Nimbus.AsyncClient.getNimbusConf_call.getResult()
ClusterSummary	Nimbus.AsyncClient.getClusterInfo_call.getResult()
NimbusSummary	Nimbus.AsyncClient.getLeader_call.getResult()
Boolean	Nimbus.AsyncClient.isTopologyNameAllowed_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfo_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult()
TopologyPageInfo	Nimbus.AsyncClient.getTopologyPageInfo_call.getResult()
SupervisorPageInfo	Nimbus.AsyncClient.getSupervisorPageInfo_call.getResult()
ComponentPageInfo	Nimbus.AsyncClient.getComponentPageInfo_call.getResult()
String	Nimbus.AsyncClient.getTopologyConf_call.getResult()
StormTopology	Nimbus.AsyncClient.getTopology_call.getResult()
StormTopology	Nimbus.AsyncClient.getUserTopology_call.getResult()
TopologyHistoryInfo	Nimbus.AsyncClient.getTopologyHistory_call.getResult()
List<OwnerResourceSummary>	Nimbus.AsyncClient.getOwnerResourceSummaries_call.getResult()
SupervisorAssignments	Nimbus.AsyncClient.getSupervisorAssignments_call.getResult()
Void	Nimbus.AsyncClient.sendSupervisorWorkerHeartbeats_call.getResult()
Void	Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat_call.getResult()
Boolean	Nimbus.AsyncClient.isRemoteBlobExists_call.getResult()
Void	Supervisor.AsyncClient.sendSupervisorAssignments_call.getResult()
Assignment	Supervisor.AsyncClient.getLocalAssignmentForStorm_call.getResult()
Void	Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat_call.getResult()
SupervisorAssignments	Nimbus.Iface.getSupervisorAssignments(String node) Get assigned assignments for a specific supervisor
SupervisorAssignments	Nimbus.Client.getSupervisorAssignments(String node)
SupervisorPageInfo	Nimbus.Iface.getSupervisorPageInfo(String id, String host, boolean is_include_sys)
SupervisorPageInfo	Nimbus.Client.getSupervisorPageInfo(String id, String host, boolean is_include_sys)
StormTopology	Nimbus.Iface.getTopology(String id) Returns the compiled topology that contains ackers and metrics consumsers.
StormTopology	Nimbus.Client.getTopology(String id)
String	Nimbus.Iface.getTopologyConf(String id)
String	Nimbus.Client.getTopologyConf(String id)
TopologyHistoryInfo	Nimbus.Iface.getTopologyHistory(String user)
TopologyHistoryInfo	Nimbus.Client.getTopologyHistory(String user)
TopologyInfo	Nimbus.Iface.getTopologyInfo(String id)
TopologyInfo	Nimbus.Client.getTopologyInfo(String id)
TopologyInfo	Nimbus.Iface.getTopologyInfoWithOpts(String id, GetInfoOptions options)
TopologyInfo	Nimbus.Client.getTopologyInfoWithOpts(String id, GetInfoOptions options)
TopologyPageInfo	Nimbus.Iface.getTopologyPageInfo(String id, String window, boolean is_include_sys)
TopologyPageInfo	Nimbus.Client.getTopologyPageInfo(String id, String window, boolean is_include_sys)
StormTopology	Nimbus.Iface.getUserTopology(String id) Returns the user specified topology as submitted originally.
StormTopology	Nimbus.Client.getUserTopology(String id)
boolean	Nimbus.Iface.isRemoteBlobExists(String blobKey) Decide if the blob is removed from cluster.
boolean	Nimbus.Client.isRemoteBlobExists(String blobKey)
boolean	Nimbus.Iface.isTopologyNameAllowed(String name)
boolean	Nimbus.Client.isTopologyNameAllowed(String name)
void	Nimbus.Iface.killTopology(String name)
void	Nimbus.Client.killTopology(String name)
void	Nimbus.Iface.killTopologyWithOpts(String name, KillOptions options)
void	Nimbus.Client.killTopologyWithOpts(String name, KillOptions options)
void	Nimbus.Iface.rebalance(String name, RebalanceOptions options)
void	Nimbus.Client.rebalance(String name, RebalanceOptions options)
void	Nimbus.Client.recv_activate()
BeginDownloadResult	Nimbus.Client.recv_beginBlobDownload()
String	Nimbus.Client.recv_beginCreateBlob()
String	Nimbus.Client.recv_beginFileUpload()
String	Nimbus.Client.recv_beginUpdateBlob()
void	Nimbus.Client.recv_cancelBlobUpload()
void	Nimbus.Client.recv_deactivate()
void	Nimbus.Client.recv_debug()
void	Nimbus.Client.recv_deleteBlob()
ByteBuffer	Nimbus.Client.recv_downloadBlobChunk()
ByteBuffer	Nimbus.Client.recv_downloadChunk()
String	DistributedRPC.Client.recv_execute()
void	DistributedRPCInvocations.Client.recv_failRequest()
void	DistributedRPCInvocations.Client.recv_failRequestV2()
DRPCRequest	DistributedRPCInvocations.Client.recv_fetchRequest()
void	Nimbus.Client.recv_finishBlobUpload()
void	Nimbus.Client.recv_finishFileUpload()
ReadableBlobMeta	Nimbus.Client.recv_getBlobMeta()
int	Nimbus.Client.recv_getBlobReplication()
ClusterSummary	Nimbus.Client.recv_getClusterInfo()
ComponentPageInfo	Nimbus.Client.recv_getComponentPageInfo()
NimbusSummary	Nimbus.Client.recv_getLeader()
Assignment	Supervisor.Client.recv_getLocalAssignmentForStorm()
String	Nimbus.Client.recv_getNimbusConf()
List<OwnerResourceSummary>	Nimbus.Client.recv_getOwnerResourceSummaries()
SupervisorAssignments	Nimbus.Client.recv_getSupervisorAssignments()
SupervisorPageInfo	Nimbus.Client.recv_getSupervisorPageInfo()
StormTopology	Nimbus.Client.recv_getTopology()
String	Nimbus.Client.recv_getTopologyConf()
TopologyHistoryInfo	Nimbus.Client.recv_getTopologyHistory()
TopologyInfo	Nimbus.Client.recv_getTopologyInfo()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoWithOpts()
TopologyPageInfo	Nimbus.Client.recv_getTopologyPageInfo()
StormTopology	Nimbus.Client.recv_getUserTopology()
boolean	Nimbus.Client.recv_isRemoteBlobExists()
boolean	Nimbus.Client.recv_isTopologyNameAllowed()
void	Nimbus.Client.recv_killTopology()
void	Nimbus.Client.recv_killTopologyWithOpts()
void	Nimbus.Client.recv_rebalance()
void	DistributedRPCInvocations.Client.recv_result()
void	Supervisor.Client.recv_sendSupervisorAssignments()
void	Nimbus.Client.recv_sendSupervisorWorkerHeartbeat()
void	Supervisor.Client.recv_sendSupervisorWorkerHeartbeat()
void	Nimbus.Client.recv_sendSupervisorWorkerHeartbeats()
void	Nimbus.Client.recv_setBlobMeta()
void	Nimbus.Client.recv_submitTopology()
void	Nimbus.Client.recv_submitTopologyWithOpts()
int	Nimbus.Client.recv_updateBlobReplication()
void	Nimbus.Client.recv_uploadBlobChunk()
void	Nimbus.Client.recv_uploadChunk()
void	Nimbus.Client.recv_uploadNewCredentials()
void	DistributedRPCInvocations.Iface.result(String id, String result)
void	DistributedRPCInvocations.Client.result(String id, String result)
void	Supervisor.Iface.sendSupervisorAssignments(SupervisorAssignments assignments) Send node specific assignments to supervisor
void	Supervisor.Client.sendSupervisorAssignments(SupervisorAssignments assignments)
void	Nimbus.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) Send supervisor local worker heartbeat when a supervisor is unreachable
void	Nimbus.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)
void	Supervisor.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat) Send worker heartbeat to local supervisor
void	Supervisor.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)
void	Nimbus.Iface.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) Send supervisor worker heartbeats for a specific supervisor
void	Nimbus.Client.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)
void	Nimbus.Iface.setBlobMeta(String key, SettableBlobMeta meta)
void	Nimbus.Client.setBlobMeta(String key, SettableBlobMeta meta)
void	Nimbus.Iface.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.Client.submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology)
void	Nimbus.Iface.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
void	Nimbus.Client.submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options)
int	Nimbus.Iface.updateBlobReplication(String key, int replication)
int	Nimbus.Client.updateBlobReplication(String key, int replication)
void	Nimbus.Iface.uploadBlobChunk(String session, ByteBuffer chunk)
void	Nimbus.Client.uploadBlobChunk(String session, ByteBuffer chunk)
void	Nimbus.Iface.uploadChunk(String location, ByteBuffer chunk)
void	Nimbus.Client.uploadChunk(String location, ByteBuffer chunk)
void	Nimbus.Iface.uploadNewCredentials(String name, Credentials creds)
void	Nimbus.Client.uploadNewCredentials(String name, Credentials creds)

Constructors in org.apache.storm.generated with parameters of type AuthorizationException

Constructor and Description
activate_result(NotAliveException e, AuthorizationException aze)
AuthorizationException(AuthorizationException other) Performs a deep copy on other.
beginBlobDownload_result(BeginDownloadResult success, AuthorizationException aze, KeyNotFoundException knf)
beginCreateBlob_result(String success, AuthorizationException aze, KeyAlreadyExistsException kae)
beginFileUpload_result(String success, AuthorizationException aze)
beginUpdateBlob_result(String success, AuthorizationException aze, KeyNotFoundException knf)
cancelBlobUpload_result(AuthorizationException aze)
deactivate_result(NotAliveException e, AuthorizationException aze)
debug_result(NotAliveException e, AuthorizationException aze)
deleteBlob_result(AuthorizationException aze, KeyNotFoundException knf, IllegalStateException ise)
downloadBlobChunk_result(ByteBuffer success, AuthorizationException aze)
downloadChunk_result(ByteBuffer success, AuthorizationException aze)
execute_result(String success, DRPCExecutionException e, AuthorizationException aze)
failRequest_result(AuthorizationException aze)
failRequestV2_result(AuthorizationException aze)
fetchRequest_result(DRPCRequest success, AuthorizationException aze)
finishBlobUpload_result(AuthorizationException aze)
finishFileUpload_result(AuthorizationException aze)
getBlobMeta_result(ReadableBlobMeta success, AuthorizationException aze, KeyNotFoundException knf)
getBlobReplication_result(int success, AuthorizationException aze, KeyNotFoundException knf)
getClusterInfo_result(ClusterSummary success, AuthorizationException aze)
getComponentPageInfo_result(ComponentPageInfo success, NotAliveException e, AuthorizationException aze)
getLeader_result(NimbusSummary success, AuthorizationException aze)
getLocalAssignmentForStorm_result(Assignment success, NotAliveException e, AuthorizationException aze)
getNimbusConf_result(String success, AuthorizationException aze)
getOwnerResourceSummaries_result(List<OwnerResourceSummary> success, AuthorizationException aze)
getSupervisorAssignments_result(SupervisorAssignments success, AuthorizationException aze)
getSupervisorPageInfo_result(SupervisorPageInfo success, NotAliveException e, AuthorizationException aze)
getTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
getTopologyConf_result(String success, NotAliveException e, AuthorizationException aze)
getTopologyHistory_result(TopologyHistoryInfo success, AuthorizationException aze)
getTopologyInfo_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
getTopologyInfoWithOpts_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
getTopologyPageInfo_result(TopologyPageInfo success, NotAliveException e, AuthorizationException aze)
getUserTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
isRemoteBlobExists_result(boolean success, AuthorizationException aze)
isTopologyNameAllowed_result(boolean success, AuthorizationException aze)
killTopology_result(NotAliveException e, AuthorizationException aze)
killTopologyWithOpts_result(NotAliveException e, AuthorizationException aze)
rebalance_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)
result_result(AuthorizationException aze)
sendSupervisorAssignments_result(AuthorizationException aze)
sendSupervisorWorkerHeartbeat_result(AuthorizationException aze)
sendSupervisorWorkerHeartbeat_result(AuthorizationException aze, NotAliveException e)
sendSupervisorWorkerHeartbeats_result(AuthorizationException aze)
setBlobMeta_result(AuthorizationException aze, KeyNotFoundException knf)
submitTopology_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)
submitTopologyWithOpts_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)
updateBlobReplication_result(int success, AuthorizationException aze, KeyNotFoundException knf)
uploadBlobChunk_result(AuthorizationException aze)
uploadChunk_result(AuthorizationException aze)
uploadNewCredentials_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)

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

Methods in org.apache.storm.hdfs.blobstore that throw AuthorizationException

Modifier and Type	Method and Description
boolean	HdfsBlobStore.blobExists(String key, Subject who) Checks if a blob exists.
AtomicOutputStream	HdfsBlobStore.createBlob(String key, SettableBlobMeta meta, Subject who)
AtomicOutputStream	HdfsClientBlobStore.createBlobToExtend(String key, SettableBlobMeta meta)
void	HdfsClientBlobStore.deleteBlob(String key)
void	HdfsBlobStore.deleteBlob(String key, Subject who)
InputStreamWithMeta	HdfsClientBlobStore.getBlob(String key)
InputStreamWithMeta	HdfsBlobStore.getBlob(String key, Subject who)
ReadableBlobMeta	HdfsClientBlobStore.getBlobMeta(String key)
ReadableBlobMeta	HdfsBlobStore.getBlobMeta(String key, Subject who)
int	HdfsClientBlobStore.getBlobReplication(String key)
int	HdfsBlobStore.getBlobReplication(String key, Subject who)
boolean	HdfsClientBlobStore.isRemoteBlobExists(String blobKey)
void	HdfsBlobStore.setBlobMeta(String key, SettableBlobMeta meta, Subject who)
void	HdfsClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta)
AtomicOutputStream	HdfsClientBlobStore.updateBlob(String key)
AtomicOutputStream	HdfsBlobStore.updateBlob(String key, Subject who)
int	HdfsClientBlobStore.updateBlobReplication(String key, int replication)
int	HdfsBlobStore.updateBlobReplication(String key, int replication, Subject who)
void	HdfsBlobStore.writeMetadata(String key, SettableBlobMeta meta)

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

Methods in org.apache.storm.kafka.trident that throw AuthorizationException

Modifier and Type	Method and Description
protected void	TridentKafkaClientTopologyNamedTopics.run(String[] args)

Uses of AuthorizationException in org.apache.storm.localizer

Methods in org.apache.storm.localizer that throw AuthorizationException

Modifier and Type	Method and Description
protected org.apache.storm.localizer.LocallyCachedBlob.DownloadMeta	LocallyCachedBlob.fetch(ClientBlobStore store, String key, IOFunction<Long,Path> pathSupplier, IOFunction<File,OutputStream> outStreamSupplier) Helper function to download blob from blob store.
abstract long	LocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store) Download the latest version to a temp location.
long	LocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store)
long	LocalizedResource.fetchUnzipToTemp(ClientBlobStore store)
abstract long	LocallyCachedBlob.getRemoteVersion(ClientBlobStore store) Get the version of the blob in the blob store.
long	LocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store)
long	LocalizedResource.getRemoteVersion(ClientBlobStore store)

Uses of AuthorizationException in org.apache.storm.utils

Subclasses of AuthorizationException in org.apache.storm.utils

Modifier and Type	Class and Description
class	WrappedAuthorizationException Wraps the generated TException to allow getMessage() to return a valid string.

Methods in org.apache.storm.utils that throw AuthorizationException

Modifier and Type	Method and Description
static void	ServerUtils.downloadResourcesAsSupervisor(String key, String localFile, ClientBlobStore cb) Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
void	ServerUtils.downloadResourcesAsSupervisorImpl(String key, String localFile, ClientBlobStore cb)
String	DRPCClient.execute(String func, String args)
static long	ServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf) Validate topology blobstore map.
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf, BlobStore blobStore) Validate topology blobstore map.
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf, NimbusBlobStore client) Validate topology blobstore map.