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 Modifier and Type Class Description static classNimbus.Client.Factory
-
Method Summary
-
-
-
Method Detail
-
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
public void send_killTopology(String name) throws org.apache.storm.thrift.TException
- 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
public void send_activate(String name) throws org.apache.storm.thrift.TException
- 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
public void send_deactivate(String name) throws org.apache.storm.thrift.TException
- 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
public void setLogConfig(String name, LogConfig config) throws org.apache.storm.thrift.TException
- 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
public LogConfig getLogConfig(String name) throws org.apache.storm.thrift.TException
- Specified by:
getLogConfigin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_getLogConfig
public void send_getLogConfig(String name) throws org.apache.storm.thrift.TException
- Throws:
org.apache.storm.thrift.TException
-
recv_getLogConfig
public LogConfig recv_getLogConfig() throws org.apache.storm.thrift.TException
- 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
public void send_beginUpdateBlob(String key) throws org.apache.storm.thrift.TException
- 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
public void send_finishBlobUpload(String session) throws org.apache.storm.thrift.TException
- 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
public void send_cancelBlobUpload(String session) throws org.apache.storm.thrift.TException
- 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
public void send_getBlobMeta(String key) throws org.apache.storm.thrift.TException
- 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
public void send_beginBlobDownload(String key) throws org.apache.storm.thrift.TException
- 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
public void send_downloadBlobChunk(String session) throws org.apache.storm.thrift.TException
- 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
public void send_deleteBlob(String key) throws org.apache.storm.thrift.TException
- 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
public ListBlobsResult listBlobs(String session) throws org.apache.storm.thrift.TException
- Specified by:
listBlobsin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_listBlobs
public void send_listBlobs(String session) throws org.apache.storm.thrift.TException
- Throws:
org.apache.storm.thrift.TException
-
recv_listBlobs
public ListBlobsResult recv_listBlobs() throws org.apache.storm.thrift.TException
- 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
public void send_getBlobReplication(String key) throws org.apache.storm.thrift.TException
- 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
public void createStateInZookeeper(String key) throws org.apache.storm.thrift.TException
- Specified by:
createStateInZookeeperin interfaceNimbus.Iface- Throws:
org.apache.storm.thrift.TException
-
send_createStateInZookeeper
public void send_createStateInZookeeper(String key) throws org.apache.storm.thrift.TException
- 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
public String beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException
- 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
public void recv_uploadChunk() throws AuthorizationException, org.apache.storm.thrift.TException- 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
public void send_finishFileUpload(String location) throws org.apache.storm.thrift.TException
- 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
public void send_downloadChunk(String id) throws org.apache.storm.thrift.TException
- 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
public String getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException
- 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
public void send_getTopologySummaryByName(String name) throws org.apache.storm.thrift.TException
- 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
public void send_getTopologySummary(String id) throws org.apache.storm.thrift.TException
- 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
public NimbusSummary getLeader() throws AuthorizationException, org.apache.storm.thrift.TException
- 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
public void send_isTopologyNameAllowed(String name) throws org.apache.storm.thrift.TException
- 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
public void send_getTopologyInfoByName(String name) throws org.apache.storm.thrift.TException
- 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
public void send_getTopologyInfo(String id) throws org.apache.storm.thrift.TException
- 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
public void send_getTopologyConf(String id) throws org.apache.storm.thrift.TException
- 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
public void send_getTopology(String id) throws org.apache.storm.thrift.TException
- 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
public void send_getUserTopology(String id) throws org.apache.storm.thrift.TException
- 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
public void send_getTopologyHistory(String user) throws org.apache.storm.thrift.TException
- 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
public void send_getOwnerResourceSummaries(String owner) throws org.apache.storm.thrift.TException
- 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
public void send_getSupervisorAssignments(String node) throws org.apache.storm.thrift.TException
- 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
public void processWorkerMetrics(WorkerMetrics metrics) throws org.apache.storm.thrift.TException
- 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
public void send_isRemoteBlobExists(String blobKey) throws org.apache.storm.thrift.TException
- 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
-
-