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 Summary
Nested Classes -
Field Summary
Fields inherited from class org.apache.storm.thrift.TServiceClient
iprot_, oprot_, seqid_ -
Constructor Summary
Constructors -
Method Summary
Modifier 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.TServiceClient
getInputProtocol, getOutputProtocol, receiveBase, sendBase, sendBaseOneway
-
Constructor Details
-
Client
public Client(org.apache.storm.thrift.protocol.TProtocol prot) -
Client
public Client(org.apache.storm.thrift.protocol.TProtocol iprot, org.apache.storm.thrift.protocol.TProtocol oprot)
-
-
Method Details
-
submitTopology
public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
submitTopologyin interfaceNimbus.Iface- Throws:
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_submitTopology
public void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_submitTopology
public void recv_submitTopology() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
submitTopologyWithOpts
public void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
submitTopologyWithOptsin interfaceNimbus.Iface- Throws:
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_submitTopologyWithOpts
public 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_submitTopologyWithOpts
public void recv_submitTopologyWithOpts() throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
killTopology
public void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
killTopologyin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_killTopology
- Throws:
org.apache.storm.thrift.TException
-
recv_killTopology
public void recv_killTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
killTopologyWithOpts
public void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
killTopologyWithOptsin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_killTopologyWithOpts
public void send_killTopologyWithOpts(String name, KillOptions options) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_killTopologyWithOpts
public void recv_killTopologyWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
activate
public void activate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
activatein interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_activate
- Throws:
org.apache.storm.thrift.TException
-
recv_activate
public void recv_activate() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
deactivate
public void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
deactivatein interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_deactivate
- Throws:
org.apache.storm.thrift.TException
-
recv_deactivate
public void recv_deactivate() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
rebalance
public void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
rebalancein interfaceNimbus.Iface- Throws:
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_rebalance
public void send_rebalance(String name, RebalanceOptions options) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_rebalance
public void recv_rebalance() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
setLogConfig
- Specified by:
setLogConfigin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_setLogConfig
public void send_setLogConfig(String name, LogConfig config) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_setLogConfig
public void recv_setLogConfig() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
getLogConfig
- Specified by:
getLogConfigin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_getLogConfig
- Throws:
org.apache.storm.thrift.TException
-
recv_getLogConfig
- Throws:
org.apache.storm.thrift.TException
-
debug
public 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 interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_debug
public void send_debug(String name, String component, boolean enable, double samplingPercentage) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_debug
public void recv_debug() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
setWorkerProfiler
public void setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException - Specified by:
setWorkerProfilerin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_setWorkerProfiler
public void send_setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_setWorkerProfiler
public void recv_setWorkerProfiler() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
getComponentPendingProfileActions
public List<ProfileRequest> getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException - Specified by:
getComponentPendingProfileActionsin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_getComponentPendingProfileActions
public void send_getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_getComponentPendingProfileActions
public List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
uploadNewCredentials
public void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
uploadNewCredentialsin interfaceNimbus.Iface- Throws:
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_uploadNewCredentials
public void send_uploadNewCredentials(String name, Credentials creds) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_uploadNewCredentials
public void recv_uploadNewCredentials() throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
beginCreateBlob
public String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException - Specified by:
beginCreateBlobin interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyAlreadyExistsExceptionorg.apache.storm.thrift.TException
-
send_beginCreateBlob
public void send_beginCreateBlob(String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_beginCreateBlob
public String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyAlreadyExistsExceptionorg.apache.storm.thrift.TException
-
beginUpdateBlob
public String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
beginUpdateBlobin interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
send_beginUpdateBlob
- Throws:
org.apache.storm.thrift.TException
-
recv_beginUpdateBlob
public String recv_beginUpdateBlob() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
uploadBlobChunk
public void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
uploadBlobChunkin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_uploadBlobChunk
public void send_uploadBlobChunk(String session, ByteBuffer chunk) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_uploadBlobChunk
public void recv_uploadBlobChunk() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
finishBlobUpload
public void finishBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
finishBlobUploadin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_finishBlobUpload
- Throws:
org.apache.storm.thrift.TException
-
recv_finishBlobUpload
public void recv_finishBlobUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
cancelBlobUpload
public void cancelBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
cancelBlobUploadin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_cancelBlobUpload
- Throws:
org.apache.storm.thrift.TException
-
recv_cancelBlobUpload
public void recv_cancelBlobUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getBlobMeta
public ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
getBlobMetain interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
send_getBlobMeta
- Throws:
org.apache.storm.thrift.TException
-
recv_getBlobMeta
public ReadableBlobMeta recv_getBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
setBlobMeta
public void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
setBlobMetain interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
send_setBlobMeta
public void send_setBlobMeta(String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_setBlobMeta
public void recv_setBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
beginBlobDownload
public BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
beginBlobDownloadin interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
send_beginBlobDownload
- Throws:
org.apache.storm.thrift.TException
-
recv_beginBlobDownload
public BeginDownloadResult recv_beginBlobDownload() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
downloadBlobChunk
public ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
downloadBlobChunkin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_downloadBlobChunk
- Throws:
org.apache.storm.thrift.TException
-
recv_downloadBlobChunk
public ByteBuffer recv_downloadBlobChunk() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
deleteBlob
public void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException - Specified by:
deleteBlobin interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyNotFoundExceptionIllegalStateExceptionorg.apache.storm.thrift.TException
-
send_deleteBlob
- Throws:
org.apache.storm.thrift.TException
-
recv_deleteBlob
public void recv_deleteBlob() throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyNotFoundExceptionIllegalStateExceptionorg.apache.storm.thrift.TException
-
listBlobs
- Specified by:
listBlobsin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_listBlobs
- Throws:
org.apache.storm.thrift.TException
-
recv_listBlobs
- Throws:
org.apache.storm.thrift.TException
-
getBlobReplication
public int getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
getBlobReplicationin interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
send_getBlobReplication
- Throws:
org.apache.storm.thrift.TException
-
recv_getBlobReplication
public int recv_getBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
updateBlobReplication
public int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException - Specified by:
updateBlobReplicationin interfaceNimbus.Iface- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
send_updateBlobReplication
public void send_updateBlobReplication(String key, int replication) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_updateBlobReplication
public int recv_updateBlobReplication() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TException
-
createStateInZookeeper
- Specified by:
createStateInZookeeperin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_createStateInZookeeper
- Throws:
org.apache.storm.thrift.TException
-
recv_createStateInZookeeper
public void recv_createStateInZookeeper() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
beginFileUpload
- Specified by:
beginFileUploadin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_beginFileUpload
public void send_beginFileUpload() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
recv_beginFileUpload
public String recv_beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
uploadChunk
public void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
uploadChunkin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_uploadChunk
public void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_uploadChunk
- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
finishFileUpload
public void finishFileUpload(String location) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
finishFileUploadin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_finishFileUpload
- Throws:
org.apache.storm.thrift.TException
-
recv_finishFileUpload
public void recv_finishFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
downloadChunk
public ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
downloadChunkin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_downloadChunk
- Throws:
org.apache.storm.thrift.TException
-
recv_downloadChunk
public ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getNimbusConf
- Specified by:
getNimbusConfin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getNimbusConf
public void send_getNimbusConf() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
recv_getNimbusConf
public String recv_getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getClusterInfo
public ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException- Specified by:
getClusterInfoin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getClusterInfo
public void send_getClusterInfo() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
recv_getClusterInfo
public ClusterSummary recv_getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologySummaries
public List<TopologySummary> getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Specified by:
getTopologySummariesin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologySummaries
public void send_getTopologySummaries() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
recv_getTopologySummaries
public List<TopologySummary> recv_getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologySummaryByName
public TopologySummary getTopologySummaryByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologySummaryByNamein interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologySummaryByName
- Throws:
org.apache.storm.thrift.TException
-
recv_getTopologySummaryByName
public TopologySummary recv_getTopologySummaryByName() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologySummary
public TopologySummary getTopologySummary(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologySummaryin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologySummary
- Throws:
org.apache.storm.thrift.TException
-
recv_getTopologySummary
public TopologySummary recv_getTopologySummary() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getLeader
- Specified by:
getLeaderin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getLeader
public void send_getLeader() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
recv_getLeader
public NimbusSummary recv_getLeader() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
isTopologyNameAllowed
public boolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
isTopologyNameAllowedin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_isTopologyNameAllowed
- Throws:
org.apache.storm.thrift.TException
-
recv_isTopologyNameAllowed
public boolean recv_isTopologyNameAllowed() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfoByName
public TopologyInfo getTopologyInfoByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologyInfoByNamein interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologyInfoByName
- Throws:
org.apache.storm.thrift.TException
-
recv_getTopologyInfoByName
public TopologyInfo recv_getTopologyInfoByName() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfo
public TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologyInfoin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologyInfo
- Throws:
org.apache.storm.thrift.TException
-
recv_getTopologyInfo
public TopologyInfo recv_getTopologyInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfoByNameWithOpts
public TopologyInfo getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologyInfoByNameWithOptsin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologyInfoByNameWithOpts
public void send_getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_getTopologyInfoByNameWithOpts
public TopologyInfo recv_getTopologyInfoByNameWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyInfoWithOpts
public TopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologyInfoWithOptsin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologyInfoWithOpts
public void send_getTopologyInfoWithOpts(String id, GetInfoOptions options) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_getTopologyInfoWithOpts
public TopologyInfo recv_getTopologyInfoWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyPageInfo
public TopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologyPageInfoin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologyPageInfo
public void send_getTopologyPageInfo(String id, String window, boolean is_include_sys) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_getTopologyPageInfo
public TopologyPageInfo recv_getTopologyPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getSupervisorPageInfo
public SupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getSupervisorPageInfoin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getSupervisorPageInfo
public void send_getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_getSupervisorPageInfo
public SupervisorPageInfo recv_getSupervisorPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getComponentPageInfo
public 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 interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getComponentPageInfo
public 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_getComponentPageInfo
public ComponentPageInfo recv_getComponentPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyConf
public String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologyConfin interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologyConf
- Throws:
org.apache.storm.thrift.TException
-
recv_getTopologyConf
public String recv_getTopologyConf() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopology
public 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 interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopology
- Throws:
org.apache.storm.thrift.TException
-
recv_getTopology
public StormTopology recv_getTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getUserTopology
public 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 interfaceNimbus.Iface- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getUserTopology
- Throws:
org.apache.storm.thrift.TException
-
recv_getUserTopology
public StormTopology recv_getUserTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException- Throws:
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TException
-
getTopologyHistory
public TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getTopologyHistoryin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getTopologyHistory
- Throws:
org.apache.storm.thrift.TException
-
recv_getTopologyHistory
public TopologyHistoryInfo recv_getTopologyHistory() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getOwnerResourceSummaries
public List<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.storm.thrift.TException - Specified by:
getOwnerResourceSummariesin interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getOwnerResourceSummaries
- Throws:
org.apache.storm.thrift.TException
-
recv_getOwnerResourceSummaries
public List<OwnerResourceSummary> recv_getOwnerResourceSummaries() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
getSupervisorAssignments
public 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 interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_getSupervisorAssignments
- Throws:
org.apache.storm.thrift.TException
-
recv_getSupervisorAssignments
public SupervisorAssignments recv_getSupervisorAssignments() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeats
public 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 interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_sendSupervisorWorkerHeartbeats
public void send_sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_sendSupervisorWorkerHeartbeats
public void recv_sendSupervisorWorkerHeartbeats() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
sendSupervisorWorkerHeartbeat
public 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 interfaceNimbus.Iface- Throws:
AuthorizationExceptionNotAliveExceptionorg.apache.storm.thrift.TException
-
send_sendSupervisorWorkerHeartbeat
public void send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_sendSupervisorWorkerHeartbeat
public void recv_sendSupervisorWorkerHeartbeat() throws AuthorizationException, NotAliveException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionNotAliveExceptionorg.apache.storm.thrift.TException
-
processWorkerMetrics
- Specified by:
processWorkerMetricsin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_processWorkerMetrics
public void send_processWorkerMetrics(WorkerMetrics metrics) throws org.apache.storm.thrift.TException - Throws:
org.apache.storm.thrift.TException
-
recv_processWorkerMetrics
public void recv_processWorkerMetrics() throws org.apache.storm.thrift.TException- Throws:
org.apache.storm.thrift.TException
-
isRemoteBlobExists
public 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 interfaceNimbus.Iface- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-
send_isRemoteBlobExists
- Throws:
org.apache.storm.thrift.TException
-
recv_isRemoteBlobExists
public boolean recv_isRemoteBlobExists() throws AuthorizationException, org.apache.storm.thrift.TException- Throws:
AuthorizationExceptionorg.apache.storm.thrift.TException
-