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

Packages that use AuthorizationException

Package	Description
org.apache.storm
org.apache.storm.blobstore
org.apache.storm.dependency
org.apache.storm.drpc
org.apache.storm.generated
org.apache.storm.hdfs.blobstore
org.apache.storm.kafka.trident
org.apache.storm.localizer
org.apache.storm.starter.util
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
static void	StormSubmitter.pushCredentials(String name, Map stormConf, Map<String,String> credentials) Push a new set of credentials to the running topology.
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopology(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener) Submits a topology to run on the cluster.
static void	StormSubmitter.submitTopologyAs(String name, Map stormConf, StormTopology topology, SubmitOptions opts, StormSubmitter.ProgressListener progressListener, String asUser) Submits a topology to run on the cluster as a particular user.
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology) Submits a topology to run on the cluster with a progress bar.
static void	StormSubmitter.submitTopologyWithProgressBar(String name, Map stormConf, StormTopology topology, SubmitOptions opts) Submits a topology to run on the cluster with a progress bar.

Uses of AuthorizationException in org.apache.storm.blobstore

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

Modifier and Type	Method and Description
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 AtomicOutputStream	NimbusBlobStore.createBlobToExtend(String key, SettableBlobMeta meta)
protected abstract AtomicOutputStream	ClientBlobStore.createBlobToExtend(String key, SettableBlobMeta meta) Client facing API to create a blob.
void	NimbusBlobStore.deleteBlob(String key)
abstract void	ClientBlobStore.deleteBlob(String key) Client facing API to delete a blob.
void	LocalFsBlobStore.deleteBlob(String key, Subject who)
abstract void	BlobStore.deleteBlob(String key, Subject who) Deletes the blob data and metadata.
InputStreamWithMeta	NimbusBlobStore.getBlob(String key)
abstract InputStreamWithMeta	ClientBlobStore.getBlob(String key) Client facing API to read a blob.
InputStreamWithMeta	LocalFsBlobStore.getBlob(String key, Subject who)
abstract InputStreamWithMeta	BlobStore.getBlob(String key, Subject who) Gets the InputStream to read the blob details
ReadableBlobMeta	NimbusBlobStore.getBlobMeta(String key)
abstract ReadableBlobMeta	ClientBlobStore.getBlobMeta(String key) Client facing API to read the metadata information.
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.
int	NimbusBlobStore.getBlobReplication(String key)
abstract int	ClientBlobStore.getBlobReplication(String key) Client facing API to read the replication of a blob.
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.
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 void	NimbusBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta)
protected abstract void	ClientBlobStore.setBlobMetaToExtend(String key, SettableBlobMeta meta) Client facing API to set the metadata for a blob.
AtomicOutputStream	NimbusBlobStore.updateBlob(String key)
abstract AtomicOutputStream	ClientBlobStore.updateBlob(String key) Client facing API to update a blob.
AtomicOutputStream	LocalFsBlobStore.updateBlob(String key, Subject who)
abstract AtomicOutputStream	BlobStore.updateBlob(String key, Subject who) Updates the blob data.
int	NimbusBlobStore.updateBlobReplication(String key, int replication)
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)
abstract int	BlobStore.updateBlobReplication(String key, int replication, Subject who) Modifies the replication factor of the blob.
static void	BlobStore.validateKey(String key) Validates key checking for potentially harmful patterns
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.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)
DRPCRequest	DRPCInvocationsClient.fetchRequest(String func)
void	DRPCInvocationsClient.result(String id, String result)

Uses of AuthorizationException in org.apache.storm.generated

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

