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	Description
BeginDownloadResult	LocalCluster.beginBlobDownload(String key)
String	LocalCluster.beginCreateBlob(String key, SettableBlobMeta meta)
String	LocalCluster.beginFileUpload()
String	LocalCluster.beginUpdateBlob(String key)
void	LocalCluster.cancelBlobUpload(String session)
void	LocalCluster.debug(String name, String component, boolean enable, double samplingPercentage)
void	LocalCluster.deleteBlob(String key)
ByteBuffer	LocalCluster.downloadBlobChunk(String session)
ByteBuffer	LocalCluster.downloadChunk(String id)
String	LocalDRPC.execute(String functionName, String funcArgs)
void	LocalDRPC.failRequest(String id)
void	LocalDRPC.failRequestV2(String id, DRPCExecutionException e)
DRPCRequest	LocalDRPC.fetchRequest(String functionName)
void	LocalCluster.finishBlobUpload(String session)
void	LocalCluster.finishFileUpload(String location)
ReadableBlobMeta	LocalCluster.getBlobMeta(String key)
int	LocalCluster.getBlobReplication(String key)
ComponentPageInfo	LocalCluster.getComponentPageInfo(String topologyId, String componentId, String window, boolean isIncludeSys)
NimbusSummary	LocalCluster.getLeader()
String	LocalCluster.getNimbusConf()
List<OwnerResourceSummary>	LocalCluster.getOwnerResourceSummaries(String owner)
SupervisorAssignments	LocalCluster.getSupervisorAssignments(String node)
SupervisorPageInfo	LocalCluster.getSupervisorPageInfo(String id, String host, boolean isIncludeSys)
TopologyHistoryInfo	LocalCluster.getTopologyHistory(String user)
TopologyPageInfo	LocalCluster.getTopologyPageInfo(String id, String window, boolean isIncludeSys)
StormTopology	LocalCluster.getUserTopology(String id)
boolean	LocalCluster.isRemoteBlobExists(String blobKey)
boolean	LocalCluster.isTopologyNameAllowed(String name)
static boolean	StormSubmitter.pushCredentials(String name, Map<String,Object> topoConf, Map<String,String> credentials)	Push a new set of credentials to the running topology.
static boolean	StormSubmitter.pushCredentials(String name, Map<String,Object> topoConf, Map<String,String> credentials, String expectedUser)	Push a new set of credentials to the running topology.
void	LocalDRPC.result(String id, String result)
void	LocalCluster.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)
void	LocalCluster.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)
void	LocalCluster.setBlobMeta(String key, SettableBlobMeta meta)
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

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

Modifier and Type	Method	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.
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.
AtomicOutputStream	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	BlobStore.getBlob(String key, Subject who)	Gets the InputStream to read the blob details.
abstract InputStreamWithMeta	ClientBlobStore.getBlob(String key)	Client facing API to read a blob.
InputStreamWithMeta	LocalFsBlobStore.getBlob(String key, Subject who)
InputStreamWithMeta	LocalModeClientBlobStore.getBlob(String key)
InputStreamWithMeta	NimbusBlobStore.getBlob(String key)
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.
ReadableBlobMeta	LocalFsBlobStore.getBlobMeta(String key, Subject who)
ReadableBlobMeta	LocalModeClientBlobStore.getBlobMeta(String key)
ReadableBlobMeta	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[]	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.
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.
AtomicOutputStream	LocalFsBlobStore.updateBlob(String key, Subject who)
AtomicOutputStream	LocalModeClientBlobStore.updateBlob(String key)
AtomicOutputStream	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

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

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

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

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

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

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

Modifier and Type	Method	Description
int	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)

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

