Package org.apache.storm.generated
Class Nimbus.Client
java.lang.Object
org.apache.storm.thrift.TServiceClient
org.apache.storm.generated.Nimbus.Client
- All Implemented Interfaces:
- Nimbus.Iface
- Enclosing class:
- Nimbus
public static class Nimbus.Client
extends org.apache.storm.thrift.TServiceClient
implements Nimbus.Iface
- 
Nested Class SummaryNested Classes
- 
Field SummaryFields inherited from class org.apache.storm.thrift.TServiceClientiprot_, oprot_, seqid_
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoidbeginBlobDownload(String key) beginCreateBlob(String key, SettableBlobMeta meta) beginUpdateBlob(String key) voidcancelBlobUpload(String session) voidvoiddeactivate(String name) voidEnable/disable logging the tuples generated in topology via an internal EventLogger bolt.voiddeleteBlob(String key) downloadBlobChunk(String session) downloadChunk(String id) voidfinishBlobUpload(String session) voidfinishFileUpload(String location) getBlobMeta(String key) intgetBlobReplication(String key) getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) getComponentPendingProfileActions(String id, String component_id, ProfileAction action) getLogConfig(String name) getOwnerResourceSummaries(String owner) Get assigned assignments for a specific supervisorgetSupervisorPageInfo(String id, String host, boolean is_include_sys) getTopology(String id) Returns the compiled topology that contains ackers and metrics consumsers.getTopologyHistory(String user) getTopologyInfoByName(String name) getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) getTopologyInfoWithOpts(String id, GetInfoOptions options) getTopologyPageInfo(String id, String window, boolean is_include_sys) Returns the user specified topology as submitted originally.booleanisRemoteBlobExists(String blobKey) Decide if the blob is removed from cluster.booleanisTopologyNameAllowed(String name) voidkillTopology(String name) voidkillTopologyWithOpts(String name, KillOptions options) voidprocessWorkerMetrics(WorkerMetrics metrics) voidrebalance(String name, RebalanceOptions options) voidvoidvoidvoidvoidvoidvoidvoidintbooleanbooleanvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidvoidintvoidvoidvoidvoidsend_activate(String name) voidvoidsend_beginCreateBlob(String key, SettableBlobMeta meta) voidvoidvoidsend_cancelBlobUpload(String session) voidvoidsend_deactivate(String name) voidsend_debug(String name, String component, boolean enable, double samplingPercentage) voidsend_deleteBlob(String key) voidsend_downloadBlobChunk(String session) voidvoidsend_finishBlobUpload(String session) voidsend_finishFileUpload(String location) voidsend_getBlobMeta(String key) voidvoidvoidsend_getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) voidsend_getComponentPendingProfileActions(String id, String component_id, ProfileAction action) voidvoidsend_getLogConfig(String name) voidvoidvoidvoidsend_getSupervisorPageInfo(String id, String host, boolean is_include_sys) voidvoidvoidvoidvoidvoidsend_getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) voidsend_getTopologyInfoWithOpts(String id, GetInfoOptions options) voidsend_getTopologyPageInfo(String id, String window, boolean is_include_sys) voidvoidvoidvoidvoidsend_isRemoteBlobExists(String blobKey) voidvoidsend_killTopology(String name) voidsend_killTopologyWithOpts(String name, KillOptions options) voidsend_listBlobs(String session) voidsend_processWorkerMetrics(WorkerMetrics metrics) voidsend_rebalance(String name, RebalanceOptions options) voidvoidvoidsend_setBlobMeta(String key, SettableBlobMeta meta) voidsend_setLogConfig(String name, LogConfig config) voidsend_setWorkerProfiler(String id, ProfileRequest profileRequest) voidsend_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) voidsend_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) voidsend_updateBlobReplication(String key, int replication) voidsend_uploadBlobChunk(String session, ByteBuffer chunk) voidsend_uploadChunk(String location, ByteBuffer chunk) voidsend_uploadNewCredentials(String name, Credentials creds) voidSend supervisor local worker heartbeat when a supervisor is unreachablevoidSend supervisor worker heartbeats for a specific supervisorvoidsetBlobMeta(String key, SettableBlobMeta meta) voidsetLogConfig(String name, LogConfig config) voidsetWorkerProfiler(String id, ProfileRequest profileRequest) voidsubmitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) voidsubmitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) intupdateBlobReplication(String key, int replication) voiduploadBlobChunk(String session, ByteBuffer chunk) voiduploadChunk(String location, ByteBuffer chunk) voiduploadNewCredentials(String name, Credentials creds) Methods inherited from class org.apache.storm.thrift.TServiceClientgetInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway
- 
Constructor Details- 
Clientpublic Client(org.apache.storm.thrift.protocol.TProtocol prot) 
- 
Clientpublic Client(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TProtocol oprot) 
 
