Uses of Class
backtype.storm.generated.AuthorizationException

Packages that use AuthorizationException

Package	Description
backtype.storm
backtype.storm.drpc
backtype.storm.generated
backtype.storm.utils

Uses of AuthorizationException in backtype.storm

Methods in backtype.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)
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 backtype.storm.drpc

Methods in backtype.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 backtype.storm.generated

Methods in backtype.storm.generated that return AuthorizationException

Modifier and Type	Method and Description
AuthorizationException	AuthorizationException.deepCopy()
AuthorizationException	DistributedRPCInvocations.result_result.get_aze()
AuthorizationException	DistributedRPCInvocations.fetchRequest_result.get_aze()
AuthorizationException	DistributedRPCInvocations.failRequest_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.uploadNewCredentials_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.getTopologyInfo_result.get_aze()
AuthorizationException	Nimbus.getTopologyInfoWithOpts_result.get_aze()
AuthorizationException	Nimbus.getTopologyConf_result.get_aze()
AuthorizationException	Nimbus.getTopology_result.get_aze()
AuthorizationException	Nimbus.getUserTopology_result.get_aze()
AuthorizationException	DistributedRPC.execute_result.get_aze()

Methods in backtype.storm.generated with parameters of type AuthorizationException

Modifier and Type	Method and Description
int	AuthorizationException.compareTo(AuthorizationException other)
boolean	AuthorizationException.equals(AuthorizationException that)
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	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.uploadNewCredentials_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.getTopologyInfo_result.set_aze(AuthorizationException aze)
void	Nimbus.getTopologyInfoWithOpts_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	DistributedRPC.execute_result.set_aze(AuthorizationException aze)

Methods in backtype.storm.generated that throw AuthorizationException

Modifier and Type	Method and Description
void	Nimbus.Iface.activate(String name)
void	Nimbus.Client.activate(String name)
String	Nimbus.Iface.beginFileDownload(String file)
String	Nimbus.Client.beginFileDownload(String file)
String	Nimbus.Iface.beginFileUpload()
String	Nimbus.Client.beginFileUpload()
void	Nimbus.Iface.deactivate(String name)
void	Nimbus.Client.deactivate(String name)
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.finishFileUpload(String location)
void	Nimbus.Client.finishFileUpload(String location)
ClusterSummary	Nimbus.Iface.getClusterInfo()
ClusterSummary	Nimbus.Client.getClusterInfo()
String	Nimbus.Iface.getNimbusConf()
String	Nimbus.Client.getNimbusConf()
void	DistributedRPCInvocations.AsyncClient.result_call.getResult()
DRPCRequest	DistributedRPCInvocations.AsyncClient.fetchRequest_call.getResult()
void	DistributedRPCInvocations.AsyncClient.failRequest_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.uploadNewCredentials_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()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfo_call.getResult()
TopologyInfo	Nimbus.AsyncClient.getTopologyInfoWithOpts_call.getResult()
String	Nimbus.AsyncClient.getTopologyConf_call.getResult()
StormTopology	Nimbus.AsyncClient.getTopology_call.getResult()
StormTopology	Nimbus.AsyncClient.getUserTopology_call.getResult()
String	DistributedRPC.AsyncClient.execute_call.getResult()
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)
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)
StormTopology	Nimbus.Iface.getUserTopology(String id) Returns the user specified topology as submitted originally.
StormTopology	Nimbus.Client.getUserTopology(String id)
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()
String	Nimbus.Client.recv_beginFileDownload()
String	Nimbus.Client.recv_beginFileUpload()
void	Nimbus.Client.recv_deactivate()
ByteBuffer	Nimbus.Client.recv_downloadChunk()
String	DistributedRPC.Client.recv_execute()
void	DistributedRPCInvocations.Client.recv_failRequest()
DRPCRequest	DistributedRPCInvocations.Client.recv_fetchRequest()
void	Nimbus.Client.recv_finishFileUpload()
ClusterSummary	Nimbus.Client.recv_getClusterInfo()
String	Nimbus.Client.recv_getNimbusConf()
StormTopology	Nimbus.Client.recv_getTopology()
String	Nimbus.Client.recv_getTopologyConf()
TopologyInfo	Nimbus.Client.recv_getTopologyInfo()
TopologyInfo	Nimbus.Client.recv_getTopologyInfoWithOpts()
StormTopology	Nimbus.Client.recv_getUserTopology()
void	Nimbus.Client.recv_killTopology()
void	Nimbus.Client.recv_killTopologyWithOpts()
void	Nimbus.Client.recv_rebalance()
void	DistributedRPCInvocations.Client.recv_result()
void	Nimbus.Client.recv_submitTopology()
void	Nimbus.Client.recv_submitTopologyWithOpts()
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.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)
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 backtype.storm.generated with parameters of type AuthorizationException

Constructor and Description
AuthorizationException(AuthorizationException other) Performs a deep copy on other.
DistributedRPC.execute_result(String success, DRPCExecutionException e, AuthorizationException aze)
DistributedRPCInvocations.failRequest_result(AuthorizationException aze)
DistributedRPCInvocations.fetchRequest_result(DRPCRequest success, AuthorizationException aze)
DistributedRPCInvocations.result_result(AuthorizationException aze)
Nimbus.activate_result(NotAliveException e, AuthorizationException aze)
Nimbus.beginFileDownload_result(String success, AuthorizationException aze)
Nimbus.beginFileUpload_result(String success, AuthorizationException aze)
Nimbus.deactivate_result(NotAliveException e, AuthorizationException aze)
Nimbus.downloadChunk_result(ByteBuffer success, AuthorizationException aze)
Nimbus.finishFileUpload_result(AuthorizationException aze)
Nimbus.getClusterInfo_result(ClusterSummary success, AuthorizationException aze)
Nimbus.getNimbusConf_result(String success, AuthorizationException aze)
Nimbus.getTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
Nimbus.getTopologyConf_result(String success, NotAliveException e, AuthorizationException aze)
Nimbus.getTopologyInfo_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
Nimbus.getTopologyInfoWithOpts_result(TopologyInfo success, NotAliveException e, AuthorizationException aze)
Nimbus.getUserTopology_result(StormTopology success, NotAliveException e, AuthorizationException aze)
Nimbus.killTopology_result(NotAliveException e, AuthorizationException aze)
Nimbus.killTopologyWithOpts_result(NotAliveException e, AuthorizationException aze)
Nimbus.rebalance_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)
Nimbus.submitTopology_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)
Nimbus.submitTopologyWithOpts_result(AlreadyAliveException e, InvalidTopologyException ite, AuthorizationException aze)
Nimbus.uploadChunk_result(AuthorizationException aze)
Nimbus.uploadNewCredentials_result(NotAliveException e, InvalidTopologyException ite, AuthorizationException aze)

Uses of AuthorizationException in backtype.storm.utils

Methods in backtype.storm.utils that throw AuthorizationException

Modifier and Type	Method and Description
static void	Utils.downloadFromMaster(Map conf, String file, String localFile)
String	DRPCClient.execute(String func, String args)