Modifier and Type	Method	Description
void	Nimbus.Client.activate(String name)
void	Nimbus.Iface.activate(String name)
BeginDownloadResult	Nimbus.Client.beginBlobDownload(String key)
BeginDownloadResult	Nimbus.Iface.beginBlobDownload(String key)
String	Nimbus.Client.beginCreateBlob(String key, SettableBlobMeta meta)
String	Nimbus.Iface.beginCreateBlob(String key, SettableBlobMeta meta)
String	Nimbus.Client.beginFileUpload()
String	Nimbus.Iface.beginFileUpload()
String	Nimbus.Client.beginUpdateBlob(String key)
String	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	Nimbus.Client.debug(String name, String component, boolean enable, double samplingPercentage)
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.deleteBlob(String key)
void	Nimbus.Iface.deleteBlob(String key)
ByteBuffer	Nimbus.Client.downloadBlobChunk(String session)
ByteBuffer	Nimbus.Iface.downloadBlobChunk(String session)
ByteBuffer	Nimbus.Client.downloadChunk(String id)
ByteBuffer	Nimbus.Iface.downloadChunk(String id)
String	DistributedRPC.Client.execute(String functionName, String funcArgs)
String	DistributedRPC.Iface.execute(String functionName, String funcArgs)
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)
DRPCRequest	DistributedRPCInvocations.Client.fetchRequest(String functionName)
DRPCRequest	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)
ReadableBlobMeta	Nimbus.Client.getBlobMeta(String key)
ReadableBlobMeta	Nimbus.Iface.getBlobMeta(String key)
int	Nimbus.Client.getBlobReplication(String key)
int	Nimbus.Iface.getBlobReplication(String key)
ClusterSummary	Nimbus.Client.getClusterInfo()
ClusterSummary	Nimbus.Iface.getClusterInfo()
ComponentPageInfo	Nimbus.Client.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)
ComponentPageInfo	Nimbus.Iface.getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys)
NimbusSummary	Nimbus.Client.getLeader()
NimbusSummary	Nimbus.Iface.getLeader()
Assignment	Supervisor.Client.getLocalAssignmentForStorm(String id)
Assignment	Supervisor.Iface.getLocalAssignmentForStorm(String id)	Get local assignment for a storm
String	Nimbus.Client.getNimbusConf()
String	Nimbus.Iface.getNimbusConf()
List<OwnerResourceSummary>	Nimbus.Client.getOwnerResourceSummaries(String owner)
List<OwnerResourceSummary>	Nimbus.Iface.getOwnerResourceSummaries(String owner)
String	DistributedRPC.AsyncClient.execute_call.getResult()
Void	DistributedRPCInvocations.AsyncClient.failRequest_call.getResult()
Void	DistributedRPCInvocations.AsyncClient.failRequestV2_call.getResult()
DRPCRequest	DistributedRPCInvocations.AsyncClient.fetchRequest_call.getResult()
Void	DistributedRPCInvocations.AsyncClient.result_call.getResult()
Void	Nimbus.AsyncClient.activate_call.getResult()
BeginDownloadResult	Nimbus.AsyncClient.beginBlobDownload_call.getResult()
String	Nimbus.AsyncClient.beginCreateBlob_call.getResult()
String	Nimbus.AsyncClient.beginFileUpload_call.getResult()
String	Nimbus.AsyncClient.beginUpdateBlob_call.getResult()
Void	Nimbus.AsyncClient.cancelBlobUpload_call.getResult()
Void	Nimbus.AsyncClient.deactivate_call.getResult()
Void	Nimbus.AsyncClient.debug_call.getResult()
Void	Nimbus.AsyncClient.deleteBlob_call.getResult()
ByteBuffer	Nimbus.AsyncClient.downloadBlobChunk_call.getResult()
ByteBuffer	Nimbus.AsyncClient.downloadChunk_call.getResult()
Void	Nimbus.AsyncClient.finishBlobUpload_call.getResult()
Void	Nimbus.AsyncClient.finishFileUpload_call.getResult()
ReadableBlobMeta	Nimbus.AsyncClient.getBlobMeta_call.getResult()
Integer	Nimbus.AsyncClient.getBlobReplication_call.getResult()
ClusterSummary	Nimbus.AsyncClient.getClusterInfo_call.getResult()
ComponentPageInfo	Nimbus.AsyncClient.getComponentPageInfo_call.getResult()
NimbusSummary	Nimbus.AsyncClient.getLeader_call.getResult()
String	Nimbus.AsyncClient.getNimbusConf_call.getResult()
List<OwnerResourceSummary>	Nimbus.AsyncClient.getOwnerResourceSummaries_call.getResult()
SupervisorAssignments	Nimbus.AsyncClient.getSupervisorAssignments_call.getResult()
SupervisorPageInfo	Nimbus.AsyncClient.getSupervisorPageInfo_call.getResult()
StormTopology	Nimbus.AsyncClient.getTopology_call.getResult()
String	Nimbus.AsyncClient.getTopologyConf_call.getResult()
TopologyHistoryInfo	Nimbus.AsyncClient.getTopologyHistory_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfo_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoByName_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoByNameWithOpts_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult()
TopologyPageInfo	Nimbus.AsyncClient.getTopologyPageInfo_call.getResult()
List<TopologySummary>	Nimbus.AsyncClient.getTopologySummaries_call.getResult()
TopologySummary	Nimbus.AsyncClient.getTopologySummary_call.getResult()
TopologySummary	Nimbus.AsyncClient.getTopologySummaryByName_call.getResult()
StormTopology	Nimbus.AsyncClient.getUserTopology_call.getResult()
Boolean	Nimbus.AsyncClient.isRemoteBlobExists_call.getResult()
Boolean	Nimbus.AsyncClient.isTopologyNameAllowed_call.getResult()
Void	Nimbus.AsyncClient.killTopology_call.getResult()
Void	Nimbus.AsyncClient.killTopologyWithOpts_call.getResult()
Void	Nimbus.AsyncClient.rebalance_call.getResult()
Void	Nimbus.AsyncClient.sendSupervisorWorkerHeartbeat_call.getResult()
Void	Nimbus.AsyncClient.sendSupervisorWorkerHeartbeats_call.getResult()
Void	Nimbus.AsyncClient.setBlobMeta_call.getResult()
Void	Nimbus.AsyncClient.submitTopology_call.getResult()
Void	Nimbus.AsyncClient.submitTopologyWithOpts_call.getResult()
Integer	Nimbus.AsyncClient.updateBlobReplication_call.getResult()
Void	Nimbus.AsyncClient.uploadBlobChunk_call.getResult()
Void	Nimbus.AsyncClient.uploadChunk_call.getResult()
Void	Nimbus.AsyncClient.uploadNewCredentials_call.getResult()
Assignment	Supervisor.AsyncClient.getLocalAssignmentForStorm_call.getResult()
Void	Supervisor.AsyncClient.sendSupervisorAssignments_call.getResult()
Void	Supervisor.AsyncClient.sendSupervisorWorkerHeartbeat_call.getResult()
SupervisorAssignments	Nimbus.Client.getSupervisorAssignments(String node)
SupervisorAssignments	Nimbus.Iface.getSupervisorAssignments(String node)	Get assigned assignments for a specific supervisor
SupervisorPageInfo	Nimbus.Client.getSupervisorPageInfo(String id, String host, boolean is_include_sys)
SupervisorPageInfo	Nimbus.Iface.getSupervisorPageInfo(String id, String host, boolean is_include_sys)
StormTopology	Nimbus.Client.getTopology(String id)
StormTopology	Nimbus.Iface.getTopology(String id)	Returns the compiled topology that contains ackers and metrics consumsers.
String	Nimbus.Client.getTopologyConf(String id)
String	Nimbus.Iface.getTopologyConf(String id)
TopologyHistoryInfo	Nimbus.Client.getTopologyHistory(String user)
TopologyHistoryInfo	Nimbus.Iface.getTopologyHistory(String user)
TopologyInfo	Nimbus.Client.getTopologyInfo(String id)
TopologyInfo	Nimbus.Iface.getTopologyInfo(String id)
TopologyInfo	Nimbus.Client.getTopologyInfoByName(String name)
TopologyInfo	Nimbus.Iface.getTopologyInfoByName(String name)
TopologyInfo	Nimbus.Client.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)
TopologyInfo	Nimbus.Iface.getTopologyInfoByNameWithOpts(String name, GetInfoOptions options)
TopologyInfo	Nimbus.Client.getTopologyInfoWithOpts(String id, GetInfoOptions options)
TopologyInfo	Nimbus.Iface.getTopologyInfoWithOpts(String id, GetInfoOptions options)
TopologyPageInfo	Nimbus.Client.getTopologyPageInfo(String id, String window, boolean is_include_sys)
TopologyPageInfo	Nimbus.Iface.getTopologyPageInfo(String id, String window, boolean is_include_sys)
List<TopologySummary>	Nimbus.Client.getTopologySummaries()
List<TopologySummary>	Nimbus.Iface.getTopologySummaries()
TopologySummary	Nimbus.Client.getTopologySummary(String id)
TopologySummary	Nimbus.Iface.getTopologySummary(String id)
TopologySummary	Nimbus.Client.getTopologySummaryByName(String name)
TopologySummary	Nimbus.Iface.getTopologySummaryByName(String name)
StormTopology	Nimbus.Client.getUserTopology(String id)
StormTopology	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()
BeginDownloadResult	Nimbus.Client.recv_beginBlobDownload()
String	Nimbus.Client.recv_beginCreateBlob()
String	Nimbus.Client.recv_beginFileUpload()
String	Nimbus.Client.recv_beginUpdateBlob()
void	Nimbus.Client.recv_cancelBlobUpload()
void	Nimbus.Client.recv_deactivate()
void	Nimbus.Client.recv_debug()
void	Nimbus.Client.recv_deleteBlob()
ByteBuffer	Nimbus.Client.recv_downloadBlobChunk()
ByteBuffer	Nimbus.Client.recv_downloadChunk()
String	DistributedRPC.Client.recv_execute()
void	DistributedRPCInvocations.Client.recv_failRequest()
void	DistributedRPCInvocations.Client.recv_failRequestV2()
DRPCRequest	DistributedRPCInvocations.Client.recv_fetchRequest()
void	Nimbus.Client.recv_finishBlobUpload()
void	Nimbus.Client.recv_finishFileUpload()
ReadableBlobMeta	Nimbus.Client.recv_getBlobMeta()
int	Nimbus.Client.recv_getBlobReplication()
ClusterSummary	Nimbus.Client.recv_getClusterInfo()
ComponentPageInfo	Nimbus.Client.recv_getComponentPageInfo()
NimbusSummary	Nimbus.Client.recv_getLeader()
Assignment	Supervisor.Client.recv_getLocalAssignmentForStorm()
String	Nimbus.Client.recv_getNimbusConf()
List<OwnerResourceSummary>	Nimbus.Client.recv_getOwnerResourceSummaries()
SupervisorAssignments	Nimbus.Client.recv_getSupervisorAssignments()
SupervisorPageInfo	Nimbus.Client.recv_getSupervisorPageInfo()
StormTopology	Nimbus.Client.recv_getTopology()
String	Nimbus.Client.recv_getTopologyConf()
TopologyHistoryInfo	Nimbus.Client.recv_getTopologyHistory()
TopologyInfo	Nimbus.Client.recv_getTopologyInfo()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoByName()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoByNameWithOpts()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoWithOpts()
TopologyPageInfo	Nimbus.Client.recv_getTopologyPageInfo()
List<TopologySummary>	Nimbus.Client.recv_getTopologySummaries()
TopologySummary	Nimbus.Client.recv_getTopologySummary()
TopologySummary	Nimbus.Client.recv_getTopologySummaryByName()
StormTopology	Nimbus.Client.recv_getUserTopology()
boolean	Nimbus.Client.recv_isRemoteBlobExists()
boolean	Nimbus.Client.recv_isTopologyNameAllowed()
void	Nimbus.Client.recv_killTopology()
void	Nimbus.Client.recv_killTopologyWithOpts()
void	Nimbus.Client.recv_rebalance()
void	DistributedRPCInvocations.Client.recv_result()
void	Supervisor.Client.recv_sendSupervisorAssignments()
void	Nimbus.Client.recv_sendSupervisorWorkerHeartbeat()
void	Supervisor.Client.recv_sendSupervisorWorkerHeartbeat()
void	Nimbus.Client.recv_sendSupervisorWorkerHeartbeats()
void	Nimbus.Client.recv_setBlobMeta()
void	Nimbus.Client.recv_submitTopology()
void	Nimbus.Client.recv_submitTopologyWithOpts()
int	Nimbus.Client.recv_updateBlobReplication()
void	Nimbus.Client.recv_uploadBlobChunk()
void	Nimbus.Client.recv_uploadChunk()
void	Nimbus.Client.recv_uploadNewCredentials()
void	DistributedRPCInvocations.Client.result(String id, String result)
void	DistributedRPCInvocations.Iface.result(String id, String result)
void	Supervisor.Client.sendSupervisorAssignments(SupervisorAssignments assignments)
void	Supervisor.Iface.sendSupervisorAssignments(SupervisorAssignments assignments)	Send node specific assignments to supervisor
void	Nimbus.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)
void	Nimbus.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat)	Send supervisor local worker heartbeat when a supervisor is unreachable
void	Supervisor.Client.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)
void	Supervisor.Iface.sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heartbeat)	Send worker heartbeat to local supervisor
void	Nimbus.Client.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)
void	Nimbus.Iface.sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats)	Send supervisor worker heartbeats for a specific supervisor
void	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)

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