- 
- 
Method Details- 
submitTopologypublic void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- submitTopologyin interface- Nimbus.Iface
- Throws:
- AlreadyAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_submitTopologypublic void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_submitTopologypublic void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AlreadyAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
submitTopologyWithOptspublic void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- submitTopologyWithOptsin interface- Nimbus.Iface
- Throws:
- AlreadyAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_submitTopologyWithOptspublic void send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_submitTopologyWithOptspublic void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AlreadyAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
killTopologypublic void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- killTopologyin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_killTopology- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_killTopologypublic void recv_killTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
killTopologyWithOptspublic void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- killTopologyWithOptsin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_killTopologyWithOptspublic void send_killTopologyWithOpts(String name, KillOptions options) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_killTopologyWithOptspublic void recv_killTopologyWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
activatepublic void activate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- activatein interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_activate- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_activatepublic void recv_activate() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
deactivatepublic void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- deactivatein interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_deactivate- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_deactivatepublic void recv_deactivate() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
rebalancepublic void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- rebalancein interface- Nimbus.Iface
- Throws:
- NotAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_rebalancepublic void send_rebalance(String name, RebalanceOptions options) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_rebalancepublic void recv_rebalance() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
setLogConfig- Specified by:
- setLogConfigin interface- Nimbus.Iface
- Throws:
- org.apache.storm.thrift.TException
 
- 
send_setLogConfigpublic void send_setLogConfig(String name, LogConfig config) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_setLogConfigpublic void recv_setLogConfig() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
getLogConfig- Specified by:
- getLogConfigin interface- Nimbus.Iface
- Throws:
- org.apache.storm.thrift.TException
 
- 
send_getLogConfig- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getLogConfig- Throws:
- org.apache.storm.thrift.TException
 
- 
debugpublic void debug(String name, String component, boolean enable, double samplingPercentage) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Nimbus.IfaceEnable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional and if null or empty, the debug flag will apply to the entire topology. The 'samplingPercentage' will limit loggging to a percentage of generated tuples.- Specified by:
- debugin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_debugpublic void send_debug(String name, String component, boolean enable, double samplingPercentage) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_debugpublic void recv_debug() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
setWorkerProfilerpublic void setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException - Specified by:
- setWorkerProfilerin interface- Nimbus.Iface
- Throws:
- org.apache.storm.thrift.TException
 
- 
send_setWorkerProfilerpublic void send_setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_setWorkerProfilerpublic void recv_setWorkerProfiler() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
getComponentPendingProfileActionspublic List<ProfileRequest> getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException - Specified by:
- getComponentPendingProfileActionsin interface- Nimbus.Iface
- Throws:
- org.apache.storm.thrift.TException
 
- 
send_getComponentPendingProfileActionspublic void send_getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getComponentPendingProfileActionspublic List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
uploadNewCredentialspublic void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- uploadNewCredentialsin interface- Nimbus.Iface
- Throws:
- NotAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_uploadNewCredentialspublic void send_uploadNewCredentials(String name, Credentials creds) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_uploadNewCredentialspublic void recv_uploadNewCredentials() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- InvalidTopologyException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
beginCreateBlobpublic String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException - Specified by:
- beginCreateBlobin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyAlreadyExistsException
- org.apache.storm.thrift.TException
 
