public static class Nimbus.Client extends org.apache.storm.thrift.TServiceClient implements Nimbus.Iface
| Modifier and Type | Class and Description |
|---|---|
static class |
Nimbus.Client.Factory |
| Constructor and Description |
|---|
Client(org.apache.storm.thrift.protocol.TProtocol prot) |
Client(org.apache.storm.thrift.protocol.TProtocol iprot,
org.apache.storm.thrift.protocol.TProtocol oprot) |
public Client(org.apache.storm.thrift.protocol.TProtocol prot)
public Client(org.apache.storm.thrift.protocol.TProtocol iprot,
org.apache.storm.thrift.protocol.TProtocol oprot)
public void submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
submitTopology in interface Nimbus.IfaceAlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_submitTopology(String name, String uploadedJarLocation, String jsonConf, StormTopology topology) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_submitTopology()
throws AlreadyAliveException,
InvalidTopologyException,
AuthorizationException,
org.apache.storm.thrift.TException
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws AlreadyAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
submitTopologyWithOpts in interface Nimbus.IfaceAlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_submitTopologyWithOpts(String name, String uploadedJarLocation, String jsonConf, StormTopology topology, SubmitOptions options) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_submitTopologyWithOpts()
throws AlreadyAliveException,
InvalidTopologyException,
AuthorizationException,
org.apache.storm.thrift.TException
AlreadyAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void killTopology(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
killTopology in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_killTopology(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_killTopology()
throws NotAliveException,
AuthorizationException,
org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void killTopologyWithOpts(String name, KillOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
killTopologyWithOpts in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_killTopologyWithOpts(String name, KillOptions options) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_killTopologyWithOpts()
throws NotAliveException,
AuthorizationException,
org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void activate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
activate in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_activate(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_activate()
throws NotAliveException,
AuthorizationException,
org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void deactivate(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
deactivate in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_deactivate(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_deactivate()
throws NotAliveException,
AuthorizationException,
org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void rebalance(String name, RebalanceOptions options) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
rebalance in interface Nimbus.IfaceNotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_rebalance(String name, RebalanceOptions options) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_rebalance()
throws NotAliveException,
InvalidTopologyException,
AuthorizationException,
org.apache.storm.thrift.TException
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void setLogConfig(String name, LogConfig config) throws org.apache.storm.thrift.TException
setLogConfig in interface Nimbus.Ifaceorg.apache.storm.thrift.TExceptionpublic void send_setLogConfig(String name, LogConfig config) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_setLogConfig()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic LogConfig getLogConfig(String name) throws org.apache.storm.thrift.TException
getLogConfig in interface Nimbus.Ifaceorg.apache.storm.thrift.TExceptionpublic void send_getLogConfig(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic LogConfig recv_getLogConfig() throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void debug(String name, String component, boolean enable, double samplingPercentage) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
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.
debug in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_debug(String name, String component, boolean enable, double samplingPercentage) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_debug()
throws NotAliveException,
AuthorizationException,
org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException
setWorkerProfiler in interface Nimbus.Ifaceorg.apache.storm.thrift.TExceptionpublic void send_setWorkerProfiler(String id, ProfileRequest profileRequest) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_setWorkerProfiler()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic List<ProfileRequest> getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException
getComponentPendingProfileActions in interface Nimbus.Ifaceorg.apache.storm.thrift.TExceptionpublic void send_getComponentPendingProfileActions(String id, String component_id, ProfileAction action) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic List<ProfileRequest> recv_getComponentPendingProfileActions() throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void uploadNewCredentials(String name, Credentials creds) throws NotAliveException, InvalidTopologyException, AuthorizationException, org.apache.storm.thrift.TException
uploadNewCredentials in interface Nimbus.IfaceNotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_uploadNewCredentials(String name, Credentials creds) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_uploadNewCredentials()
throws NotAliveException,
InvalidTopologyException,
AuthorizationException,
org.apache.storm.thrift.TException
NotAliveExceptionInvalidTopologyExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic String beginCreateBlob(String key, SettableBlobMeta meta) throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException
beginCreateBlob in interface Nimbus.IfaceAuthorizationExceptionKeyAlreadyExistsExceptionorg.apache.storm.thrift.TExceptionpublic void send_beginCreateBlob(String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic String recv_beginCreateBlob() throws AuthorizationException, KeyAlreadyExistsException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyAlreadyExistsExceptionorg.apache.storm.thrift.TExceptionpublic String beginUpdateBlob(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
beginUpdateBlob in interface Nimbus.IfaceAuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void send_beginUpdateBlob(String key) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic String recv_beginUpdateBlob() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void uploadBlobChunk(String session, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException
uploadBlobChunk in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_uploadBlobChunk(String session, ByteBuffer chunk) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_uploadBlobChunk()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void finishBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException
finishBlobUpload in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_finishBlobUpload(String session) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_finishBlobUpload()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void cancelBlobUpload(String session) throws AuthorizationException, org.apache.storm.thrift.TException
cancelBlobUpload in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_cancelBlobUpload(String session) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_cancelBlobUpload()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic ReadableBlobMeta getBlobMeta(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
getBlobMeta in interface Nimbus.IfaceAuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void send_getBlobMeta(String key) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic ReadableBlobMeta recv_getBlobMeta() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void setBlobMeta(String key, SettableBlobMeta meta) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
setBlobMeta in interface Nimbus.IfaceAuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void send_setBlobMeta(String key, SettableBlobMeta meta) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_setBlobMeta()
throws AuthorizationException,
KeyNotFoundException,
org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic BeginDownloadResult beginBlobDownload(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
beginBlobDownload in interface Nimbus.IfaceAuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void send_beginBlobDownload(String key) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic BeginDownloadResult recv_beginBlobDownload() throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic ByteBuffer downloadBlobChunk(String session) throws AuthorizationException, org.apache.storm.thrift.TException
downloadBlobChunk in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_downloadBlobChunk(String session) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic ByteBuffer recv_downloadBlobChunk() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void deleteBlob(String key) throws AuthorizationException, KeyNotFoundException, IllegalStateException, org.apache.storm.thrift.TException
deleteBlob in interface Nimbus.IfaceAuthorizationExceptionKeyNotFoundExceptionIllegalStateExceptionorg.apache.storm.thrift.TExceptionpublic void send_deleteBlob(String key) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_deleteBlob()
throws AuthorizationException,
KeyNotFoundException,
IllegalStateException,
org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionIllegalStateExceptionorg.apache.storm.thrift.TExceptionpublic ListBlobsResult listBlobs(String session) throws org.apache.storm.thrift.TException
listBlobs in interface Nimbus.Ifaceorg.apache.storm.thrift.TExceptionpublic void send_listBlobs(String session) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic ListBlobsResult recv_listBlobs() throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic int getBlobReplication(String key) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
getBlobReplication in interface Nimbus.IfaceAuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void send_getBlobReplication(String key) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic int recv_getBlobReplication()
throws AuthorizationException,
KeyNotFoundException,
org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic int updateBlobReplication(String key, int replication) throws AuthorizationException, KeyNotFoundException, org.apache.storm.thrift.TException
updateBlobReplication in interface Nimbus.IfaceAuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void send_updateBlobReplication(String key, int replication) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic int recv_updateBlobReplication()
throws AuthorizationException,
KeyNotFoundException,
org.apache.storm.thrift.TException
AuthorizationExceptionKeyNotFoundExceptionorg.apache.storm.thrift.TExceptionpublic void createStateInZookeeper(String key) throws org.apache.storm.thrift.TException
createStateInZookeeper in interface Nimbus.Ifaceorg.apache.storm.thrift.TExceptionpublic void send_createStateInZookeeper(String key) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_createStateInZookeeper()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic String beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException
beginFileUpload in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_beginFileUpload()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic String recv_beginFileUpload() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void uploadChunk(String location, ByteBuffer chunk) throws AuthorizationException, org.apache.storm.thrift.TException
uploadChunk in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_uploadChunk(String location, ByteBuffer chunk) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_uploadChunk()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void finishFileUpload(String location) throws AuthorizationException, org.apache.storm.thrift.TException
finishFileUpload in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_finishFileUpload(String location) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_finishFileUpload()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic ByteBuffer downloadChunk(String id) throws AuthorizationException, org.apache.storm.thrift.TException
downloadChunk in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_downloadChunk(String id) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic ByteBuffer recv_downloadChunk() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic String getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException
getNimbusConf in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getNimbusConf()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic String recv_getNimbusConf() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic ClusterSummary getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException
getClusterInfo in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getClusterInfo()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic ClusterSummary recv_getClusterInfo() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic List<TopologySummary> getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException
getTopologySummaries in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologySummaries()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic List<TopologySummary> recv_getTopologySummaries() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologySummary getTopologySummaryByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologySummaryByName in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologySummaryByName(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologySummary recv_getTopologySummaryByName() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologySummary getTopologySummary(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologySummary in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologySummary(String id) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologySummary recv_getTopologySummary() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic NimbusSummary getLeader() throws AuthorizationException, org.apache.storm.thrift.TException
getLeader in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getLeader()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic NimbusSummary recv_getLeader() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic boolean isTopologyNameAllowed(String name) throws AuthorizationException, org.apache.storm.thrift.TException
isTopologyNameAllowed in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_isTopologyNameAllowed(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic boolean recv_isTopologyNameAllowed()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologyInfo getTopologyInfoByName(String name) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologyInfoByName in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologyInfoByName(String name) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologyInfo recv_getTopologyInfoByName() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologyInfo getTopologyInfo(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologyInfo in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologyInfo(String id) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologyInfo recv_getTopologyInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologyInfo getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologyInfoByNameWithOpts in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologyInfoByNameWithOpts(String name, GetInfoOptions options) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologyInfo recv_getTopologyInfoByNameWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologyInfo getTopologyInfoWithOpts(String id, GetInfoOptions options) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologyInfoWithOpts in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologyInfoWithOpts(String id, GetInfoOptions options) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologyInfo recv_getTopologyInfoWithOpts() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologyPageInfo getTopologyPageInfo(String id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologyPageInfo in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologyPageInfo(String id, String window, boolean is_include_sys) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologyPageInfo recv_getTopologyPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic SupervisorPageInfo getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getSupervisorPageInfo in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getSupervisorPageInfo(String id, String host, boolean is_include_sys) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic SupervisorPageInfo recv_getSupervisorPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic ComponentPageInfo getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getComponentPageInfo in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getComponentPageInfo(String topology_id, String component_id, String window, boolean is_include_sys) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic ComponentPageInfo recv_getComponentPageInfo() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic String getTopologyConf(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
getTopologyConf in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologyConf(String id) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic String recv_getTopologyConf() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic StormTopology getTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
Nimbus.IfaceReturns the compiled topology that contains ackers and metrics consumsers. Compare Nimbus.Iface.getUserTopology(String id).
getTopology in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopology(String id) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic StormTopology recv_getTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic StormTopology getUserTopology(String id) throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
Nimbus.IfaceReturns the user specified topology as submitted originally. Compare Nimbus.Iface.getTopology(String id).
getUserTopology in interface Nimbus.IfaceNotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getUserTopology(String id) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic StormTopology recv_getUserTopology() throws NotAliveException, AuthorizationException, org.apache.storm.thrift.TException
NotAliveExceptionAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic TopologyHistoryInfo getTopologyHistory(String user) throws AuthorizationException, org.apache.storm.thrift.TException
getTopologyHistory in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getTopologyHistory(String user) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic TopologyHistoryInfo recv_getTopologyHistory() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic List<OwnerResourceSummary> getOwnerResourceSummaries(String owner) throws AuthorizationException, org.apache.storm.thrift.TException
getOwnerResourceSummaries in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getOwnerResourceSummaries(String owner) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic List<OwnerResourceSummary> recv_getOwnerResourceSummaries() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic SupervisorAssignments getSupervisorAssignments(String node) throws AuthorizationException, org.apache.storm.thrift.TException
Nimbus.IfaceGet assigned assignments for a specific supervisor
getSupervisorAssignments in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_getSupervisorAssignments(String node) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic SupervisorAssignments recv_getSupervisorAssignments() throws AuthorizationException, org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws AuthorizationException, org.apache.storm.thrift.TException
Nimbus.IfaceSend supervisor worker heartbeats for a specific supervisor
sendSupervisorWorkerHeartbeats in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_sendSupervisorWorkerHeartbeats(SupervisorWorkerHeartbeats heartbeats) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_sendSupervisorWorkerHeartbeats()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws AuthorizationException, NotAliveException, org.apache.storm.thrift.TException
Nimbus.IfaceSend supervisor local worker heartbeat when a supervisor is unreachable
sendSupervisorWorkerHeartbeat in interface Nimbus.IfaceAuthorizationExceptionNotAliveExceptionorg.apache.storm.thrift.TExceptionpublic void send_sendSupervisorWorkerHeartbeat(SupervisorWorkerHeartbeat heatbeat) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_sendSupervisorWorkerHeartbeat()
throws AuthorizationException,
NotAliveException,
org.apache.storm.thrift.TException
AuthorizationExceptionNotAliveExceptionorg.apache.storm.thrift.TExceptionpublic void processWorkerMetrics(WorkerMetrics metrics) throws org.apache.storm.thrift.TException
processWorkerMetrics in interface Nimbus.Ifaceorg.apache.storm.thrift.TExceptionpublic void send_processWorkerMetrics(WorkerMetrics metrics) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic void recv_processWorkerMetrics()
throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic boolean isRemoteBlobExists(String blobKey) throws AuthorizationException, org.apache.storm.thrift.TException
Nimbus.IfaceDecide if the blob is removed from cluster.
isRemoteBlobExists in interface Nimbus.IfaceAuthorizationExceptionorg.apache.storm.thrift.TExceptionpublic void send_isRemoteBlobExists(String blobKey) throws org.apache.storm.thrift.TException
org.apache.storm.thrift.TExceptionpublic boolean recv_isRemoteBlobExists()
throws AuthorizationException,
org.apache.storm.thrift.TException
AuthorizationExceptionorg.apache.storm.thrift.TExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.