Modifier	Constructor	Description
	activate_result(NotAliveException e, AuthorizationException aze)
	AuthorizationException(AuthorizationException other)	Performs a deep copy on other.
	beginBlobDownload_result(BeginDownloadResult success, AuthorizationException aze, KeyNotFoundException knf)
	beginCreateBlob_result(String success, AuthorizationException aze, KeyAlreadyExistsException kae)
	beginFileUpload_result(String success, AuthorizationException aze)
	beginUpdateBlob_result(String success, AuthorizationException aze, KeyNotFoundException knf)
	cancelBlobUpload_result(AuthorizationException aze)
	deactivate_result(NotAliveException e, AuthorizationException aze)
	debug_result(NotAliveException e, AuthorizationException aze)
	deleteBlob_result(AuthorizationException aze, KeyNotFoundException knf, IllegalStateException ise)
	downloadBlobChunk_result(ByteBuffer success, AuthorizationException aze)
	downloadChunk_result(ByteBuffer success, AuthorizationException aze)
	execute_result(String success, DRPCExecutionException e, AuthorizationException aze)
	failRequest_result(AuthorizationException aze)
	failRequestV2_result(AuthorizationException aze)
	fetchRequest_result(DRPCRequest success, AuthorizationException aze)
	finishBlobUpload_result(AuthorizationException aze)
	finishFileUpload_result(AuthorizationException aze)
	getBlobMeta_result(ReadableBlobMeta success, AuthorizationException aze, KeyNotFoundException knf)
	getBlobReplication_result(int success, AuthorizationException aze, KeyNotFoundException knf)
	getClusterInfo_result(ClusterSummary success, AuthorizationException aze)
	getComponentPageInfo_result(ComponentPageInfo success, NotAliveException e, AuthorizationException aze)
	getLeader_result(NimbusSummary success, AuthorizationException aze)
	getLocalAssignmentForStorm_result(Assignment success, NotAliveException e, AuthorizationException aze)
	getNimbusConf_result(String success, AuthorizationException aze)
	getOwnerResourceSummaries_result(List<OwnerResourceSummary> success, AuthorizationException aze)
	getSupervisorAssignments_result(SupervisorAssignments success, AuthorizationException aze)
	getSupervisorPageInfo_result(SupervisorPageInfo success, NotAliveException e, AuthorizationException aze)
	getTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
	getTopologyConf_result(String success, NotAliveException e, AuthorizationException aze)
	getTopologyHistory_result(TopologyHistoryInfo success, AuthorizationException aze)
	getTopologyInfo_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
	getTopologyInfoByName_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
	getTopologyInfoByNameWithOpts_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
	getTopologyInfoWithOpts_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
	getTopologyPageInfo_result(TopologyPageInfo success, NotAliveException e, AuthorizationException aze)
	getTopologySummaries_result(List<TopologySummary> success, AuthorizationException aze)
	getTopologySummary_result(TopologySummary success, NotAliveException e, AuthorizationException aze)
	getTopologySummaryByName_result(TopologySummary success, NotAliveException e, AuthorizationException aze)
	getUserTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
	isRemoteBlobExists_result(boolean success, AuthorizationException aze)
	isTopologyNameAllowed_result(boolean success, AuthorizationException aze)
	killTopology_result(NotAliveException e, AuthorizationException aze)
	killTopologyWithOpts_result(NotAliveException e, AuthorizationException aze)
	rebalance_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)
	result_result(AuthorizationException aze)
	sendSupervisorAssignments_result(AuthorizationException aze)
	sendSupervisorWorkerHeartbeat_result(AuthorizationException aze, NotAliveException e)
	sendSupervisorWorkerHeartbeat_result(AuthorizationException aze)
	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	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	HdfsBlobStore.deleteBlob(String key, Subject who)
void	HdfsClientBlobStore.deleteBlob(String key)
InputStreamWithMeta	HdfsBlobStore.getBlob(String key, Subject who)
InputStreamWithMeta	HdfsClientBlobStore.getBlob(String key)
ReadableBlobMeta	HdfsBlobStore.getBlobMeta(String key, Subject who)
ReadableBlobMeta	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)
AtomicOutputStream	HdfsBlobStore.updateBlob(String key, Subject who)
AtomicOutputStream	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

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

Modifier and Type	Method	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	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.
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

Subclasses of AuthorizationException in org.apache.storm.utils

Modifier and Type	Class	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	Description
String	DRPCClient.execute(String func, String args)
static long	ServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf)	Validate topology blobstore map.
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf, BlobStore blobStore)	Validate topology blobstore map.
static void	Utils.validateTopologyBlobStoreMap(Map<String,Object> topoConf, NimbusBlobStore client)	Validate topology blobstore map.