- 
send_beginCreateBlobpublic void send_beginCreateBlob(String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_beginCreateBlobpublic String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyAlreadyExistsException
- org.apache.storm.thrift.TException
 
- 
beginUpdateBlobpublic String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
- beginUpdateBlobin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
send_beginUpdateBlob- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_beginUpdateBlobpublic String recv_beginUpdateBlob() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
uploadBlobChunkpublic void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- uploadBlobChunkin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_uploadBlobChunkpublic void send_uploadBlobChunk(String session, ByteBuffer chunk) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_uploadBlobChunkpublic void recv_uploadBlobChunk() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
finishBlobUploadpublic void finishBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- finishBlobUploadin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_finishBlobUpload- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_finishBlobUploadpublic void recv_finishBlobUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
cancelBlobUploadpublic void cancelBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- cancelBlobUploadin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_cancelBlobUpload- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_cancelBlobUploadpublic void recv_cancelBlobUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getBlobMetapublic ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
- getBlobMetain interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
send_getBlobMeta- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getBlobMetapublic ReadableBlobMeta recv_getBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
setBlobMetapublic void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
- setBlobMetain interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
send_setBlobMetapublic void send_setBlobMeta(String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_setBlobMetapublic void recv_setBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
beginBlobDownloadpublic BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
- beginBlobDownloadin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
send_beginBlobDownload- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_beginBlobDownloadpublic BeginDownloadResult recv_beginBlobDownload() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
downloadBlobChunkpublic ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- downloadBlobChunkin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_downloadBlobChunk- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_downloadBlobChunkpublic ByteBuffer recv_downloadBlobChunk() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
deleteBlobpublic void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException - Specified by:
- deleteBlobin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyNotFoundException
- IllegalStateException
- org.apache.storm.thrift.TException
 
- 
send_deleteBlob- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_deleteBlobpublic void recv_deleteBlob() throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyNotFoundException
- IllegalStateException
- org.apache.storm.thrift.TException
 
- 
listBlobs- Specified by:
- listBlobsin interface- Nimbus.Iface
- Throws:
- org.apache.storm.thrift.TException
 
- 
send_listBlobs- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_listBlobs- Throws:
- org.apache.storm.thrift.TException
 
- 
getBlobReplicationpublic int getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
- getBlobReplicationin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
send_getBlobReplication- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getBlobReplicationpublic int recv_getBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
updateBlobReplicationpublic int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
- updateBlobReplicationin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
send_updateBlobReplicationpublic void send_updateBlobReplication(String key, int replication) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_updateBlobReplicationpublic int recv_updateBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- KeyNotFoundException
- org.apache.storm.thrift.TException
 
- 
createStateInZookeeper- Specified by:
- createStateInZookeeperin interface- Nimbus.Iface
- Throws:
- org.apache.storm.thrift.TException
 
- 
send_createStateInZookeeper- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_createStateInZookeeperpublic void recv_createStateInZookeeper() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
beginFileUpload- Specified by:
- beginFileUploadin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_beginFileUploadpublic void send_beginFileUpload() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_beginFileUploadpublic String recv_beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
uploadChunkpublic void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- uploadChunkin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_uploadChunkpublic void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_uploadChunk- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
finishFileUploadpublic void finishFileUpload(String location) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- finishFileUploadin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_finishFileUpload- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_finishFileUploadpublic void recv_finishFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
downloadChunkpublic ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- downloadChunkin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_downloadChunk- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_downloadChunkpublic ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getNimbusConf- Specified by:
- getNimbusConfin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getNimbusConfpublic void send_getNimbusConf() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getNimbusConfpublic String recv_getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getClusterInfopublic ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException- Specified by:
- getClusterInfoin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getClusterInfopublic void send_getClusterInfo() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getClusterInfopublic ClusterSummary recv_getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologySummariespublic List<TopologySummary> getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Specified by:
- getTopologySummariesin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologySummariespublic void send_getTopologySummaries() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologySummariespublic List<TopologySummary> recv_getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologySummaryByNamepublic TopologySummary getTopologySummaryByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologySummaryByNamein interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologySummaryByName- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologySummaryByNamepublic TopologySummary recv_getTopologySummaryByName() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologySummarypublic TopologySummary getTopologySummary(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologySummaryin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologySummary- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologySummarypublic TopologySummary recv_getTopologySummary() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getLeader- Specified by:
- getLeaderin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getLeaderpublic void send_getLeader() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getLeaderpublic NimbusSummary recv_getLeader() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
isTopologyNameAllowedpublic boolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- isTopologyNameAllowedin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_isTopologyNameAllowed- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_isTopologyNameAllowedpublic boolean recv_isTopologyNameAllowed() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoByNamepublic TopologyInfo getTopologyInfoByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoByNamein interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologyInfoByName- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologyInfoByNamepublic TopologyInfo recv_getTopologyInfoByName() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologyInfopublic TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologyInfo- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologyInfopublic TopologyInfo recv_getTopologyInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoByNameWithOptspublic TopologyInfo getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoByNameWithOptsin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologyInfoByNameWithOptspublic void send_getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologyInfoByNameWithOptspublic TopologyInfo recv_getTopologyInfoByNameWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologyInfoWithOptspublic TopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologyInfoWithOptsin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologyInfoWithOptspublic void send_getTopologyInfoWithOpts(String id, GetInfoOptions options) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologyInfoWithOptspublic TopologyInfo recv_getTopologyInfoWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologyPageInfopublic TopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologyPageInfoin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologyPageInfopublic void send_getTopologyPageInfo(String id, String window, boolean is_include_sys) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologyPageInfopublic TopologyPageInfo recv_getTopologyPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getSupervisorPageInfopublic SupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getSupervisorPageInfoin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getSupervisorPageInfopublic void send_getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getSupervisorPageInfopublic SupervisorPageInfo recv_getSupervisorPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getComponentPageInfopublic ComponentPageInfo getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getComponentPageInfoin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getComponentPageInfopublic void send_getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getComponentPageInfopublic ComponentPageInfo recv_getComponentPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologyConfpublic String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologyConfin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologyConf- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologyConfpublic String recv_getTopologyConf() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologypublic StormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Nimbus.IfaceReturns the compiled topology that contains ackers and metrics consumsers. CompareNimbus.Iface.getUserTopology(String id).- Specified by:
- getTopologyin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopology- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologypublic StormTopology recv_getTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getUserTopologypublic StormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Nimbus.IfaceReturns the user specified topology as submitted originally. CompareNimbus.Iface.getTopology(String id).- Specified by:
- getUserTopologyin interface- Nimbus.Iface
- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getUserTopology- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getUserTopologypublic StormTopology recv_getUserTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
- NotAliveException
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getTopologyHistorypublic TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getTopologyHistoryin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getTopologyHistory- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getTopologyHistorypublic TopologyHistoryInfo recv_getTopologyHistory() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getOwnerResourceSummariespublic List<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
- getOwnerResourceSummariesin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getOwnerResourceSummaries- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getOwnerResourceSummariespublic List<OwnerResourceSummary> recv_getOwnerResourceSummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
getSupervisorAssignmentspublic SupervisorAssignments getSupervisorAssignments(String node) throws AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Nimbus.IfaceGet assigned assignments for a specific supervisor- Specified by:
- getSupervisorAssignmentsin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_getSupervisorAssignments- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_getSupervisorAssignmentspublic SupervisorAssignments recv_getSupervisorAssignments() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
sendSupervisorWorkerHeartbeatspublic void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Nimbus.IfaceSend supervisor worker heartbeats for a specific supervisor- Specified by:
- sendSupervisorWorkerHeartbeatsin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_sendSupervisorWorkerHeartbeatspublic void send_sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_sendSupervisorWorkerHeartbeatspublic void recv_sendSupervisorWorkerHeartbeats() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
sendSupervisorWorkerHeartbeatpublic void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.storm.thrift.TException Description copied from interface:Nimbus.IfaceSend supervisor local worker heartbeat when a supervisor is unreachable- Specified by:
- sendSupervisorWorkerHeartbeatin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- NotAliveException
- org.apache.storm.thrift.TException
 
- 
send_sendSupervisorWorkerHeartbeatpublic void send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_sendSupervisorWorkerHeartbeatpublic void recv_sendSupervisorWorkerHeartbeat() throws AuthorizationException, NotAliveException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- NotAliveException
- org.apache.storm.thrift.TException
 
- 
processWorkerMetrics- Specified by:
- processWorkerMetricsin interface- Nimbus.Iface
- Throws:
- org.apache.storm.thrift.TException
 
- 
send_processWorkerMetricspublic void send_processWorkerMetrics(WorkerMetrics metrics) throws org.apache.storm.thrift.TException - Throws:
- org.apache.storm.thrift.TException
 
- 
recv_processWorkerMetricspublic void recv_processWorkerMetrics() throws org.apache.storm.thrift.TException- Throws:
- org.apache.storm.thrift.TException
 
- 
isRemoteBlobExistspublic boolean isRemoteBlobExists(String blobKey) throws AuthorizationException, org.apache.storm.thrift.TException Description copied from interface:Nimbus.IfaceDecide if the blob is removed from cluster.- Specified by:
- isRemoteBlobExistsin interface- Nimbus.Iface
- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
- 
send_isRemoteBlobExists- Throws:
- org.apache.storm.thrift.TException
 
- 
recv_isRemoteBlobExistspublic boolean recv_isRemoteBlobExists() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
- AuthorizationException
- org.apache.storm.thrift.TException
 
 
-