Modifier and Type	Method and Description
AuthorizationException	AuthorizationException.deepCopy()
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.beginFileDownload_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	DistributedRPCInvocations.result_result.get_aze()
AuthorizationException	DistributedRPCInvocations.fetchRequest_result.get_aze()
AuthorizationException	DistributedRPCInvocations.failRequest_result.get_aze()
AuthorizationException	DistributedRPC.execute_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	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.beginFileDownload_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	DistributedRPCInvocations.result_result.set_aze(AuthorizationException aze)
void	DistributedRPCInvocations.fetchRequest_result.set_aze(AuthorizationException aze)
void	DistributedRPCInvocations.failRequest_result.set_aze(AuthorizationException aze)
void	DistributedRPC.execute_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.beginFileDownload(String file)
String	Nimbus.Client.beginFileDownload(String file)
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)
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()
String	Nimbus.Iface.getNimbusConf()
String	Nimbus.Client.getNimbusConf()
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()
int	Nimbus.AsyncClient.getBlobReplication_call.getResult()
int	Nimbus.AsyncClient.updateBlobReplication_call.getResult()
String	Nimbus.AsyncClient.beginFileUpload_call.getResult()
void	Nimbus.AsyncClient.uploadChunk_call.getResult()
void	Nimbus.AsyncClient.finishFileUpload_call.getResult()
String	Nimbus.AsyncClient.beginFileDownload_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()
void	DistributedRPCInvocations.AsyncClient.result_call.getResult()
DRPCRequest	DistributedRPCInvocations.AsyncClient.fetchRequest_call.getResult()
void	DistributedRPCInvocations.AsyncClient.failRequest_call.getResult()
String	DistributedRPC.AsyncClient.execute_call.getResult()
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.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_beginFileDownload()
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()
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()
String	Nimbus.Client.recv_getNimbusConf()
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_isTopologyNameAllowed()
void	Nimbus.Client.recv_killTopology()
void	Nimbus.Client.recv_killTopologyWithOpts()
void	Nimbus.Client.recv_rebalance()
void	DistributedRPCInvocations.Client.recv_result()
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	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)
beginFileDownload_result(String success, AuthorizationException aze)
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)
downloadBlobChunk_result(ByteBuffer success, AuthorizationException aze)
downloadChunk_result(ByteBuffer success, AuthorizationException aze)
execute_result(String success, DRPCExecutionException e, AuthorizationException aze)
failRequest_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)
getNimbusConf_result(String success, AuthorizationException aze)
getSupervisorPageInfo_result(SupervisorPageInfo success, NotAliveException e, AuthorizationException aze)
getTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
getTopologyConf_result(String success, NotAliveException e, AuthorizationException aze)
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)
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)
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
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)
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	TridentKafkaClientWordCountNamedTopics.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
LocalizedResource	Localizer.getBlob(LocalResource localResource, String user, String topo, File userFileDir) This function either returns the blob in the existing cache or if it doesn’t exist in the cache, it will download the blob and will block until the download is complete.
List<LocalizedResource>	Localizer.getBlobs(List<LocalResource> localResources, String user, String topo, File userFileDir) This function either returns the blobs in the existing cache or if they don’t exist in the cache, it downloads them in parallel (up to SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT) and will block until all of them have been downloaded
protected boolean	Localizer.isLocalizedResourceUpToDate(LocalizedResource lrsrc, ClientBlobStore blobstore)
void	Localizer.removeBlobReference(String key, String user, String topo, boolean uncompress)
List<LocalizedResource>	Localizer.updateBlobs(List<LocalResource> localResources, String user) This function updates blobs on the supervisor.

Uses of AuthorizationException in org.apache.storm.starter.util

Methods in org.apache.storm.starter.util that throw AuthorizationException

Modifier and Type	Method and Description
static void	StormRunner.runTopologyRemotely(StormTopology topology, String topologyName, Config conf)

Uses of AuthorizationException in org.apache.storm.utils

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

Modifier and Type	Method and Description
static void	Utils.downloadResourcesAsSupervisor(String key, String localFile, ClientBlobStore cb) Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
void	Utils.downloadResourcesAsSupervisorImpl(String key, String localFile, ClientBlobStore cb)
String	DRPCClient.execute(String func, String args)
static long	Utils.nimbusVersionOfBlob(String key, ClientBlobStore cb)